公开(公告)号：US20200174854A1

公开(公告)日：2020-06-04

申请号：US16208388

申请日：2018-12-03

Applicant: salesforce.com, inc.

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

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

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.

公开(公告)号：US20210144440A1

公开(公告)日：2021-05-13

申请号：US16678962

申请日：2019-11-08

Applicant: salesforce.com, inc.

Inventor： Dan Li ,  Lawrence Eugenio McAlpin ,  Brian St. Clair ,  Alex S. Warshavsky

IPC: H04N21/454 ,  G06F16/735 ,  H04N21/262 ,  G06F9/54 ,  G06F16/78 ,  H04L29/06 ,  H04N21/258 ,  H04N21/2668

Abstract: A method of per subscription event filtering is provided for an event recordation and distribution system. The method includes receiving an event from the event recordation and distribution system, determining that an event consumer that is a subscriber of an event stream of the event has specified filter logic for the event stream, and forwarding the event to an event consumer in response to the event meeting requirements of the specified filter logic.

公开(公告)号：US20210141679A1

公开(公告)日：2021-05-13

申请号：US16678946

申请日：2019-11-08

Applicant: salesforce.com, inc.

Inventor： Dan Li ,  Lawrence Eugenio McAlpin ,  Brian St. Clair ,  Alex S. Warshavsky

IPC: G06F11/00 ,  G06F9/54

Abstract: A method for failure event notification in an event recordation and distribution system. The method including monitoring each stage of processing of an event by an event publisher manager, detecting a failure of the event to publish in the event recordation and distribution system, and publishing an error event notification to a status stream in response to detecting the failure.

公开(公告)号：US10776186B2

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

申请号：US16273117

申请日：2019-02-11

Applicant: salesforce.com, inc.

Inventor： Brian St. Clair ,  Alex S. Warshavsky ,  John Arlan Brock

IPC: G06K17/00 ,  G06F9/54 ,  G06F16/2458 ,  G06F16/2455

Abstract: A method and system for event delivery are described. A batch of events for a first topic with replay identifiers is received. Responsive to determining that there is an active replay identifier discontinuity information for the first topic, a determination is performed of whether the first batch of events includes a second set of events that fills the discontinuity identified in the replay identifier discontinuity information. Upon determining that the first batch of events includes a second subset of events with second respective replay identifiers that start from the last replay identifier and do not include a discontinuity the second subset of events is transmitted to an event consumer, and the replay identifier discontinuity information for the first topic is updated based on the second subset of events transmitted.

公开(公告)号：US11533538B2

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

申请号：US16678962

申请日：2019-11-08

Applicant: salesforce.com, inc.

Inventor： Dan Li ,  Lawrence Eugenio McAlpin ,  Brian St. Clair ,  Alex S. Warshavsky

IPC: H04N21/239 ,  H04N21/2543 ,  H04N21/262 ,  H04N21/454 ,  G06F16/735 ,  H04N21/2668 ,  G06F16/78 ,  H04N21/258 ,  G06F9/54 ,  H04L65/61

Abstract: A method of per subscription event filtering is provided for an event recordation and distribution system. The method includes receiving an event from the event recordation and distribution system, determining that an event consumer that is a subscriber of an event stream of the event has specified filter logic for the event stream, and forwarding the event to an event consumer in response to the event meeting requirements of the specified filter logic.

公开(公告)号：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.

公开(公告)号：US20200257574A1

公开(公告)日：2020-08-13

申请号：US16273117

申请日：2019-02-11

Applicant: salesforce.com, inc.

Inventor： Brian St. Clair ,  Alex S. Warshavsky ,  John Arlan Brock

IPC: G06F9/54 ,  G06F16/2455 ,  G06F16/2458

Abstract: A method and system for event delivery are described. A batch of events for a first topic with replay identifiers is received. Responsive to determining that there is an active replay identifier discontinuity information for the first topic, a determination is performed of whether the first batch of events includes a second set of events that fills the discontinuity identified in the replay identifier discontinuity information. Upon determining that the first batch of events includes a second subset of events with second respective replay identifiers that start from the last replay identifier and do not include a discontinuity the second subset of events is transmitted to an event consumer, and the replay identifier discontinuity information for the first topic is updated based on the second subset of events transmitted.