Dynamic micro-services related job assignment

A computing node, comprising:

• one or more memories;
• and
• one or more processors, communicatively coupled to the one or more memories, configured to:
• receive, from a set of computing nodes, a set of heartbeat messages,
• wherein the set of computing nodes subscribe to a message broker associated with the set of heartbeat messages,
• wherein each computing node, of the set of computing nodes, is configured to receive the set of heartbeat messages based upon being subscribed to the message broker and exchange respective heartbeat messages, at a same time or within a threshold period of time, with another computing node of the set of computing nodes,
• wherein the set of heartbeat messages is related to determining a respective priority of the set of computing nodes for processing a set of jobs, and
• wherein the set of computing nodes includes the computing node;
• store the set of heartbeat messages in temporary memory resources associated with the computing node after receiving the set of heartbeat messages;
• identify a heartbeat message, of the set of heartbeat messages, associated with a lowest offset relative to other offsets associated with other heartbeat messages, of the set of heartbeat messages, after storing the set of heartbeat messages;
• determine the respective priority of the set of computing nodes based on one or more factors related to the set of computing nodes or the set of heartbeat messages,
• wherein the one or more factors include a respective offset associated with the set of heartbeat messages;
• determine whether the computing node is to perform a subset of the set of jobs based on the respective priority of the set of computing nodes;
• delete the set of heartbeat messages from the temporary memory resources after determining whether to perform the subset of the set of jobs;
• and
• perform a set of actions after determining whether to perform the subset of the set of jobs.

A non-transitory computer-readable medium storing instructions, the instructions comprising:

• one or more instructions that, when executed by one or more processors, cause the one or more processors to:
• receive a set of heartbeat messages from a set of computing nodes,
• wherein the set of computing nodes subscribe to a message broker associated with the set of heartbeat messages,
• wherein each computing node, of the set of computing nodes, is configured to receive the set of heartbeat messages based upon being subscribed to the message broker and exchange respective heartbeat messages, at a same time or within a threshold period of time, with another computing node of the set of computing nodes, and
• wherein the set of heartbeat messages is related to determining a respective priority of the set of computing nodes for processing a set of jobs;
• identify a heartbeat message, of the set of heartbeat messages, associated with a lowest offset relative to other offsets associated with other heartbeat messages, of the set of heartbeat messages, based on a clock or a respective timestamp for the set of heartbeat messages;
• store the set of heartbeat messages in temporary memory resources of a computing node of the set of computing nodes,
• wherein the set of heartbeat messages is stored based on a respective offset associated with the set of heartbeat messages;
• determine the respective priority of the set of computing nodes based on one or more factors related to the set of heartbeat messages or the set of computing nodes after storing the set of heartbeat messages;
• determine whether the computing node is to perform a subset of the set of jobs based on the respective priority of the set of computing nodes;
• delete the set of heartbeat messages from the temporary memory resources of the computing node after determining whether the computing node is to perform the subset of the set of jobs;
• and
• perform a set of actions after deleting the set of heartbeat messages.