-
公开(公告)号: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
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.
-
公开(公告)号:US11032385B2
公开(公告)日:2021-06-08
申请号:US17024180
申请日:2020-09-17
Applicant: salesforce.com, inc.
Inventor: Sivananda Reddy Thummala Abbigari , Lawrence Eugenio McAlpin , Vikram Kommaraju , John Arlan Brock , Soumen Bandyopadhyay
IPC: G06F15/173 , H04L29/08 , H04L12/58
Abstract: Implementations are described which provide for recipient-based filtering of an event that relates to a topic to which consumers are subscribed. Responsive to determining that an attribute of the event includes a set of one or more identifiers for intended recipients for the event, the event is delivered to consumers that correspond to the intended recipients. Alternatively, responsive to determining that the attribute of the event does not include a set of one or more identifiers for intended recipients for the event, the event is delivered to all of the consumers subscribed to the topic to which the event relates.
-
公开(公告)号:US10298582B2
公开(公告)日:2019-05-21
申请号:US15158277
申请日:2016-05-18
Applicant: salesforce.com, inc.
Abstract: Controlling access to sensitive data can be difficult during an application development effort. A developer may not be authorized to see the data that is to be used by the application. Credentials used in a development environment to access development data can require modification when the application is migrated to a deployed environment. Changing the code in the deployed environment increases risks of change induced incidents. The technology disclosed allows for the creation of a named credential object, where the credentials for different environments are stored, and where the named credential object is called by metadata. This allows the promotion of code from a development environment to a deployed environment without changes to code, and without giving access to sensitive data to the developer.
-
公开(公告)号:US11599526B2
公开(公告)日:2023-03-07
申请号:US16671151
申请日:2019-10-31
Applicant: salesforce.com, inc.
Inventor: Sivananda Reddy Thummala Abbigari , Lawrence Eugenio McAlpin , Vikram Kommaraju , John Arlan Brock , Soumen Bandyopadhyay
IPC: G06F16/23
Abstract: Implementations are described for selectively publishing an event responsive to an operation on a database in a transaction. Publishing the event is delayed or not delayed respectively, responsive to determining that a value of an attribute for the event indicates that publishing the event is to be delayed, or not to be delayed, until the transaction is rolled back or committed. If publishing the event is delayed, the event is published if the transaction is committed and discarded if the transaction is rolled back. If publishing the event is not delayed, the event is published. Optionally, if the event is published, the event is published in a database or a datastore respectively, responsive to determining whether another value of another attribute for the event indicates that the event is to be published in a database or a datastore.
-
公开(公告)号: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.
-
公开(公告)号:US11416476B2
公开(公告)日:2022-08-16
申请号:US16671162
申请日:2019-10-31
Applicant: salesforce.com, inc.
Inventor: Sivananda Reddy Thummala Abbigari , Lawrence Eugenio McAlpin , Vikram Kommaraju , Pulkit Mehta , Alexey Syomichev , Soumen Bandyopadhyay
Abstract: Implementations store an event associated with a topic in a database to allow for the event to be transmitted in order with respect to other events associated with the topic which are stored in the database. A commit of a transaction is performed that includes inserting the event's payload in a record in a database object. After the commit, a field for the record is updated with an identifier of the commit. The identifier and identifiers of other commits of other transactions on the database indicate ordering of the commit with respect to the other commits. Another field of another record is updated based on the identifier and a last stored value such that the payloads of the event and of the other events are retrievable to be transmitted in an order based on the value of the other field and values of other fields of other records.
-
公开(公告)号: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.
-
公开(公告)号:US20210136166A1
公开(公告)日:2021-05-06
申请号:US17024180
申请日:2020-09-17
Applicant: salesforce.com, inc.
Inventor: Sivananda Reddy Thummala Abbigari , Lawrence Eugenio McAlpin , Vikram Kommaraju , John Arlan Brock , Soumen Bandyopadhyay
Abstract: Implementations are described which provide for recipient-based filtering of an event that relates to a topic to which consumers are subscribed. Responsive to determining that an attribute of the event includes a set of one or more identifiers for intended recipients for the event, the event is delivered to consumers that correspond to the intended recipients. Alternatively, responsive to determining that the attribute of the event does not include a set of one or more identifiers for intended recipients for the event, the event is delivered to all of the consumers subscribed to the topic to which the event relates.
-
-
-
-
-
-
-
-
-