公开(公告)号：US11630844B2

公开(公告)日：2023-04-18

申请号：US17248574

申请日：2021-01-29

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Birva Joshi ,  Shan-Cheng Ho ,  Mahalaxmi Sanathkumar ,  Priya Sethuraman

IPC: G06F16/27 ,  G06F16/23

Abstract: A method of syncing data across multiple systems includes: receiving a plurality of calendar events from a plurality of independent calendar systems that use different calendar system specific schemas; aggregating the calendar events at a unifying communication system; converting the calendar events from a calendar system specific schema to a unifying communication system specific schema; storing the plurality of calendar events in the unifying communication system specific schema; converting a calendar event received from a non-master calendar system to the master calendar system specific schema; and sending the converted calendar event to the master calendar system; wherein copies of the received calendar events that are formatted according to the calendar system specific schema of the master calendar system are stored with the master calendar system, and copies of the calendar events that are formatted according to the unifying communication system specific schema are stored with the unifying communication system.

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

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

公开(公告)号：US11609886B2

公开(公告)日：2023-03-21

申请号：US16779395

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/21 ,  G06F16/27 ,  G06F16/215 ,  G06F9/54 ,  G06N7/00

Abstract: A method and system of data deduplication for data streams in a multi-tenant system. The method receives, at a data accuracy manager, an event from an activity tracking component, determine whether the event is recorded in a probabilistic model that tracks previously received events from the activity tracking component, where the probabilistic model can accurately identify the event has not been previously received with a possible false positive response where the event has been previously received, determines whether information for the event is stored in a metric storage, where the metric storage is a database of metrics derived from the previously received events, and discards the event in response to determining that the event is recorded in the probabilistic model and in the metric storage.

公开(公告)号：US20220345458A1

公开(公告)日：2022-10-27

申请号：US17238180

申请日：2021-04-22

Applicant: salesforce.com, inc.

Inventor： Jayanth Parayil Kumarji ,  Priyadarshini Mitra ,  Kevin Terusaki ,  Zhidong Ke ,  Yifeng Liu ,  Utsavi Benani ,  Heng Zhang ,  Evan Jiang ,  Birva Joshi ,  Yogesh Patel

IPC: H04L29/06

Abstract: Various techniques and mechanisms for sharing remote resources among a trusted group are disclosed. A credential management agent utilizes a resource credential for a first user to access a secure resource corresponding to the first user for a second user by at least validating a second user and validating a consent of the first user to allow the second user to access the secure resource using the resource credential for the first user. The secure resource resides on a remote server system accessible via one or more application program interfaces (APIs). A platform management agent provides an interface for shared resource-agnostic credential sharing. The platform management agent validates credentials for the second user as belonging to a trusted group and forwards a request for access to the secure resource for the second user to the credential management agent. In response to receiving the resource credential for the first user to access the secure resource, the platform management agent accesses the secure resource on behalf of the second user to allow the second user to utilize the secure resource.

公开(公告)号：US20210240679A1

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

申请号：US16779395

申请日：2020-01-31

Applicant: Salesforce.Com, Inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06N7/00 ,  G06F9/54

Abstract: A method and system of data deduplication for data streams in a multi-tenant system. The method receives, at a data accuracy manager, an event from an activity tracking component, determine whether the event is recorded in a probabilistic model that tracks previously received events from the activity tracking component, where the probabilistic model can accurately identify the event has not been previously received with a possible false positive response where the event has been previously received, determines whether information for the event is stored in a metric storage, where the metric storage is a database of metrics derived from the previously received events, and discards the event in response to determining that the event is recorded in the probabilistic model and in the metric storage.

公开(公告)号：US20210240678A1

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

申请号：US16779386

申请日：2020-01-31

Applicant: Salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06F16/28 ,  G06F16/27

Abstract: A method enables data aggregation in a multi-tenant system. The method includes receiving, at a data aggregation manager, an event from an activity tracking component, generating, by the data aggregation manager, a first hash value based on a first identifier in the event, generating, by the data aggregation manager, a second hash value based on a second identifier in the event, and storing event message information to an entry of a metric storage database in a partition according the first hash value and the second hash value.

公开(公告)号：US11601495B2

公开(公告)日：2023-03-07

申请号：US16779418

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Shardul Vikram ,  Mattia Padovani

IPC: H04L67/10 ,  H04W24/10 ,  G06F16/22 ,  G06F9/48 ,  H04W4/029 ,  G06F9/50

Abstract: A method and system that perform cluster node work assignments for tenants in a multi-tenant system. The method includes selecting a partition of a cluster tenant tracking structure having a hierarchical namespace and virtual nodes representing each tenant by a cluster node foreman controller, searching the selected partition for a tenant that is unlocked in the cluster tenant tracking structure, and initiating work for the tenant by the cluster node.

公开(公告)号：US11537572B2

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

申请号：US16779386

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06F16/27 ,  G06F16/28

Abstract: A method enables data aggregation in a multi-tenant system. The method includes receiving, at a data aggregation manager, an event from an activity tracking component, generating, by the data aggregation manager, a first hash value based on a first identifier in the event, generating, by the data aggregation manager, a second hash value based on a second identifier in the event, and storing event message information to an entry of a metric storage database in a partition according the first hash value and the second hash value.