公开(公告)号：US20230143636A1

公开(公告)日：2023-05-11

申请号：US17454585

申请日：2021-11-11

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Igor Fedorenko

IPC: G06F16/23 ,  G06F16/2455 ,  G06F16/25 ,  G06F16/21

CPC classification number: G06F16/2358 ,  G06F16/24568 ,  G06F16/256 ,  G06F16/219

Abstract: Techniques are disclosed relating to methods that include receiving, by a computer system in a multi-tenant database service, a stream of change event records for a database on a server. A given change event record may be indicative of a modification made to the database by one of a plurality of tenants. The methods may further include storing the received change event records in one or more buffers, and tracking, in a data structure separate from the one or more buffers. Information for ones of the stored change event records may include a corresponding order of reception and a particular tenant associated with a respective change event record. In response to receiving a query from a given tenant, the methods may include processing the query using the data structure to identify change event records associated with the given tenant.

公开(公告)号：US20210390105A1

公开(公告)日：2021-12-16

申请号：US17446197

申请日：2021-08-27

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi

IPC: G06F16/2455 ,  G06F16/22 ,  G06F16/23

Abstract: Techniques are disclosed relating to caching techniques for processing a database change stream. A computer system may receive change records from a change stream that includes a plurality of records indicating changes to a database table. The change stream may include change records for multiple shards and be accessible by providing one or more position indicators for one or more of the multiple shards to request one or more change records and an updated position indicator. The system may store, for changes to a set of one or more shards, one or more cache entries that include respective groups of change records. The system may request a portion of the change stream by providing a received position indicator. The system may provide one or more cached change records from a cache entry that matches the provided position indicator.

公开(公告)号：US10608961B2

公开(公告)日：2020-03-31

申请号：US15974283

申请日：2018-05-08

Applicant: salesforce.com, inc.

Inventor： Helen Kwong ,  Benjamin Busjaeger

IPC: H04L12/861 ,  H04L29/08

Abstract: Techniques are disclosed relating to handling queues. A server-based platform, in some embodiments, accesses queue information that includes performance attributes for a plurality of queues storing one or more messages corresponding to one or more applications. In some embodiments, the platform assigns, based on the performance attributes, a corresponding set of the plurality of queues to each of a plurality of processing nodes of the platform. In some embodiments, the assigning of a corresponding set of queues to a given one of the plurality of processing nodes causes instantiation of: a first set of one or more dequeuing threads and a second set of one or more processing threads. The dequeuing threads may be executable to dequeue one or more messages stored in the corresponding set of queues. The processing threads may be executable to perform one or more tasks specified in the dequeued one or more messages.