liner_broker 1.1.3

Redis based message serverless broker.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

pub const WRITE_BUFFER_CAPASITY: usize = 8192;
pub const READ_BUFFER_CAPASITY: usize = 8192;
pub const BYTESTREAM_READ_BUFFER_SIZE: usize = 4096;
pub const BYTESTREAM_WRITE_BUFFER_SIZE: usize = 4096;
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 SENDER_THREAD_WAIT_TIMEOUT_MS: u64 = 100;
pub const LISTENER_THREAD_WAIT_TIMEOUT_MS: u64 = 100;
pub const SENDER_THREAD_WRITE_MESS_DELAY_MS: u64 = 1;
pub const SENDER_THREAD_WRITE_MESS_DELAY_REPEATE_COUNT: u64 = 10;
pub const LISTENER_THREAD_READ_MESS_DELAY_MS: u64 = 1;
pub const LISTENER_THREAD_READ_MESS_DELAY_REPEATE_COUNT: u64 = 10;
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;
pub const MEMPOOL_MIN_PERCENT_FOR_COMPRESS: f32 = 0.2;