tcp

type Client struct {
	CmdrTlsConfig *tls.CmdrTlsConfig
	// contains filtered or unexported fields
}

type ClientOpt func(*Client)

type OnTcpConnectedFunc func(c *Client, conn net.Conn)

type OnTcpDisconnectedFunc func(c *Client)

type OnTcpProcessFunc func(buf []byte, in *bufio.Reader, out *bufio.Writer) (nn int, err error)

type OnTcpServerConnectedWithClient func(ss *Server, conn net.Conn)

type OnTcpServerCreateReadWriter func(ss *Server, conn net.Conn, tsConnected time.Time) (in io.Reader, out io.Writer)

type OnTcpServerDisconnectedWithClient func(ss *Server, conn net.Conn, reader io.Reader)

type OnTcpServerListening func(ss *Server, l net.Listener)

type OnTcpServerProcessFunc func(buf []byte, in io.Reader, out io.Writer) (nn int, err error)

type Processor interface {
	// Process implements Processor interface to announce that i will process the incoming data in Read().
	Process(buf []byte, in io.Reader, out io.Writer) (nn int, err error)
}

type Server struct {
	CmdrTlsConfig *tls.CmdrTlsConfig
	// contains filtered or unexported fields
}

type ServerOpt func(*Server)