liner_broker 1.0.6

Redis based message serverless broker.
Documentation 
1
2
3
4
5
6
7
8
9
10
11

pub const WRITE_BUFFER_CAPASITY: usize = 8192;
pub const READ_BUFFER_CAPASITY: usize = 8192;
pub const EPOLL_LISTEN_EVENTS_COUNT: usize = 128;
pub const CHECK_AVAILABLE_STREAM_TIMEOUT_MS: u64 = 10*1000;  //10sec
pub const UPDATE_LAST_MESS_NUMBER_TIMEOUT_MS: u64 = 1000;    //1s
pub const UPDATE_SENDER_ADDRESSES_TIMEOUT_MS: u64 = 10*1000; //10s
pub const WRITE_MESS_DELAY_MS: u64 = 1;
pub const READ_MESS_DELAY_MS: u64 = 1;
pub const MIN_SIZE_DATA_FOR_COMPRESS_BYTE: usize = 1024*1024;
pub const DATA_COMPRESS_LEVEL: i32 = 0; // A level of `0` uses zstd's default (currently `3`).
pub const IS_CHECK_NEW_ADDRESS_TOPIC_ENABLE: bool = false;