Alerting system having a network of stateful transformation nodes
First Claim
1. A system, comprising:
- an events producer comprising one or more hardware processors configured to generate events that are part of an events stream;
an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, the alerting system configured to directly process the events and to generate actions, the alerting system comprising;
a streams transformer comprising;
a network of transformation nodes comprising;
an input transformation node configured to receive at least some of the events;
an output transformation node; and
a plurality of intermediate transformation nodes coupled between the input transformation node and the output transformation node, wherein each of the intermediate transformation nodes comprises;
a state module for each transformation node that the intermediate transformation node subscribes to, wherein each state module is configured to;
receive state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;
store each of the state updates as state information; and
update state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;
a transformation rule for that intermediate transformation node; and
a re-computation trigger function for that intermediate transformation node that is configured to;
determine whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; and
call the transformation rule to re-compute the state information for that intermediate transformation node, wherein the transformation rule is configured to communicate a state update comprising the re-computed state information to all transformation nodes that subscribe to the intermediate transformation node; and
wherein the output transformation node is configured to;
generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; and
a state change processor configured to;
perform an action when it is determined that the check result should trigger the action; and
a consumer system that is configured to consume and react to the action generated by the alerting system.
1 Assignment
0 Petitions
Accused Products
Abstract
An alerting system is provided that includes a network of transformation nodes, and state change processors. The transformation nodes include input transformation nodes, output transformation nodes, and intermediate nodes that connect the input and output transformation nodes. Each input transformation node can receive an events stream, and is coupled to one of the output transformation nodes by one or more intermediate transformation nodes. Each transformation node (except the input transformation nodes) can receive state updates from those transformation nodes that it subscribes to. Each output transformation node can generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated. Each output transformation node is coupled to one of the state change processors that can determine whether the check results should trigger an action, and if so, can then perform an action.
-
Citations
20 Claims
-
1. A system, comprising:
-
an events producer comprising one or more hardware processors configured to generate events that are part of an events stream; an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, the alerting system configured to directly process the events and to generate actions, the alerting system comprising; a streams transformer comprising;
a network of transformation nodes comprising;
an input transformation node configured to receive at least some of the events;
an output transformation node; and
a plurality of intermediate transformation nodes coupled between the input transformation node and the output transformation node, wherein each of the intermediate transformation nodes comprises;a state module for each transformation node that the intermediate transformation node subscribes to, wherein each state module is configured to;
receive state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;
store each of the state updates as state information; and
update state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;a transformation rule for that intermediate transformation node; and a re-computation trigger function for that intermediate transformation node that is configured to;
determine whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; and
call the transformation rule to re-compute the state information for that intermediate transformation node, wherein the transformation rule is configured to communicate a state update comprising the re-computed state information to all transformation nodes that subscribe to the intermediate transformation node; andwherein the output transformation node is configured to;
generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; anda state change processor configured to;
perform an action when it is determined that the check result should trigger the action; anda consumer system that is configured to consume and react to the action generated by the alerting system. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A system, comprising:
-
an events producer comprising one or more hardware processors configured to generate events that are part of an events stream; an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, the alerting system configured to directly process the events and to generate actions, the alerting system comprising; a streams transformer comprising;
a network of transformation nodes comprising;
a plurality of input transformation nodes each being configured to receive a particular events stream comprising at least some of the events;
a plurality of output transformation nodes; and
a plurality of intermediate transformation nodes coupled between the input transformation nodes and the output transformation nodes, wherein each of the intermediate transformation nodes and output transformation nodes subscribe to and receive state updates from one or more of the transformation nodes that are part of the network;wherein each of the intermediate transformation nodes is configured to;
generate a state update when stored state information for the transformation nodes that the intermediate transformation node subscribes to collectively indicates that the state update should be generated, wherein each of the intermediate transformation nodes comprises;a state module for each transformation node that the intermediate transformation node subscribes to, wherein each state module is configured to;
receive state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;
store each of the state updates as state information; and
update state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;a transformation rule for that intermediate transformation node; and a re-computation trigger function for that intermediate transformation node that is configured to;
determine whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; and
call the transformation rule to re-compute the state information for that intermediate transformation node, wherein the transformation rule is configured to communicate a state update comprising the re-computed state information to all transformation nodes that subscribe to the intermediate transformation node; andwherein each of the output transformation nodes is configured to;
generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; anda plurality of state change processors each being configured to;
perform an action when that state change processor determines, based on a check result received from a corresponding output transformation node, that the check result should trigger the action; anda consumer system that is configured to consume and react to the action generated by the alerting system. - View Dependent Claims (15, 16, 17, 18, 19)
-
-
20. A method performed by an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, wherein the alerting system comprises at least an input transformation node, an output transformation node and a plurality of intermediate transformation nodes coupled between the input transformation node and the output transformation node, the method comprising:
-
receiving, at the alerting system from an events producer comprising one or more hardware processors configured to generate events, an events stream comprising at least some of the events; receiving, at each of the intermediate transformation nodes, state updates from any of the transformation nodes that the intermediate transformation node is subscribed to; storing, at each of the intermediate transformation nodes, each of the state updates as state information; updating, at each of the intermediate transformation nodes, state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to; determining, at each of the intermediate transformation nodes, whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; calling, at each of the intermediate transformation nodes, a transformation rule for that intermediate transformation node to re-compute the state information for that intermediate transformation node; communicating, from each transformation rule for each intermediate transformation node to all transformation nodes that subscribe to that intermediate transformation node, a state update comprising re-computed state information; generating a check result at the output transformation node when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; determining at a state change processor whether the check result should trigger an action; performing the action at the state change processor when it is determined that the check result should trigger the action; and at a consumer system;
consuming and reacting to the action generated by the alerting system.
-
Specification