Crate orkas_core

Expand description

Orkas

Decentralized MQ implementation with SWIM, CRDT and Limlog. This crate depends on Tokio.

Re-exports

pub use tokio;
pub use model::OrkasConfig;

Modules

consts
Constants
model
Models include data wrapper and type aliases used in the project.

Structs

Handle
A cheap-to-clone handle to interact with the cluster. This cannot control the lifecycle of the background tasks. For that, you need to use the Orkas struct.
Orkas
The main struct of Orkas.
SerdeBincodeCodec
A codec that uses consecutive bincode to serialize and deserialize messages.

Traits

Functions

adapt
Helper function to construct a pair of stream and sink with codec deserialize to Envelope from given pair of reader and writer.
adapt_with_option
Helper function to construct a pair of stream and sink with codec deserialize to Envelope from given pair of reader and writer. This is like adapt but with a custom bincode option.