SCALING HOSTS IN DISTRIBUTED EVENT HANDLING SYSTEMS

• US 20190014171A1
• Filed: 07/10/2017
• Published: 01/10/2019
• Est. Priority Date: 07/10/2017
• Status: Active Grant

• Current Assignee: Nokia Solutions and Networks US LLC (Nokia Corporation)
• Original Assignee: Nokia Solutions and Networks US LLC (Nokia Corporation)
• Inventors: Stein, Manuel, Rimac, Ivica, Akkus, Istemi Ekin, Chen, Ruichuan, Hilt, Volker
• Granted Patent: US 11,075,982 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 41/0816 the condition being an adaptation, e.g. in response to network events
• CPC Class Codes: H04L 67/1008 based on parameters of servers, e.g. available memory or workload monitoring of computer activity G06F11/30

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.

Claims

1. An apparatus, comprising:

a processor and a memory communicatively connected to the processor, the processor configured 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, at least one of a set of publisher hosts configured to publish events of the event type or a set of subscriber hosts configured to process events of the event type;

determine, based on at least one of the set of publisher hosts or 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 processor is configured to determine the set of candidate subscriber hosts as ones of the hosts that are included in the set of hosts but that are not included in the set of subscriber hosts.

3. The apparatus of claim 1, wherein the processor is configured to determine the set of candidate subscriber hosts as ones of the hosts that are included in the set of publisher hosts but that are not included in the set of subscriber hosts.

4. The apparatus of claim 1, wherein the processor is configured to select the selected candidate subscriber host based on an ordered list of the candidate subscriber hosts.

5. The apparatus of claim 1, wherein the processor is configured to select the selected candidate subscriber host based on respective candidate scores of the respective candidate subscriber hosts.

6. The apparatus of claim 5, 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.

7. The apparatus of claim 5, 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.

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

9. The apparatus of claim 1, wherein, to initiate configuration of the selected candidate subscriber host to begin handling events of the event type, the processor is configured to:

send, toward the selected candidate subscriber host, a request for the selected candidate consumer host to obtain the event processing function for the event type and to subscribe to receive events of the event type.

10. 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, at least one of a set of publisher hosts configured to publish events of the event type or a set of subscriber hosts configured to process events of the event type;

determining, based on at least one of the set of publisher hosts or 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.

11. An apparatus, comprising:

a processor and a memory communicatively connected to the processor, the processor configured 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, at least one of a set of publisher hosts configured to publish events of the event type or a set of subscriber hosts configured to process events of the event type;

determine, based on at least one of the set of publisher hosts or 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.

12. The apparatus of claim 11, wherein the processor is configured to determine the set of candidate subscriber hosts as ones of the hosts that are included in the set of subscriber hosts.

13. The apparatus of claim 11, wherein the processor is configured to determine the set of candidate subscriber hosts as ones of the hosts that are included in the set of subscriber hosts but that are not included in the set of publisher hosts.

14. The apparatus of claim 11, wherein the processor is configured to select the selected candidate subscriber host based on an ordered list of the candidate subscriber hosts.

15. The apparatus of claim 11, wherein the processor is configured to select the selected candidate subscriber host based on respective candidate scores of the respective candidate subscriber hosts.

16. The apparatus of claim 15, 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.

17. The apparatus of claim 15, 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.

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

19. The apparatus of claim 11, wherein, to initiate configuration of the selected candidate subscriber host to stop handling events of the event type, the processor is configured to:

send, toward the selected candidate subscriber host, a request for the selected candidate consumer host to remove the event processing function for the event type and to unsubscribe from received events of the event type.

20. 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, at least one of a set of publisher hosts configured to publish events of the event type or a set of subscriber hosts configured to process events of the event type;

determining, based on at least one of the set of publisher hosts or 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.