-
公开(公告)号:US10708388B2
公开(公告)日:2020-07-07
申请号:US16229920
申请日:2018-12-21
Applicant: salesforce.com, inc.
Inventor: Stephen Hsu , Ashwin Kashyap , Cassandra Funk , Laurel Knell , Eric Berg , Martin Edward Long , Avital Arora , Stanley Lemon , William Victor Gray , Philip Alexander Waligora , Reena Parekh , Kyle Coleman Skibble
Abstract: Methods, systems, and devices for defining an action node series at a database system are described. In some examples, the workflow may include one or more nodes are associated with an action. When executed, the workflow may produce an outcome based on the occurrence of an event or parameter associated with the one or more nodes. In some examples, the workflow may include one or more branch nodes. A branch node may include logic such that, when the workflow is executed, the logic selects a particular workflow path that includes its own specific nodes. The path may be selected based on the occurrence of an event or a value of one or more parameters. Thus, when a workflow including one or more branch nodes is executed, the outcome of the workflow may be based on the occurrence of the event or the value of the parameter.
-
公开(公告)号:US20190238605A1
公开(公告)日:2019-08-01
申请号:US15884946
申请日:2018-01-31
Applicant: salesforce.com, inc.
Inventor: Yogesh Patel , Mahalaxmi Sanathkumar , Shaahin Mehdinezhad Rushan , William Victor Gray , Bhaves Patel , Shreedhar Sundaram , Rajkumar Pellakuru , William Edward Hackett , Avital Arora
CPC classification number: H04L65/4069 , G06F16/24568 , H04L51/24 , H04L67/26
Abstract: Techniques are disclosed relating to verifying the sequence of messages sent via data streaming systems. In some embodiments, a streaming server system may receive a plurality of messages associated with events at a data storage system that is accessible to various groups of users. In some embodiments, each of the plurality of messages may include an event identifier for an associated event and a group-specific sequence number. The streaming server system may detect, based on group-specific sequence numbers included in a set of messages, that a particular message for a particular group has not been received. The streaming server system may send, to the data storage system, a request for the particular message and, in response to the request, may receive the particular message from the data storage system.
-
公开(公告)号:US20190163791A1
公开(公告)日:2019-05-30
申请号:US15828182
申请日:2017-11-30
Applicant: salesforce.com, inc.
Inventor: Mahalaxmi Sanathkumar , Yogesh Patel , Shaahin Mehdinezhad Rushan , William Victor Gray , William Edward Hackett , Shreedhar Sundaram , Rajkumar Pellakuru , Anjani Gupta , Chandra S. Chadalavada
IPC: G06F17/30
Abstract: Dynamic selection of data sources for streaming dynamic data is described. A data streaming service receives a dynamic selection of a data source after the data streaming service begins executing, the dynamic selection of the data source including an identifier of a host of a multi-tenant database and an identifier of a tenant of multiple tenants storing data in the multi-tenant database. The data streaming service streams dynamic data from the data source to a data destination.
-
公开(公告)号:US11321139B2
公开(公告)日:2022-05-03
申请号:US15994162
申请日:2018-05-31
Applicant: salesforce.com, inc.
Inventor: Yogesh Patel , William Victor Gray , William Hackett , Shaahin Mehdinezhad Rushan , Johannes Kienzle , Shreedhar Sundaram , Mahalaxmi Sanathkumar , Rajkumar Pellakuru , Bhaves Patel , Bertha Ching Wai Lam
IPC: G06F9/50 , G06F9/455 , H04L12/26 , H04L43/067 , H04L43/0876 , H04L43/065
Abstract: A total number of messages in a set of messages that are processed by a computing node in a virtual computer cluster during a time interval is determined. The virtual computer cluster is deployed with a cloud computing service and includes the computing node and other computing nodes at an end time of the time interval. It is determined whether the total number of messages in the set of messages processed by the computing node is no less than a maximum per-interval message number threshold. In response to determining that the total number of messages is no less than a maximum per-interval message number threshold, the cloud computing service is caused to start an additional computing node in the virtual computer cluster after the time interval, wherein the additional computing node is used to process one or more subsequent messages to be processed after the time interval.
-
公开(公告)号:US20210037073A1
公开(公告)日:2021-02-04
申请号:US17074459
申请日:2020-10-19
Applicant: salesforce.com, inc.
Inventor: Shreedhar Sundaram , Yogesh Patel , William Victor Gray , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , Anjani Gupta , Rajkumar Pellakuru , Bhaves Patel , William Edward Hackett
IPC: H04L29/06 , H04L12/911
Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.
-
公开(公告)号:US20200099771A1
公开(公告)日:2020-03-26
申请号:US16229920
申请日:2018-12-21
Applicant: salesforce.com, inc.
Inventor: Stephen Hsu , Ashwin Kashyap , Cassandra Funk , Laurel Knell , Eric Berg , Martin Edward Long , Avital Arora , Stanley Lemon , William Victor Gray , Philip Alexander Waligora , Reena Parekh , Kyle Coleman Skibble
IPC: H04L29/08
Abstract: Methods, systems, and devices for defining an action node series at a database system are described. In some examples, the workflow may include one or more nodes are associated with an action. When executed, the workflow may produce an outcome based on the occurrence of an event or parameter associated with the one or more nodes. In some examples, the workflow may include one or more branch nodes. A branch node may include logic such that, when the workflow is executed, the logic selects a particular workflow path that includes its own specific nodes. The path may be selected based on the occurrence of an event or a value of one or more parameters. Thus, when a workflow including one or more branch nodes is executed, the outcome of the workflow may be based on the occurrence of the event or the value of the parameter.
-
公开(公告)号:US20190238604A1
公开(公告)日:2019-08-01
申请号:US15881665
申请日:2018-01-26
Applicant: salesforce.com, inc.
Inventor: Shreedhar Sundaram , Yogesh Patel , William Victor Gray , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , Anjani Gupta , Rajkumar Pellakuru , Bhaves Patel , William Edward Hackett
IPC: H04L29/06
Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.
-
公开(公告)号:US10282352B2
公开(公告)日:2019-05-07
申请号:US15145436
申请日:2016-05-03
Applicant: salesforce.com, inc.
Inventor: William Victor Gray
Abstract: Database clients submit junction data (such as invitees to a meeting or other event) at the same time that a new database entity is created. Junction data may be represented within a string array or other data structure that can be delivered using a SOAP, REST or similar protocol for delivering data to the computing server platform. By submitting junction data within the same structure that is used to create the new entity, the likelihood of phantom data or other corruption in the database is greatly reduced.
-
-
-
-
-
-
-