Granted Patent B2

US 12,645,382 · App. 18/618,772 · Granted Jun 2, 2026

Inventors: Mehrdad Arian (Vancouver, CA); Omprakaash Thoppai (San Jose, CA); Muzhi Ou (Vancouver, CA)

Assignee: Cisco Technology, Inc.

G06F3/064G06F3/0604G06F3/0656G06F3/0673

Abstract

Claims (70)

1 . A method, comprising:

receiving an instruction to collect data from a first data source;

determining a type of the first data source is a first type;

based on a determination that the type of the first data source is the first type:

assigning a plurality of isolated execution environments to generate a first cluster of collector modules to collect the data from the first data source, wherein each of the plurality of isolated execution environments instantiates at least one collector module of the first cluster of collector modules and configures the at least one collector module to collect the data from the first data source, and

assigning a first collector module of the first cluster of collector modules as a cluster leader, wherein the cluster leader is configured to:

obtain a data identifier of a plurality of blocks of data to be collected by the first cluster of collector modules, and

communicate the data identifier of the plurality of blocks of data to a communication buffer, wherein the first cluster of collector modules is configured to retrieve the data identifier of the plurality of blocks of data from the communication buffer; and

retrieving, using the first cluster of collector modules, the plurality of blocks of data from the first data source.

2 . The method of claim 1 , further comprising:

retrieving configuration data from the communication buffer based on the instruction, wherein assigning the plurality of isolated execution environments is based on the configuration data.

3 . The method of claim 1 , further comprising:

retrieving configuration data from the communication buffer based on the instruction, wherein assigning the plurality of isolated execution environments is based on the configuration data, wherein the configuration data indicates the type of the first data source.

4 . The method of claim 1 , further comprising:

retrieving configuration data from the communication buffer based on the instruction, wherein assigning the plurality of isolated execution environments is based on the configuration data, wherein the configuration data indicates an identifier of a connector corresponding to the first cluster of collector modules.

5 . The method of claim 1 , further comprising:

retrieving configuration data from the communication buffer based on the instruction, wherein assigning the plurality of isolated execution environments is based on the configuration data, wherein the configuration data indicates a number of collector modules to be instantiated for the first cluster of collector modules.

6 . The method of claim 1 , further comprising:

retrieving configuration data from the communication buffer based on the instruction, wherein assigning the plurality of isolated execution environments is based on the configuration data, wherein determining the type of the first data source is the first type is based on the configuration data.

7 . The method of claim 1 , wherein assigning the plurality of isolated execution environments to generate the first cluster of collector modules comprises:

assigning at least one of the plurality of isolated execution environments to generate at least two collector modules of the first cluster of collector modules.

8 . The method of claim 1 , wherein each of the plurality of isolated execution environments executes a respective plurality of collector modules corresponding to a respective plurality of connectors.

9 . The method of claim 1 , wherein the plurality of isolated execution environments is instantiated on and share compute resources of a host computing device.

10 . The method of claim 1 , wherein a first isolated execution environment of the plurality of isolated execution environments generates the at least one collector module of the first cluster of collector modules, configures the at least one collector module of the first cluster of collector modules to collect the data from the first data source, generates a second collector module of a second cluster of collector modules, and configures the second collector module of the second cluster of collector modules to collect second data from a second data source.

11 . The method of claim 1 , wherein a second type of data source is configured to support parallel reads.

12 . The method of claim 1 , wherein determining the type of the first data source is the first type is based on the determination that the first data source is not configured for parallel reads.

13 . The method of claim 1 , further comprising:

retrieving the data identifier of the plurality of blocks of data from the communication buffer to obtain a retrieved data identifier of the plurality of blocks of data, wherein retrieving the plurality of blocks of data from the first data source is based on the retrieved data identifier of the plurality of blocks of data.

14 . The method of claim 1 , wherein retrieving the plurality of blocks of data from the first data source comprises:

retrieving a first data identifier of a block of data from the communication buffer; and

requesting, using the first data identifier of the block of data, the block of data from the first data source.

15 . The method of claim 1 , wherein retrieving the plurality of blocks of data from the first data source comprises:

retrieving a first data identifier of a block of data from the communication buffer; and

requesting, using the first data identifier of the block of data, the block of data from the first data source,

the method further comprising:

processing the block of data.

16 . The method of claim 1 , wherein retrieving the plurality of blocks of data from the first data source comprises:

retrieving a first data identifier of a block of data from the communication buffer; and

requesting, using the first data identifier of the block of data, the block of data from the first data source,

the method further comprising:

processing the block of data; and

providing an update to the communication buffer indicating processing of the block of data.

17 . The method of claim 1 , further comprising:

receiving a second instruction to collect second data from a second data source;

determining a type of the second data source is a second type; and

based on determining the type of the second data source is the second type, retrieving, using a second cluster of collector modules, a second plurality of blocks of second data from the second data source.

18 . The method of claim 1 , further comprising:

receiving a second instruction to collect second data from a second data source;

determining a type of the second data source is a second type; and

based on a determination that the type of the second data source is the second type, retrieving, using a second cluster of collector modules, a second plurality of blocks of second data from the second data source, wherein the second data source provides coordination of the second cluster of collector modules.

19 . A host computing device comprising:

a data store; and

one or more processors configured to:

receive an instruction to collect data from a first data source;

determine a type of the first data source is a first type;

based on a determination that the type of the first data source is the first type:

assign a plurality of isolated execution environments to generate a first cluster of collector modules to collect the data from the first data source, wherein each of the plurality of isolated execution environments instantiates at least one collector module of the first cluster of collector modules and configures the at least one collector module to collect the data from the first data source, and

assign a first collector module of the first cluster of collector modules as a cluster leader, wherein the cluster leader is configured to:

obtain a data identifier of a plurality of blocks of data to be collected by the first cluster of collector modules, and

communicate the data identifier of the plurality of blocks of data to a communication buffer, wherein the first cluster of collector modules is configured to retrieve the data identifier of the plurality of blocks of data from the communication buffer; and

retrieve, using the first cluster of collector modules, the plurality of blocks of data from the first data source.

20 . One or more non-transitory computer-readable media including computer-executable instructions that, when executed by a host computing device, cause the host computing device to:

receive an instruction to collect data from a first data source;

determine a type of the first data source is a first type;

based on a determination that the type of the first data source is the first type:

assign a plurality of isolated execution environments to generate a first cluster of collector modules to collect the data from the first data source, wherein each of the plurality of isolated execution environments instantiates at least one collector module of the first cluster of collector modules and configures the at least one collector module to collect the data from the first data source, and

assign a first collector module of the first cluster of collector modules as a cluster leader, wherein the cluster leader is configured to:

obtain a data identifier of a plurality of blocks of data to be collected by the first cluster of collector modules, and

communicate the data identifier of the plurality of blocks of data to a communication buffer, wherein the first cluster of collector modules is configured to retrieve the data identifier of the plurality of blocks of data from the communication buffer; and

retrieve, using the first cluster of collector modules, the plurality of blocks of data from the first data source.

Assignments (4)

Continuity (1)

References Cited (14)