Struct tdengine::RedisPool

pub struct RedisPool {
    pub db_redis: Vec<Cluster>,
    pub url_list: Vec<String>,
    pub mutex: Mutex<i32>,
    pub sub_fd: i32,
    pub sub_connect: Option<PubSub>,
    pub sub_receiver: Option<Mutex<Receiver<Msg>>>,
    pub sub_thread_run: Option<Arc<Mutex<bool>>>,
}

Fields

db_redis: Vec<Cluster>

url_list: Vec<String>

mutex: Mutex<i32>

sub_fd: i32

sub_connect: Option<PubSub>

sub_receiver: Option<Mutex<Receiver<Msg>>>

sub_thread_run: Option<Arc<Mutex<bool>>>

Methods

impl RedisPool

fn new() -> RedisPool

fn instance() -> &'static mut RedisPool

fn set_url_list(&mut self, url_list: Vec<String>) -> bool

fn get_redis_connection(&mut self) -> Option<Cluster>

fn release_redis_connection(&mut self, cluster: Cluster)

fn get_sub_connection(&mut self) -> Option<&mut PubSub>

fn get_sub_receiver(&mut self) -> Option<&mut Mutex<Receiver<Msg>>>

fn stop_recv_sub_msg(&mut self) -> bool

fn start_recv_sub_msg(&mut self)