Notification service in a decentralized control plane of a computing system

• US 10,379,775 B2
• Filed: 06/28/2016
• Issued: 08/13/2019
• Est. Priority Date: 06/28/2016
• Status: Active Grant

• Current Assignee: Vmware LLC (Broadcom, Inc.)
• Original Assignee: VMware, Inc. (Broadcom, Inc.)
• Inventors: Chrysanthakopoulos, Georgios, Noordhuis, Pieter
• Primary Examiner(s): Roni, Syed A
• Application Number:
  US15/195,532
• Publication Number:
  US 20170371723A1
• Time in Patent Office: 1,141 Days
• Field of Search: None
• CPC Class Codes: G06F 16/2228 Indexing structures
• CPC Class Codes: G06F 16/23 Updating
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 2209/5011 Pool
• CPC Class Codes: G06F 3/0608 Saving storage space on storage systems
• CPC Class Codes: G06F 3/064 Management of blocks
• CPC Class Codes: G06F 3/0647 Migration mechanisms
• CPC Class Codes: G06F 3/0652 Erasing, e.g. deleting, data cleaning, moving of data to a wastebasket
• CPC Class Codes: G06F 3/0659 Command handling arrangements, e.g. command buffers, queues, command scheduling
• CPC Class Codes: G06F 3/0673 Single storage device
• CPC Class Codes: G06F 8/315 Object-oriented languages
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 41/0893 Assignment of logical groups to network elements
• CPC Class Codes: H04L 41/20 Network management software packages
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/104 Peer-to-peer [P2P] networks
• CPC Class Codes: H04L 67/1095 : Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/51 : Discovery or management thereof, e.g. service location protocol [SLP] or web services
• CPC Class Codes: H04L 67/60 : Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources admission control or resource allocation H04L47/70
• CPC Class Codes: H04L 67/63 : Routing a service request depending on the request content or context

Abstract

A method of providing notifications in a control plane of a computer system includes executing a service host process of the control plane on a software platform of the computer system, the service host process managing services of the control plane and a persistent document store that stores service states for the services. The method may include creating a query task service of the control plane, a service state of the query task service including a query filter; evaluating each of the service states against the query filter as each of the service states is added to the persistent document store; updating the service state of the query task service for each of the service states that satisfies the query filter; and sending a notification to a plurality of subscribers of the query task service in response to each update to the service state of the query task service.

Claims

1. A method of providing notifications in a control plane of a computer system, comprising:

executing a service host process of the control plane on a software platform of the computer system, the service host process managing services of the control plane and a persistent document store that stores service states for the services;

creating a query task service of the control plane in addition to the services, a service state of the query task service including a query filter;

evaluating each service state of the services against the query filter as each service state of the services is added to the persistent document store;

updating the service state of the query task service for each of the service states that satisfies the query filter; and

sending a notification to a plurality of subscribers of the query task service in response to each update to the service state of the query task service.

2. The method of claim 1, wherein the query task comprises a query specification, and wherein the method further comprises generating the query filter from the query specification.

3. The method of claim 2, wherein the query specification includes a description of a query and at least one option associated with the query.

4. The method of claim 3, wherein the steps of evaluating and updating are performed in response to the at least one option including a continuous option.

5. The method of claim 1, wherein the service host process includes an index service object that implements an index service of the control plane, and wherein the method further comprises:

adding the query task to a list of active queries of the index service object;

wherein the step of evaluating is a function of the index service object performed in response to the query task being in the list of active queries.

6. The method of claim 5, wherein the step of updating is performed by a handler of a service object in the service host process that implements the query task service, and wherein the index service object invokes the handler for each of the service states that satisfies the query filter.

7. The method of claim 1, wherein the step of updating the service state of the query task service comprises:

for each service state that satisfies the query filter, updating a results object of the service state of the query task service to store at least a portion of the respective service state.

8. The method of claim 1, wherein each notification comprises the service state of the query task service.

9. The method of claim 1, wherein each of the plurality of subscribers is a client of the control plane or one of the services of the control plane.

10. A computer system, comprising:

a hardware platform having a central processing unit (CPU), memory, and storage;

a software platform executing on the hardware platform, the software platform includes a service host process of a control plane, the service host process executable by the CPU to;

manage services of the control plane and a persistent document store in the storage that stores service states for the services;

create a query task service of the control plane in addition to the services, a service state of the query task service including a query filter;

evaluate each service state of the services against the query filter as each service state of the services is added to the persistent document store;

update the service state of the query task service for each of the service states that satisfies the query filter; and

send a notification to a plurality of subscribers of the query task service in response to each update to the service state of the query task service.

11. The computer system of claim 10, wherein the query task comprises a query specification, and wherein the service host process is further executable by the CPU to generate the query filter from the query specification.

12. The computer system of claim 11, wherein the query specification includes a description of a query and at least one option associated with the query.

13. The computer system of claim 12, wherein the service host process is executable by the CPU to evaluate each of the service states and update the service state of the query task service in response to the at least one option including a continuous option.

14. The computer system of claim 10, wherein the service host process is executable by the CPU to:

manage an index service object that implements an index service of the control plane; and

add the query task to a list of active queries of the index service object;

wherein the service host process is executable by the CPU to evaluate each of the service states using a function of the index service object performed in response to the query task being in the list of active queries.

15. The computer system of claim 14, wherein the service host process is executable by the CPU to update the service state of the query task service using a handler of a service object in the service host process that implements the query task service, and wherein the index service object invokes the handler for each of the service states that satisfies the query filter.

16. The computer system of claim 10, wherein the service host process is executable by the CPU to update the service state of the query task service by:

for each service state that satisfies the query filter, updating a results object of the service state of the query task service to store at least a portion of the respective service state.

17. The computer system of claim 10, wherein each notification comprises the service state of the query task service.

18. The computer system of claim 10, wherein each of the plurality of subscribers is a client of the control plane or one of the services of the control plane.

19. A non-transitory computer readable medium comprising instructions, which when executed in a computer system, causes the computer system to carry out a method of providing notifications in a control plane of a computer system, comprising:

executing a service host process of the control plane on a software platform of the computer system, the service host process managing services of the control plane and a persistent document store that stores service states for the services;

creating a query task service of the control plane in addition to the services, a service state of the query task service including a query filter;

evaluating each service state of the services against the query filter as each service state of the services is added to the persistent document store;

updating the service state of the query task service for each of the service states that satisfies the query filter; and

sending a notification to a plurality of subscribers of the query task service in response to each update to the service state of the query task service.

20. The non-transitory computer readable medium of claim 19, wherein the service host process includes an index service object that implements an index service of the control plane, and wherein the method further comprises:

adding the query task to a list of active queries of the index service object;

wherein the step of evaluating is a function of the index service object performed in response to the query task being in the list of active queries.