Method and system for information gathering and aggregation in dynamic distributed environments
First Claim
1. A method for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, the method comprising the steps of:
- obtaining topology information, the topology information identifying a plurality of topology nodes of the topology and communication paths of the plurality of topology nodes;
obtaining an information services policy;
determining information gathering directives for information gathering nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
determining information aggregating directives for information aggregating nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
sending the information gathering directives to the information gathering nodes of the plurality of topology nodes; and
sending the information aggregating directives to the information aggregating nodes of the plurality of topology nodes.
2 Assignments
0 Petitions
Accused Products
Abstract
A method for information gathering and aggregation in a dynamic distributed environment includes obtaining topology information identifying a plurality of topology nodes of the topology and communication paths of the plurality of topology nodes. An information services policy is obtained, and information gathering directives are determined for information gathering nodes included in the plurality of topology nodes and sent thereto, based on the obtained topology information and the obtained information services policy. Information aggregating directives are also determined for information aggregating nodes included in the plurality of topology nodes and sent thereto, based on the obtained topology information and the obtained information services policy.
75 Citations
48 Claims
-
1. A method for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, the method comprising the steps of:
-
obtaining topology information, the topology information identifying a plurality of topology nodes of the topology and communication paths of the plurality of topology nodes;
obtaining an information services policy;
determining information gathering directives for information gathering nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
determining information aggregating directives for information aggregating nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
sending the information gathering directives to the information gathering nodes of the plurality of topology nodes; and
sending the information aggregating directives to the information aggregating nodes of the plurality of topology nodes. - View Dependent Claims (4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
-
- 2. The method of claim, further comprising periodically updating the topology information.
-
19. A method for information gathering and aggregation in a dynamic distributed environment comprising an active topology of topology nodes, and information aggregation comprising one or more of analyzing or condensing gathered information, the method comprising the steps of:
configuring a master node in the active topology, the master node comprising an automated topology formation application having a predefined topology policy definition and a representation of the active topology, wherein the active topology comprises nodes and intercommunication paths between the nodes, the nodes further comprising;
one or more leaf nodes having only incoming edges thereto, one or more of the one or more leaf node configured to collect information about itself;
one or more prime nodes having both incoming and outgoing edges, one or more of the one or more prime nodes configured to information received from other nodes to which each said prime node subscribes, based on a predefined information services policy; and
one or more root prime nodes having only outgoing edges, one or more of the one or more root prime nodes configured to aggregate and index information received from other nodes to which each said root prime node subscribes;
transmitting collected information from a configured leaf node to a subscribing prime node, the collected information collected according to a collecting directive, the transmitting performed according to a predetermined schedule;
receiving the transmitted collected information at a first configured prime node and aggregating the received collected information with collected information received from one or more other configured leaf nodes;
when the first configured prime node is subscribed to by a second configured prime node, transmitting the aggregated information to the second configured prime node according to a predetermined schedule;
when the first configured prime node is subscribed to by a second configured prime node, aggregating at the second configured prime node the aggregated information with information received from other nodes subscribed to by the second configured prime node;
when an aggregating step detects a predefined topology affecting event, transmitting a topology event notification to the master node, the event notification indicating an event affecting the active topology;
determining with the automated topology formation application that the topology event notification affects a topology portion of the active topology; and
based on the topology event notification, modifying the representation of the affected topology portion of the active topology according to the predefined topology policy definition. - View Dependent Claims (20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33)
-
34. A computer program product for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, comprising:
a storage medium readable by a processing circuit, the storage medium comprising machine readable computer program code including instructions for causing the processing circuit to implement a method, the method further comprising the steps of;
obtaining topology information, the topology information identifying a plurality of topology nodes of the topology and communication paths of the plurality of topology nodes;
obtaining an information services policy;
determining information gathering directives for information gathering nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
determining information aggregating directives for information aggregating nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
sending the information gathering directives to the information gathering nodes of the plurality of topology nodes; and
sending the information aggregating directives to the information aggregating nodes of the plurality of topology nodes. - View Dependent Claims (35, 36, 37, 38, 47)
-
39. A computer program product for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, comprising:
-
a storage medium readable by a processing circuit, the storage medium comprising machine readable computer program code including instructions for causing the processing circuit to implement a method, the method further comprising the steps of;
configuring a master node in the active topology, the master node comprising an automated topology formation application having a predefined topology policy definition and a representation of the active topology, wherein the active topology comprises nodes and intercommunication paths between the nodes, the nodes further comprising;
one or more leaf nodes having only incoming edges thereto, one or more of the one or more leaf node configured to collect information about itself;
one or more prime nodes having both incoming and outgoing edges, one or more of the one or more prime nodes configured to information received from other nodes to which each said prime node subscribes, based on a predefined information services policy; and
one or more root prime nodes having only outgoing edges, one or more of the one or more root prime nodes configured to aggregate and index information received from other nodes to which each said root prime node subscribes;
transmitting collected information from a configured leaf node to a subscribing prime node, the collected information collected according to a collecting directive, the transmitting performed according to a predetermined schedule;
receiving the transmitted collected information at a first configured prime node and aggregating the received collected information with collected information received from one or more other configured leaf nodes;
when the first configured prime node is subscribed to by a second configured prime node, transmitting the aggregated information to the second configured prime node according to a predetermined schedule;
when the first configured prime node is subscribed to by a second configured prime node, aggregating at the second configured prime node the aggregated information with information received from other nodes subscribed to by the second configured prime node;
when an aggregating step detects a predefined topology affecting event, transmitting a topology event notification to the master node, the event notification indicating an event affecting the active topology;
determining with the automated topology formation application that the topology event notification affects a topology portion of the active topology; and
based on the topology event notification, modifying the representation of the affected topology portion of the active topology according to the predefined topology policy definition. - View Dependent Claims (40)
-
-
41. A system for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, comprising:
-
a network;
a first computer system in communication with the network, wherein the first computer system includes instructions for implementing a method, the method further comprising;
a storage medium readable by a processing circuit, the storage medium comprising machine readable computer program code including instructions for causing the processing circuit to implement a method, the method further comprising the steps of;
obtaining topology information, the topology information identifying a plurality of topology nodes of the topology and communication paths of the plurality of topology nodes;
obtaining an information services policy;
determining information gathering directives for information gathering nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
determining information aggregating directives for information aggregating nodes included in the plurality of topology nodes, based on the obtained topology information and the obtained information services policy;
sending the information gathering directives to the information gathering nodes of the plurality of topology nodes; and
sending the information aggregating directives to the information aggregating nodes of the plurality of topology nodes. - View Dependent Claims (42, 43, 44, 45)
-
-
46. A system for information gathering and aggregation in a dynamic distributed environment comprising a topology of topology nodes, and information aggregation comprising any one of analyzing or condensing gathered information, comprising:
-
a network;
a first computer system in communication with the network, wherein the first computer system includes instructions for implementing a method, the method further comprising;
configuring a master node in the active topology, the master node comprising an automated topology formation application having a predefined topology policy definition and a representation of the active topology, wherein the active topology comprises nodes and intercommunication paths between the nodes, the nodes further comprising;
one or more leaf nodes having only incoming edges thereto, one or more of the one or more leaf node configured to collect information about itself;
one or more prime nodes having both incoming and outgoing edges, one or more of the one or more prime nodes configured to information received from other nodes to which each said prime node subscribes, based on a predefined information services policy; and
one or more root prime nodes having only outgoing edges, one or more of the one or more root prime nodes configured to aggregate and index information received from other nodes to which each said root prime node subscribes;
transmitting collected information from a configured leaf node to a subscribing prime node, the collected information collected according to a collecting directive, the transmitting performed according to a predetermined schedule;
receiving the transmitted collected information at a first configured prime node and aggregating the received collected information with collected information received from one or more other configured leaf nodes;
when the first configured prime node is subscribed to by a second configured prime node, transmitting the aggregated information to the second configured prime node according to a predetermined schedule;
when the first configured prime node is subscribed to by a second configured prime node, aggregating at the second configured prime node the aggregated information with information received from other nodes subscribed to by the second configured prime node;
when an aggregating step detects a predefined topology affecting event, transmitting a topology event notification to the master node, the event notification indicating an event affecting the active topology;
determining with the automated topology formation application that the topology event notification affects a topology portion of the active topology; and
based on the topology event notification, modifying the representation of the affected topology portion of the active topology according to the predefined topology policy definition.
-
-
48. A service for information gathering and aggregation in a dynamic distributed environment comprising a topology of intercommunicating topology nodes, wherein aggregating comprises any one of analyzing or condensing gathered information, the topology comprising:
-
one or more leaf nodes having only incoming edges thereto, one or more of the one or more leaf node configured to collect information about itself;
one or more prime nodes having both incoming and outgoing edges, one or more of the one or more prime nodes configured to information received from other nodes to which each said prime node subscribes, based on a predefined information services policy, wherein the topology comprises a hierarchy of one or more prime nodes; and
one or more root prime nodes having only outgoing edges, one or more of the one or more root prime nodes configured to aggregate and index information received from other nodes to which each said root prime node subscribes;
the service comprising;
configuring a master node to manage the topology;
providing any one of information gathering directives and information aggregating directives to the topology nodes, the directives based on an information services policy wherein any one of information gathered or aggregated information is aggregated at aggregating nodes;
in response to an event notification received at the master node, modifying a portion of the topology wherein an event notification is signaled when any one of a node is added to the topology, a node is removed from the topology, a node fails, an aggregator requests a topology change or an application requests a topology change, wherein further the modification of the portion of the topology comprises any one of modifying a topology node intercommunication path, adding a node, removing a node, modifying the information gathering directive of a node, notifying an application of the event notification or modifying the information aggregating directive of a node.
-
Specification