s2-storage 0.1.1

Storage-layer internals shared by S2 server implementations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

mod batcher;
mod codec;
mod encryption;
mod framing;
mod iterator;
#[cfg(any(test, feature = "test-util"))]
pub mod test_util;

pub use batcher::{RecordBatch, RecordBatcher};
pub use codec::StoredRecordDecodeError;
pub(crate) use codec::WireEncode;
pub use encryption::{
    EncryptedRecord, RecordDecryptionError, decrypt_read_session_output, decrypt_stored_record,
    encrypt_append_input, encrypt_record,
};
pub use framing::{
    StoredRecord, StoredSequencedBytes, StoredSequencedRecord, decode_if_command_record,
    decode_record, decode_stored_record, encode_stored_record, encode_stored_record_into,
    stored_record_encoded_size, try_metered_size,
};
pub use iterator::StoredRecordIterator;
use s2_common::stream::{
    AppendInput, AppendRecord, AppendRecordBatch, AppendRecordParts, ReadBatch, ReadSessionOutput,
};

pub type StoredAppendRecord = AppendRecord<StoredRecord>;
pub type StoredAppendRecordParts = AppendRecordParts<StoredRecord>;
pub type StoredAppendRecordBatch = AppendRecordBatch<StoredRecord>;
pub type StoredAppendInput = AppendInput<StoredRecord>;
pub type StoredReadBatch = ReadBatch<StoredRecord>;
pub type StoredReadSessionOutput = ReadSessionOutput<StoredRecord>;