Struct GCRuntimeTCPManager 

pub struct GCRuntimeTCPManager {
    port: u16,
    polling_rate_ms_wait: u64,
    stalled_connection_timeout: Duration,
    tx_connection_buffer_size: usize,
    rx_connection_buffer_size: usize,
    controller: Arc<GCGatewayController>,
    channel_tx: SyncSender<ChannelMessage>,
    channel_rx: Receiver<ChannelMessage>,
}

Fields

port: u16

polling_rate_ms_wait: u64

stalled_connection_timeout: Duration

tx_connection_buffer_size: usize

rx_connection_buffer_size: usize

controller: Arc<GCGatewayController>

channel_tx: SyncSender<ChannelMessage>

channel_rx: Receiver<ChannelMessage>

Implementations

impl GCRuntimeTCPManager

pub fn new(port: u16, controller: Arc<GCGatewayController>) -> Self

pub fn set_tx_connection_buffer_size(self, capacity: usize) -> Self

pub fn set_rx_connection_buffer_size(self, capacity: usize) -> Self

pub fn set_server_stalled_connection_timeout(self, timeout: Duration) -> Self

pub fn set_port(self, port: u16) -> Self

pub fn set_polling_rate(self, rate_ms: u64) -> Self

fn handle_new_runtime( &self, addr: SocketAddr, network_manager: &mut GCNetworkManager<GCRuntimeTCPState>, )

Connects to the new runtime and announces the current subscribed datapoints.

pub fn spawn(self) -> Result<GCRuntimeTCP, GCNetError>