System and method for notification within decentralized network
First Claim
1. A system for event notification in a decentralized network of interconnected nodes, comprising:
- a first node defined to produce a resource for publication across the decentralized network;
a second node defined to be responsible for a resource identifier for the resource produced by the first node, wherein the second node is defined to maintain a subscription registry for the resource that includes identifiers of nodes that are to receive the resource produced by the first node, and wherein the second node is defined to distribute the resource produced by the first node to each node having an identifier included within the subscription registry, such that the first node is not required to distribute the resource that it produces to nodes other than the second node; and
a third node defined to identify the second node as being responsible for the resource identifier, the third node being further defined to publish a subscription object for the resource,wherein the second node responds to the subscription object by entering the third node on the subscription registry for the resource produced by the first node.
4 Assignments
0 Petitions
Accused Products
Abstract
Methods are provided for event notification in a decentralized peer-to-peer (P2P) network. Each node within the P2P network can publish a subscription object for a published resource. Through the use of common identifiers, each subscription object is co-located with a corresponding publish object for the resource. Upon receiving notification of an event associated with the resource, the node responsible for the publish object for the resource distributes the event notification to each node present on the corresponding subscription registry. Therefore, nodes within the P2P network that are interested in a resource are capable of establishing a persistent query for the resource by publishing a subscription object for the resource on the responsible node.
-
Citations
45 Claims
-
1. A system for event notification in a decentralized network of interconnected nodes, comprising:
-
a first node defined to produce a resource for publication across the decentralized network; a second node defined to be responsible for a resource identifier for the resource produced by the first node, wherein the second node is defined to maintain a subscription registry for the resource that includes identifiers of nodes that are to receive the resource produced by the first node, and wherein the second node is defined to distribute the resource produced by the first node to each node having an identifier included within the subscription registry, such that the first node is not required to distribute the resource that it produces to nodes other than the second node; and a third node defined to identify the second node as being responsible for the resource identifier, the third node being further defined to publish a subscription object for the resource, wherein the second node responds to the subscription object by entering the third node on the subscription registry for the resource produced by the first node. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
-
13. A method for establishing a subscription registry for a published resource in a decentralized network of interconnected nodes, comprising:
-
producing a resource at a first node for publication across a decentralized network; generating a hash value for the resource produced at the first node; identifying a second node as being responsible for a hash value range bounding the hash value generated for the resource; and assigning responsibility for the resource to the second node, whereby the second node is responsible for establishing and maintaining a subscription registry for the resource that includes identifiers of nodes that are to receive the resource produced by the first node, and whereby the second node is responsible for distributing the resource produced by the first node to each node having an identifier included within the subscription registry, such that the first node is not required to distribute the resource that it produces to nodes other than the second node. - View Dependent Claims (14, 15, 16, 17, 18, 19)
-
-
20. A data storage device for storing data to be read by a computer system, the data storage device including program instructions for establishing a subscription registry for a published resource in a decentralized network of interconnected nodes, comprising:
-
program instructions for producing a resource at a first node for publication across a decentralized network; program instructions for generating a hash value for the resource produced at the first node; program instructions for identifying a second node as being responsible for a hash value range bounding the hash value generated for the resource; and program instructions for assigning responsibility for the resource to the second node, whereby the second node is responsible for establishing and maintaining a subscription registry for the resource that includes identifiers of nodes that are to receive the resource produced by the first node, and whereby the second node is responsible for distributing the resource produced by the first node to each node having an identifier included within the subscription registry, such that the first node is not required to distribute the resource that it produces to nodes other than the second node. - View Dependent Claims (21, 22, 23, 24, 25, 26)
-
-
27. A method for subscribing to a resource published within a decentralized network of interconnected nodes, comprising:
-
performing a hashing operation on a key that is uniquely associated with a resource, the hashing operation generating a hash value that is uniquely associated with the resource, wherein the resource is a data item; publishing a subscription object for the resource at a node interested in the resource, the subscription object being assigned a hash value equivalent to the hash value associated with the resource, wherein the subscription object includes a reference to the node interested in the resource; transmitting the subscription object from the node interested in the resource to a node responsible for the hash value associated with both the resource and the subscription object for the resource; and operating the node responsible for the hash value associated with both the resource and subscription object for the resource to update a subscription registry for the resource to include information contained within the subscription object for the resource including the reference to the node interested in the resource. - View Dependent Claims (28, 29, 30, 31)
-
-
32. A data storage device for storing data to be read by a computer system, the data storage device including program instructions for subscribing to a resource published within a decentralized network of interconnected nodes, comprising:
-
program instructions for performing a hashing operation on a key that is uniquely associated with a resource, the hashing operation generating a hash value that is uniquely associated with the resource, wherein the resource is a data item; program instructions for publishing a subscription object for the resource at a node interested in the resource, the subscription object being assigned a hash value equivalent to the hash value associated with the resource, wherein the subscription object includes a reference to the node interested in the resource; program instructions for transmitting the subscription object from the node interested in the resource to a node responsible for the hash value associated with both the resource and the subscription object for the resource; and program instructions for operating the node responsible for the hash value associated with both the resource and subscription object for the resource to update a subscription registry for the resource to include information contained within the subscription object for the resource including the reference to the node interested in the resource. - View Dependent Claims (33, 34, 35, 36)
-
-
37. A computing device, comprising:
-
a processor; and a memory capable of storing program instructions to be executed by the processor, the program instructions including, computer code for accepting responsibility for a resource having a uniquely associated hash value within a hash value range assigned to the computing device, wherein the resource is a data item, computer code for establishing a subscription registry for the resource, computer code for receiving subscription objects that are uniquely associated with the resource from other computing devices and recording the subscription objects in the subscription registry, wherein each subscription object includes a reference to a computing device from which it is transmitted, and computer code for notifying computing devices having a recorded subscription object in the subscription registry of an event associated with the resource. - View Dependent Claims (38, 39, 40, 41, 42)
-
-
43. A mechanism for providing event notification in a decentralized network of interconnected nodes, comprising:
-
means for establishing a subscription registry for a resource published within the decentralized network, wherein the resource is a data item; means for receiving a subscription object for the resource from a node within the decentralized network, wherein the subscription object is uniquely associated with the resource, and wherein the subscription object includes a reference to the node from which it is transmitted; means for recording the subscription object in the subscription registry for the resource; means for receiving an update to the resource; and means for notifying each node having a subscription object recorded in the subscription registry for the resource of the update to the resource. - View Dependent Claims (44, 45)
-
Specification