-
公开(公告)号:US20200287718A1
公开(公告)日:2020-09-10
申请号:US16294646
申请日:2019-03-06
Applicant: Salesforce.com, Inc.
Inventor: Hal Scott Hildebrand , Prithvi Krishnan Padmanabhan
Abstract: For each data value associated with a data object, a respective object value identification query message that includes the data value may be sent to each of a plurality of identity nodes via a network. For each of the data values, a respective object value identification response message that includes a respective network identifier corresponding with the respective data value may be received. A local identifier may be determined based on the object value identification response messages, and a response query message including the local identifier may be transmitted.
-
公开(公告)号:US10776825B2
公开(公告)日:2020-09-15
申请号:US16037261
申请日:2018-07-17
Applicant: salesforce.com, inc.
Inventor: Yingwu Zhao , Hal Scott Hildebrand , Lawrence McAlpin , Alex Warshavsky
Abstract: A processor can cause a first communication, to a user device, of a first item based on an eventing system being in a first mode, a configuration to cause the eventing system to cause, without a request from the user device, a communication of an item to the user device in response to an entry of the item into a memory. After the first communication, the processor can cause the eventing system to be in a second mode, a configuration to cause the eventing system to refrain from communications of items to the user device. The processor can receive, from the user device, a signal to cause the eventing system to switch from the second mode to the first mode. After receiving the signal, a second item can be entered into the information memory. The processor can cause a second communication, to the user device, of the second item.
-
公开(公告)号:US10409650B2
公开(公告)日:2019-09-10
申请号:US15052822
申请日:2016-02-24
Applicant: salesforce.com, inc.
Inventor: Yingwu Zhao , Hal Scott Hildebrand
Abstract: The technology disclosed relates to discovering a previously unknown attribute of stream processing systems according to which client offsets or client subscription queries for a streaming data store rapidly converge to a dynamic tip of a data stream that includes the most recent messages or events. In particular, it relates to grouping clients into bins to reduce a number of queries to the streaming data store by several orders of magnitude when servicing tens, hundreds, thousands or millions of clients. The bin count is further reduced by coalescing bins that have overlapping offsets. It also relates to establishing separate caches only for the current tips of data streams and serving the bins from the caches instead of the backend data store using group queries. Further, the caches are periodically updated to include the most recent messages or events appended to the dynamic tips of the data streams.
-
公开(公告)号:US11128465B2
公开(公告)日:2021-09-21
申请号:US16294654
申请日:2019-03-06
Applicant: Salesforce.com, Inc.
Inventor: Hal Scott Hildebrand , Prithvi Krishnan Padmanabhan
Abstract: A request to identify a data value may be received via a network at a designated one of a plurality of identity nodes. A query that includes the data value may be transmitted to an identity service associated with the designated identity node. A response message from the identity service may include one or more designated network identifiers corresponding with the data value. The designated identity node may communicate with the plurality of identity nodes to identify a plurality of network identifiers corresponding with the data value. A trust ledger may be updated to include a correspondence between a selected one of the network identifiers and the data value.
-
公开(公告)号: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.
-
公开(公告)号:US20170242887A1
公开(公告)日:2017-08-24
申请号:US15052822
申请日:2016-02-24
Applicant: salesforce.com, inc.
Inventor: Yingwu ZHAO , Hal Scott Hildebrand
CPC classification number: G06F9/5083
Abstract: The technology disclosed relates to discovering a previously unknown attribute of stream processing systems according to which client offsets or client subscription queries for a streaming data store rapidly converge to a dynamic tip of a data stream that includes the most recent messages or events. In particular, it relates to grouping clients into bins to reduce a number of queries to the streaming data store by several orders of magnitude when servicing tens, hundreds, thousands or millions of clients. The bin count is further reduced by coalescing bins that have overlapping offsets. It also relates to establishing separate caches only for the current tips of data streams and serving the bins from the caches instead of the backend data store using group queries. Further, the caches are periodically updated to include the most recent messages or events appended to the dynamic tips of the data streams.
-
公开(公告)号:US11082226B2
公开(公告)日:2021-08-03
申请号:US16294646
申请日:2019-03-06
Applicant: Salesforce.com, Inc.
Inventor: Hal Scott Hildebrand , Prithvi Krishnan Padmanabhan
Abstract: For each data value associated with a data object, a respective object value identification query message that includes the data value may be sent to each of a plurality of identity nodes via a network. For each of the data values, a respective object value identification response message that includes a respective network identifier corresponding with the respective data value may be received. A local identifier may be determined based on the object value identification response messages, and a response query message including the local identifier may be transmitted.
-
公开(公告)号:US20200287719A1
公开(公告)日:2020-09-10
申请号:US16294654
申请日:2019-03-06
Applicant: Salesforce.com, Inc.
Inventor: Hal Scott Hildebrand , Prithvi Krishnan Padmanabhan
Abstract: A request to identify a data value may be received via a network at a designated one of a plurality of identity nodes. A query that includes the data value may be transmitted to an identity service associated with the designated identity node. A response message from the identity service may include one or more designated network identifiers corresponding with the data value. The designated identity node may communicate with the plurality of identity nodes to identify a plurality of network identifiers corresponding with the data value. A trust ledger may be updated to include a correspondence between a selected one of the network identifiers and the data value.
-
公开(公告)号:US20200097503A1
公开(公告)日:2020-03-26
申请号:US16203544
申请日:2018-11-28
Applicant: salesforce.com, inc.
Inventor: Yingwu Zhao , Hal Scott Hildebrand
IPC: G06F16/907 , G06F9/54 , G06F16/903
Abstract: A method for enabling event consumption is described. Upon receipt of a request for events associated with a first initial topic, a determination that the request includes a request for historical events is performed. Responsive to determining that one or more rules apply to the request for historical events, a determination of a first path from the first initial topic to a first aggregate topic is performed based on the one or more rules. The first path is different from a second path from the first initial topic to a second aggregate topic that is defined according to a current multiplexed framework definition. The current multiplexed framework definition is used for storing new events associated with the first initial topic in a second multiplexed event recordation system at a time that follows the time of receipt of the request. A first set of historical events is retrieved based on the first path.
-
公开(公告)号:US20200027126A1
公开(公告)日:2020-01-23
申请号:US16037261
申请日:2018-07-17
Applicant: salesforce.com, inc.
Inventor: Yingwu Zhao , Hal Scott Hildebrand , Lawrence McAlpin , Alex Warshavsky
IPC: G06Q30/02
Abstract: A processor can cause a first communication, to a user device, of a first item based on an eventing system being in a first mode, a configuration to cause the eventing system to cause, without a request from the user device, a communication of an item to the user device in response to an entry of the item into a memory. After the first communication, the processor can cause the eventing system to be in a second mode, a configuration to cause the eventing system to refrain from communications of items to the user device. The processor can receive, from the user device, a signal to cause the eventing system to switch from the second mode to the first mode. After receiving the signal, a second item can be entered into the information memory. The processor can cause a second communication, to the user device, of the second item.
-
-
-
-
-
-
-
-
-