Expand description
Zenoh /zeno/ is a stack that unifies data in motion, data at rest, and computations. It elegantly blends traditional pub/sub with geo-distributed storage, queries, and computations, while retaining a level of time and space efficiency that is well beyond any of the mainstream stacks.
This crate provides components extending the core Zenoh functionalities.
These components include
§Serialization
The base zenoh library allows to send/receive data as raw bytes payload. But in order to simplify the library’s usability and, more importantly, to ensure interoperability between zenoh-based applications, this crate provides serialization/deserialization functionalities.
The key functions are z_serialize and z_deserialize that allows to
serialize/deserialize any data structure implementing the Serialize and
Deserialize traits respectively.
§Advanced Pub/Sub
The AdvancedPublisher and AdvancedSubscriber provide advanced pub/sub
functionalities, including support for message history, recovery, and more.
Modules§
- group
- To manage groups and group memberships
Structs§
- Advanced
Publication Builder - Advanced
Publisher - The extension to a
Publisherproviding advanced functionalities. - Advanced
Publisher Builder - The builder of AdvancedPublisher, allowing to configure it.
- Advanced
Subscriber - The extension to
Subscriberthat provides advanced functionalities - Advanced
Subscriber Builder - The builder of an
AdvancedSubscriber, allowing to configure it. - Cache
Config - Configure an
AdvancedPublishercache. - Fetching
Subscriber Deprecated - A Subscriber that will run the given user defined
fetchfunction at startup. - Fetching
Subscriber Builder Deprecated - The builder of
FetchingSubscriber, allowing to configure it. - History
Config - Configure query for historical data for
historymethod. - Liveliness
Space Deprecated - The key space for liveliness tokens.
- Miss
- A struct that represent missed samples.
- Miss
Detection Config - Configuration for sample miss detection
- Publication
Cache Deprecated PublicationCache.- Publication
Cache Builder Deprecated - The builder of PublicationCache, allowing to configure it.
- Querying
Subscriber Builder Deprecated - The builder of
FetchingSubscriber, allowing to configure it. - Recovery
Config - Configure retransmission.
- Replies
Config - Configure replies.
- Sample
Miss Handler Undeclaration - A
Resolvablereturned bySampleMissListener::undeclare - Sample
Miss Listener - A listener to detect missed samples.
- Sample
Miss Listener Builder - A builder for initializing a
SampleMissListener. - User
Space Deprecated - The key space for user data.
- ZDeserialize
Error - Error occurring in deserialization.
- ZDeserializer
- Deserializer implementing the Zenoh serialization format.
- ZRead
Iter - Iterator returned by
ZDeserializer::deserialize_iter. - ZSerializer
- Serializer implementing the Zenoh serialization format.
Enums§
- KeySpace
Deprecated - The space of keys to use in a
FetchingSubscriber.
Traits§
- Advanced
Publisher Builder Ext - Some extensions to the
zenoh::publication::PublisherBuilder - Advanced
Subscriber Builder Ext - Some extensions to the
zenoh::subscriber::SubscriberBuilder - Deserialize
- Deserialization implementation.
- Extract
Sample Deprecated ExtractSample.- Serialize
- Serialization implementation.
- Session
Ext - Some extensions to the
zenoh::Session - Subscriber
Builder Ext Deprecated - Some extensions to the
zenoh::subscriber::SubscriberBuilder - Subscriber
Forward - Allows writing
subscriber.forward(receiver)instead ofsubscriber.stream().map(Ok).forward(publisher)
Functions§
- z_
deserialize - Deserialize an object according to the Zenoh serialization format.
- z_
serialize - Serialize an object according to the Zenoh serialization format.