Skip to main content

Crate yantrikdb_protocol

Crate yantrikdb_protocol 

Source

Re-exports§

pub use codec::YantrikCodec;
pub use error::ProtocolError;
pub use frame::Frame;
pub use opcodes::OpCode;

Modules§

codec
error
frame
messages
Typed message payloads for each wire protocol command.
opcodes

Functions§

make_error
Build a frame with an error response.
make_frame
Build a complete frame from an opcode, stream ID, and serializable payload.
make_frame_auto_compress
Build a frame whose payload is auto-compressed if it exceeds min_size_bytes.
pack
Helper: serialize a message to MessagePack bytes.
pack_compressed
Pack and zstd-compress a message. Use for large payloads (oplog batches, recall results).
unpack
Helper: deserialize a message from MessagePack bytes.
unpack_frame
Decompress a frame’s payload if it’s marked compressed, then unpack. Use this in handlers instead of unpack directly when the payload may be compressed.