Communication with high available clusters using message bus technology

A non-transitory machine-readable medium having instructions stored therein, which when executed by a processor, cause the processor to perform operations for managing operation of a deployment of data processing systems, the operations comprising:

• obtaining, by a message bus, an activity request from a client system, the activity request being for performance of a service by a high availability cluster;
• classifying, by the message bus, the activity request to obtain a topic classification for the activity request;
• identifying, by the message bus, subscribers to the topic classification;
• and
• distributing, by the message bus, the activity request to the subscribers to initiate the performance of the service by the high availability cluster;
• obtaining, by the message bus and from a newly added cluster instance of the high availability cluster, a cluster management subscription request;
• subscribing, by the message bus, the newly added cluster instance to a cluster management topic based on the cluster management subscription request;
• obtaining, by the message bus and from the newly added cluster instance, a leader vote;
• classifying, by the message bus, the leader vote into a cluster management topic classification;
• identifying, by the message bus and based on the cluster management topic classification, the cluster management topic;
• identifying, by the message bus, the subscribers to the cluster management topic;
• and
• distributing, by the message bus, the leader vote to the subscribers of the cluster management topic to facilitate an instance of a quorum to select a new leader for the high availability cluster.

A data processing system, comprising:

• a processor;
• and
• a memory coupled to the processor to store instructions, which when executed by the processor, cause the processor to perform operations managing operation of a deployment of data processing systems, the operations comprising:
• obtaining, by a message bus, an activity request from a client system, the activity request being for performance of a service by a high availability cluster;
• classifying, by the message bus, the activity request to obtain a topic classification for the activity request;
• identifying, by the message bus, subscribers to the topic classification;
• distributing, by the message bus, the activity request to the subscribers to initiate the performance of the service by the high availability cluster;
• obtaining, by the message bus and from a newly added cluster instance of the high availability cluster, a cluster management subscription request;
• subscribing, by the message bus, the newly added cluster instance to a cluster management topic based on the cluster management subscription request;
• obtaining, by the message bus and from the newly added cluster instance, a leader vote;
• classifying, by the message bus, the leader vote into a cluster management topic classification;
• identifying, by the message bus and based on the cluster management topic classification, the cluster management topic;
• identifying, by the message bus, the subscribers to the cluster management topic;
• and
• distributing, by the message bus, the leader vote to the subscribers of the cluster management topic to facilitate an instance of a quorum to select a new leader for the high availability cluster.