Expand description
This crate provides mechanisms to publish and consume messages of a Decentralized Message Queue network through a DMQ node.
Modules§
- test
- Test utilities.
Structs§
- DmqConsumer
Client Deduplicator - A DMQ consumer client that filters out duplicate messages.
- DmqConsumer
Client Pallas - A DMQ client consumer implementation.
- DmqConsumer
Server Pallas - A DMQ server implementation for messages notification from a DMQ node.
- DmqMessage
- Wrapper for a DMQ message which can be serialized and deserialized.
- DmqMessage
Builder - A builder for creating DMQ messages.
- DmqPublisher
Client Pallas - A DMQ client publisher implementation.
- DmqPublisher
Server Pallas - A DMQ server implementation for messages publication to a DMQ node.
- System
Unix Timestamp Provider - Provides the current timestamp in seconds since the UNIX epoch from the system.
Enums§
- DmqNetwork
- The Dmq Network that is being targeted
Constants§
- DMQ_
MESSAGE_ DEDUPLICATOR_ TTL - Default maximum time to keep a seen message in the deduplicator cache.
Traits§
- DmqConsumer
Client - Trait for the client side of consuming messages from a DMQ node.
- DmqConsumer
Server - Trait for the server side of consuming messages from a DMQ node.
- DmqPublisher
Client - Trait for the client side of publishing messages from a DMQ node.
- DmqPublisher
Server - Trait for the server side of publishing messages from a DMQ node.