SYSTEM AND METHOD FOR EFFICIENTLY DISTRIBUTING COMPUTATION IN PUBLISHER-SUBSCRIBER NETWORKS
Methods and systems for spawning and deploying offspring Bots in a messaging system are provided. One method includes analyzing data in a channel stream of a plurality of channel streams in a computing network, generating a function to modify the data in the channel stream, and spawning at least one offspring computer processing node to perform the modification. The at least one offspring computer processing node derives from the computer processing node. The method further includes deploying the at least one offspring computer processing node to a periphery of the computing network, and causing the at least one offspring computer processing node to perform the modification at the periphery of the computing network.
1 . A method, comprising:
analyzing, by a computer processing device, data in a channel stream of a plurality of channel streams in a computing network;
generating, by the computer processing device, a function to modify the data in the channel stream;
spawning, by the computer processing device, at least one offspring computer processing node to perform the modification, the at least one offspring computer processing node being derived from the computer processing device;
deploying the at least one offspring computer processing node to a periphery of the computing network; and
causing the at least one offspring computer processing node to perform the modification at the periphery of the computing network.
2 . The method of claim 1 , wherein analyzing the data in the channel stream comprises analyzing data being transmitted from a publisher computer processing node to a subscriber computer processing node in the computing network.
3 . The method of claim 2 , wherein deploying the at least one offspring computer processing node to the periphery of the computing network comprises deploying the at least one offspring computer processing node to the publisher computer processing node.
4 . The method of claim 2 , wherein deploying the at least one offspring computer processing node to the periphery of the computing network comprises deploying the at least one offspring computer processing node to the subscriber computer processing node.
5 . The method of claim 1 , comprising spawning a plurality of offspring computer processing nodes, each of the plurality of offspring computer processing nodes being spawned to perform a different modification.
6 . The method of claim 1 , wherein spawning the at least one offspring computer processing node comprises including the at least one offspring computer processing node together with the computer processing node before the computer processing device is instantiated in the computing network.
7 . The method of claim 1 , wherein spawning the at least one offspring computer processing node comprises generating the at least one offspring computer processing node at runtime.
8 . The method of claim 1 , wherein spawning the at least one offspring computer processing node comprises increasing a processing capacity of the computer processing node in the computing network.
9 . An apparatus, comprising:
a computer processing device to:
analyze data in a channel stream of a plurality of channel streams in a computing network;
generate a function to modify the data in the channel stream;
spawn at least one offspring computer processing node to perform the modification, the at least one offspring computer processing node deriving from the computer processing device;
deploy the at least one offspring computer processing node to a periphery of the computing network; and
cause the at least one offspring computer processing node to perform the modification at the periphery of the computing network.
10 . The apparatus of claim 9 , wherein to analyze the data in the channel stream, the computer processing device is to analyze data being transmitted from a publisher computer processing node to a subscriber computer processing node in the computing network.
11 . The apparatus of claim 10 , wherein to deploy the at least one offspring computer processing node to the periphery of the computing network, the computer processing device is to deploy the at least one offspring computer processing node to the publisher computer processing node.
12 . The apparatus of claim 9 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to include the at least one offspring computer processing node together with the computer processing device before the computer processing device is instantiated in the computing network.
13 . The apparatus of claim 9 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to generate the at least one offspring computer processing node at runtime.
14 . The apparatus of claim 9 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to increase a processing capacity of the computer processing device in the computing network.
15 . A non-transitory computer-readable storage medium including instructions that, when executed by a computer processing device, cause the computer processing device to:
analyze data in a channel stream of a plurality of channel streams in a computing network;
generate a function to modify the data in the channel stream;
spawn, by the computer processing device, at least one offspring computer processing node to perform the modification, the at least one offspring computer processing node driving from the computer processing device;
deploy the at least one offspring computer processing node to a periphery of the computing network; and
cause the at least one offspring computer processing node to perform the modification at the periphery of the computing network.
16 . The non-transitory computer-readable storage medium of claim 15 , wherein to analyze the data in the channel stream, the computer processing device is to analyze data being transmitted from a publisher computer processing node to a subscriber computer processing node in the computing network.
17 . The non-transitory computer-readable storage medium of claim 16 , wherein to deploy the at least one offspring computer processing node to the periphery of the computing network, the computer processing device is to deploy the at least one offspring computer processing node to the publisher computer processing node.
18 . The non-transitory computer-readable storage medium of claim 15 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to include the at least one offspring computer processing node together with the computer processing device before the computer processing device is instantiated in the computing network.
19 . The non-transitory computer-readable storage medium of claim 15 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to generate the at least one offspring computer processing node at runtime.
20 . The non-transitory computer-readable storage medium of claim 15 , wherein to spawn the at least one offspring computer processing node, the computer processing device is to increase a processing capacity of the computer processing device in the computing network.