Methods, apparatus, and articles of manufacture for decentralized data storage and processing for IoT devices are disclosed. An example apparatus includes memory; and a processor to cause storage of a contract in an off-chain datastore; generate a hash value of the contract; cause storage of the hash value on a blockchain to be accessible to multiple nodes in an IoT network; and cause storage of a transaction on the blockchain, the transaction corresponding to an objective of the contract based on data sensed by an IoT device in the IoT network.

A device may include a memory storing instructions and processor configured to execute the instructions to receive, by a first blockchain node and via a first base station, a message from a first Internet of Things (IoT) device to a second IoT device, wherein the device corresponds to a first multi-access edge computing (MEC) device located in a first MEC network associated with the first base station. The processor may be further configured to authenticate, by the first blockchain node, the first IoT device using a blockchain associated with a group of IoT devices and send, by the first blockchain node, the message to a second blockchain node in a second MEC device in a second MEC network associated with a second base station servicing the second IoT device, in response to authenticating the first IoT device using the blockchain associated with the group of IoT devices.

A method including determining, by a first device in communication with a second device in a mesh network, an access policy associated with processing communications received from the second device; processing, by the first device based at least in part on the access policy, a first communication received from the second device over an exclusive meshnet connection between the first device and the second device; determining, by the first device, a change in the access policy associated with processing communications received from the second device; processing, by the first device based at least in part on the change in the access policy, a second communication received from the second device in real-time; and transmitting, by the first device to the second device, access policy information indicating the change in the access policy to the second device over the exclusive meshnet connection or via a relay server.

A system that facilitates sharing of multimedia content includes a user interface, network circuitry; and one or more processors. The processors perform operations that include displaying, via the user interface, a list of one or more media playback devices available to be added to a social networking group. A selection of first and second media playback devices to be associated with a particular social networking group is received via the user interface. The first media playback device is associated with a first playback queue that specifies a first set of media items associated with first media content that can be streamed from a first streaming service to the first media playback device. An indication to the social networking system that specifies the selection of the first and second media playback devices to be associated with the group is communicated via the network circuitry. In response, the social networking system communicates second media content items associated with the first media content items to a second playback queue associated with the second media playback device. The second playback items facilitate streaming of second media content associated with the first media content from a second streaming service to the second media playback device.

A geolocation-based data sharing system and method which enables end users to connect and share electronic data of any form based on the users' interaction with geolocation points established by other users. The systems and method can be used to enable end users to share data, text, photos, music, etc. when a second user positions himself or herself in a position assigned by a first user.

Described embodiments provide systems and methods for pushing session information to a newly joined node in a cluster of nodes. In the cluster, each node may maintain a session table of existing sessions. One or more nodes may detect a new node has joined the cluster. Each node, responsive to the detection, may apply a hash function on a tuple of each session of the existing sessions in the session table of the node to determine whether one or more existing sessions are identified to be owned by the new node as a result of the hash function. Each node, responsive to identifying that one or more sessions are to be owned by the new node, may push corresponding session information to the new node. The new node may become configured to receive a packet corresponding to the one or more sessions and to process the packet.

Disclosed are embodiments for providing batch performance using a stream processor. In one embodiment, a method is disclosed comprising receiving, at a stream processor, an event, the stream processor including a plurality of processing stages; generating, by the stream processor, an augmented event based on the event, the augmented event including at least one additional field not appearing in the event, the additional field generated by an operation selected from the group consisting of a join or dimensional annotation operation; and emitting, by the stream processor, the augmented event to downstream consumer.

An electronic device of a first user configured to connect with a second electronic device of a second user over a first peer-to-peer wireless network link; send to the second electronic device, a first unique code generated by the first electronic device, corresponding to a first user identifier of the first electronic device; receive from the second electronic device, a second unique code generated by the second electronic device, corresponding to a second user identifier of the second electronic device; store on the first electronic device, information indicating the proximity of the second electronic device and the time when the second electronic device is within the communicable range of the first electronic device; compare the second unique code with a third unique code downloaded from a web server; and, upon determining that the third unique code matches the second unique code, display a notification on the first electronic device.

Method, systems and apparatuses may provide for technology that provides a decentralized network. The technology may include a managing node that generates a list of a plurality of compute nodes that are within a tier. The technology may further include a first compute node providing compute resources for other nodes to utilize. The first compute node conducts a determination that the first compute node is within the tier based at least in part on the compute resources, and sends a notification to the managing node to add the first compute node to the list based on the determination. The technology may also include a client node conducting an identification of the tier based on a compute capacity that is predicted to be utilized to execute one or more tasks associated with the client node. The client node identifies the managing node based on the identification and requests the list from the managing node.

A method is provided of managing a non-static collection of machines. A first client machine runs a first communication protocol. The non-static collection of machines includes a first linear communication orbit, the first linear communication orbit comprising a sequence of machines that run the first communication protocol, and a second linear communication orbit, the second linear communication orbit comprising a sequence of machines that run a second communication protocol distinct from the first communication protocol. The first client machine receives an instruction from a server to install the second communication protocol, installs the second communication protocol, and then submits a registration request to the server. The first client machine receives, from the server, contact information of a list of potential neighbors. The first client machine then, proactively constructs and maintains a respective local segment of the second linear communication orbit.