Clustering framework for distributing workloads across nodes of a cluster
AssigneeItron, Inc.
InventorsChristopher MOCK, Joseph MARTIN
Life of this patent
Estimating the term…
Abstract
Various embodiments disclose a method comprising obtaining, by a node in a cluster of nodes, a message from a messaging queue; determining, by the node, a shard within the cluster that corresponds to the message based upon an identifier included in the message; determining, by the node, a responsible node associated with the shard; and forwarding, by the node, the message to the responsible node, wherein the responsible node delivers the message to a destination.
Claims20
A method comprising:
- obtaining, by a node in a cluster of nodes, a message from a queue;
- determining, by the node, a shard within the cluster that corresponds to the message based upon an identifier included in the message;
- determining, by the node, a responsible node associated with the shard;
- and
- forwarding, by the node, the message to the responsible node, wherein the responsible node delivers the message to a destination.
A computing device in a cluster, the computing device comprising:
- one or more processors;
- and a memory storing executable instructions that, when executed by the one or more processors, cause the one or more processors to perform operations comprising:
- receiving a message from a messaging queue;
- identifying a responsible node for the message based upon an identifier included in the message;
- and
- forwarding, by the computing device, the message to the responsible node, wherein the responsible node delivers the message to a destination identified in the message.
One or more non-transitory computer-readable media storing instructions which, when executed by one or more processors of a node device of a cluster, cause the one or more processors to perform operations comprising:
- receiving a message from a client device of the cluster;
- identifying a shard within the cluster based upon an identifier of a sender or recipient of the message;
- identifying an assigned node device associated with the shard;
- and
- sending the message to the assigned node device, wherein the assigned node device delivers the message to a destination.
Dependencies are inferred from the claim text.