Struct CbskClient

pub struct CbskClient {
    pub header: Arc<Vec<u8>>,
    /* private fields */
}

cbsk client

Fields

header: Arc<Vec<u8>>

cbsk header

Implementations

impl CbskClient

custom method

pub fn new<C: CbskClientCallBack>( cb: Arc<C>, addr: SocketAddr, buf_len: usize, ) -> Self

new cbsk client
if the tcp connection is disconnected, it will reconnect after 3 seconds

pub fn new_with_tcp_config<C: CbskClientCallBack>( cb: Arc<C>, conf: Arc<TcpClientConfig>, buf_len: usize, ) -> Self

use tcp client config create cbsk client

pub fn new_with_header<C: CbskClientCallBack>( cb: Arc<C>, addr: SocketAddr, header: Vec<u8>, buf_len: usize, ) -> Self

custom header create cbsk client

pub fn new_with_htc<C: CbskClientCallBack>( cb: Arc<C>, header: Vec<u8>, conf: Arc<TcpClientConfig>, buf_len: usize, ) -> Self

htc is an abbreviation for header_tcp_config

pub fn default_tcp_config(addr: SocketAddr) -> TcpClientConfig

get default tcp config

pub async fn start(&self)

start cbsk client

pub fn start_in_handle(&self) -> JoinHandle<()>

start cbsk client in join handle

pub async fn is_connected(&self) -> bool

get has the cbsk server connection been success

pub async fn stop(&self)

stop cbsk server connect
will shutdown tcp connection and will not new connection

pub async fn re_conn(&self)

notify tcp to re connect
will shutdown tcp connection, if TcpClientConfig reconn is disable
will shutdown and create new tcp connection,if TcpClientConfig reconn is enable

pub fn get_recv_time(&self) -> i64

the last time the data was received

pub fn get_config(&self) -> Arc<TcpClientConfig>

get tcp config

Trait Implementations

impl CbskWriteTrait for CbskClient

support write data to cbsk

fn get_log_head(&self) -> &str

get internal log name

async fn try_send_bytes(&self, bytes: Vec<u8>) -> Result<()>

try send bytes to cbsk

async fn send_text(&self, text: &str)

send text to cbsk

async fn try_send_text(&self, text: impl Into<String>) -> Result<()>

try send text to cbsk

async fn send_json(&self, json: &(impl Serialize + Sync))

send json to cbsk

async fn try_send_json(&self, json: &(impl Serialize + Sync)) -> Result<()>

try send json to cbsk

async fn send_bytes(&self, bytes: Vec<u8>)

send bytes to cbsk

impl TimeTrait for CbskClient

support time trait

fn set_recv_time(&self, time: i64)

set the last time the data was received for tcp

fn get_recv_time(&self) -> i64

get the last time the data was received for tcp

fn set_timeout_time(&self, time: i64)

set tcp last read timeout

fn get_timeout_time(&self) -> i64

get tcp last read timeout

fn set_wait_callback(&self, is_wait: bool)

set is wait callback

fn get_wait_callback(&self) -> bool

get is wait callback

fn set_ignore_once(&self, is_ignore: bool)

set ignore once time check

fn get_ignore(&self) -> bool

get ignore

fn set_now(&self)

set recv time and timeout time to now

fn set_recv_time_now(&self)

set recv time to now

fn set_timeout_time_now(&self)

set timeout time to now

fn now() -> i64

get now unix_timestamp_millis

fn wait_callback(&self)

need wait callback finish business logic

fn finish_callback(&self)

callback the business logic has been completed