Versions in this module Expand all Collapse all v1 v1.0.2 Aug 20, 2019 Changes in this version + var ErrConnLoopActive = errors.New("transport error: connection loop is already active") + var ErrNotConnected = errors.New("transport error: not connected") + type StreamTransportConn struct + func NewStreamTransportConn(params *StreamTransportParams) (*StreamTransportConn, error) + func (c *StreamTransportConn) Close() error + func (c *StreamTransportConn) CloseOpt(data []byte, stopReconnecting bool) error + func (c *StreamTransportConn) Connect() error + func (c *StreamTransportConn) GetState() TransportState + func (c *StreamTransportConn) OnRead(cb onReadCallback) + func (c *StreamTransportConn) OnStateChange(cb onStateChangeCallback) + func (c *StreamTransportConn) ResetTimeout() + func (c *StreamTransportConn) Send(ctx context.Context, data []byte) error + func (c *StreamTransportConn) URL() string + type StreamTransportParams struct + Backoff bool + MaxReconnectTimeout time.Duration + Reconnect bool + ReconnectTimeout time.Duration + URL string + type TransportState int + const TransportStateConnected + const TransportStateConnecting + const TransportStateDisconnected + const TransportStateWaitBeforeReconnect + type WebsocketTx struct + Data []byte + MessageType int + Res chan error