Scaling hosts in distributed event handling systems

Patent metadata

Field	Value
Publication number	US-11075982-B2
Application number	US-201715645728-A
Country	US
Kind code	B2
Filing date	Jul 10, 2017
Priority date	Jul 10, 2017
Publication date	Jul 27, 2021
Grant date	Jul 27, 2021

Abstract

The present disclosure generally discloses a host scaling capability for supporting scaling of hosts in a distributed event handling system. The host scaling capability may be configured to support scaling of hosts in a distributed event handling system which may use distributed queuing of events, distributed processing of events, and so forth. The distributed event handling system may be serverless cloud system or other type of distributed event handling system.

First claim

What is claimed is:

1. An apparatus, comprising:
at least one processor; and
at least one memory including a set of instructions:
wherein the set of instructions is configured to, when executed by the at least one processor, cause the apparatus to:
determine, from a set of hosts for an event type of events configured to be processed based on an event processing function for the event type, a set of publisher hosts configured to publish events of the event type and a set of subscriber hosts configured to process events of the event type;
determine, based on the set of publisher hosts and the set of subscriber hosts, a set of candidate subscriber hosts which are candidates to begin handling events of the event type;
select, from the set of candidate subscriber hosts, a selected candidate subscriber host; and
initiate configuration of the selected candidate subscriber host to begin handling events of the event type.

2. The apparatus of claim 1 , wherein the set of candidate subscriber hosts includes ones of the hosts that are included in the set of publisher hosts but that are not included in the set of subscriber hosts.

3. The apparatus of claim 1 , wherein the selected candidate subscriber host is selected based on an ordered list of the candidate subscriber hosts.

4. The apparatus of claim 1 , wherein the selected candidate subscriber host is selected based on respective candidate scores of respective candidate subscriber hosts.

5. The apparatus of claim 4 , wherein the respective candidate scores of the respective candidate subscriber hosts are based on respective load contributions of the respective candidate subscriber hosts to an overall workload for the event type.

6. The apparatus of claim 4 , wherein the respective candidate scores of the respective candidate subscriber hosts are based on a score function configured to favor ones of the hosts that most contribute to an overall workload for the event type.

7. The apparatus of claim 4 , wherein, for at least one of the candidate subscriber hosts, a respective candidate score of a respective candidate subscriber host is based on a geometric mean of contribution of the at least one of the candidate subscriber hosts to an overall workload of the event type.

8. The apparatus of claim 1 , wherein, to initiate configuration of the selected candidate subscriber host to begin handling events of the event type, the set of instructions is configured to, when executed by the at least one processor, cause the apparatus to:
send, toward the selected candidate subscriber host, a request for the selected candidate subscriber host to obtain the event processing function for the event type and to subscribe to receive events of the event type.

9. A method, comprising:
determining, from a set of hosts for an event type of events configured to be processed based on an event processing function for the event type, a set of publisher hosts configured to publish events of the event type and a set of subscriber hosts configured to process events of the event type;
determining, based on the set of publisher hosts and the set of subscriber hosts, a set of candidate subscriber hosts which are candidates to begin handling events of the event type;
selecting, from the set of candidate subscriber hosts, a selected candidate subscriber host; and
initiating configuration of the selected candidate subscriber host to begin handling events of the event type.

10. An apparatus, comprising:
at least one processor, and
at least one memory including a set of instructions;
wherein the set of instructions is configured to, when executed by the at least one processor, cause the apparatus to:
determine, from a set of hosts for an event type of events configured to be processed based on an event processing function for the event type, a set of publisher hosts configured to publish events of the event type and a set of subscriber hosts configured to process events of the event type;
determine, based on the set of publisher hosts and the set of subscriber hosts, a set of candidate subscriber hosts which are candidates to stop handling events of the event type;
select, from the set of candidate subscriber hosts, a selected candidate subscriber host; and
initiate configuration of the selected candidate subscriber host to stop handling events of the event type.

11. The apparatus of claim 10 , wherein the set of candidate subscriber hosts includes ones of the hosts that are included in the set of subscriber hosts but that are not included in the set of publisher hosts.

12. The apparatus of claim 10 , wherein the selected candidate subscriber host is selected based on an ordered list of the candidate subscriber hosts.

13. The apparatus of claim 10 , Wherein the selected candidate subscriber host is selected based on respective candidate scores of the respective candidate subscriber hosts.

14. The apparatus of claim 13 , wherein the respective candidate scores of the respective candidate subscriber hosts are based on respective load contributions of the respective candidate subscriber hosts to an overall workload for the event type.

15. The apparatus of claim 13 , wherein the respective candidate scores of the respective candidate subscriber hosts are based on a score function configured to favor ones of the hosts that least contribute to an overall workload for the event type.

16. The apparatus of claim 13 , wherein, for at least one of the candidate subscriber hosts, a respective candidate score of a respective candidate subscriber host is based on a geometric mean of contribution of the at least one of the candidate subscriber hosts to an overall workload of the event type.

17. The apparatus of claim 10 , wherein, to initiate configuration of the selected candidate subscriber host to stop handling events of the event type, the set of instructions is configured to, when executed by the at least one processor, cause the apparatus to:
send, toward the selected candidate subscriber host, a request for the selected candidate subscriber host to remove the event processing function for the event type and to unsubscribe from received events of the event type.

18. A method, comprising:
determining, from a set of hosts for an event type of events configured to be processed based on an event processing function for the event type, a set of publisher hosts configured to publish events of the event type and a set of subscriber hosts configured to process events of the event type;
determining, based on the set of publisher hosts and the set of subscriber hosts, a set of candidate subscriber hosts which are candidates to stop handling events of the event type;
selecting, from the set of candidate subscriber hosts, a selected candidate subscriber host; and
initiating configuration of the selected candidate subscriber host to stop handling events of the event type.

Assignees

• Nokia Solutions & Networks Oy

Inventors

• Stein Manuel
• Rimac Ivica
• Akkus Istemi Ekin
• Chen Ruichuan
• Hilt Volker

Classifications

• G06F9/5027 Primary

  the resource being a machine, e.g. CPUs, Servers, Terminals · CPC title

• G06F9/542

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• H04L41/0816

  the condition being an adaptation, e.g. in response to network events · CPC title

• H04L67/1008 Primary

  based on parameters of servers, e.g. available memory or workload (monitoring of computer activity G06F11/30) · CPC title