公开(公告)号：US11385945B2

公开(公告)日：2022-07-12

申请号：US16208388

申请日：2018-12-03

Applicant: salesforce.com, inc.

Inventor： Alex S. Warshavsky ,  Lawrence Eugenio McAlpin ,  Alexey Syomichev

IPC: G06F9/54 ,  G06F16/2455 ,  G06F9/455 ,  G06F16/958

Abstract: A method and system for event consumers management are described. A batch of events that is stored in an event recordation system according to an aggregate topic is received based on the aggregate topic. Each event from the batch of events is associated with an initial topic to be used by a respective instance of an event consumer from a set of event consumers to consume events. A first initial topic associated with one or more events from the batch of events is determined. Based on the first initial topic, a state of a first event consumer is updated to a running state. The updated state of the first event consumer causes execution of a first instance of the first event consumer on a server of a cluster of servers for consuming events from the event recordation system based on the first initial topic.

公开(公告)号：US11044336B2

公开(公告)日：2021-06-22

申请号：US15882863

申请日：2018-01-29

Applicant: salesforce.com, inc.

Inventor： Alexey Syomichev ,  David Angulo

IPC: H04L29/08 ,  G06F3/06 ,  G06F16/25 ,  G06F16/17 ,  G06F16/182

Abstract: A software application executing on a selected application server in a cluster of application servers stores in a buffer in a memory of the selected application server a payload of data and a corresponding key. The application transfers a copy of the payload of data and the corresponding key to a selected second application server in the cluster, and creates a record in an entry in a transaction log stored in a database to which the cluster of applications servers has access, the record including: the corresponding key, a first value identifying the selected second application server to which the copy of the payload of data and corresponding key were transferred, and a second value identifying the selected first application server in which the payload of data and corresponding key were stored.

公开(公告)号：US10783044B2

公开(公告)日：2020-09-22

申请号：US16222925

申请日：2018-12-17

Applicant: salesforce.com, inc.

Inventor： Yingwu Zhao ,  Samarpan Jain ,  Hal Scott Hildebrand ,  Alexey Syomichev ,  Emin Eliot Gerba ,  Igor Pesenson ,  David William Spragg ,  Jay Hurst ,  Soumen Bandyopadhyay

IPC: G06F11/14

Abstract: A method and apparatus for a mechanism of disaster recovery and instance refresh in an event recordation system are described. A first request for events associated with a first topic is received. A first set of events associated with the first topic are retrieved from a primary event recordation system. Each event from the first set of events includes a first commit identifier indicating the order with which each event is stored in the primary event recordation system. For each event from the first set of events a first replay identifier is determined based on the first commit identifier and a first value of a low commit identifier. The first replay identifier is exposed to event consumers for identifying the event. In response to the first request each event from the first set of events is transmitted with the replay identifier.