tcp

Aug 16, 2020

Changes in this version

+ const DefaultBufferSize

+ func HandleSignals(onTrapped func(s os.Signal)) (waiter func())

+ func StopServer(s *Server)

+ type Client struct

+ CmdrTlsConfig *tls.CmdrTlsConfig

+ func NewClient(addr string, opts ...ClientOpt) *Client

+ func (s *Client) Close()

+ func (s *Client) IsClosed() bool

+ func (s *Client) Send(data []byte)

+ type ClientOpt func(*Client)

+ func WithClientLogger(l log.Logger) ClientOpt

+ func WithClientOnConnectedFunc(fn OnTcpConnectedFunc) ClientOpt

+ func WithClientOnDisconnectedFunc(fn OnTcpDisconnectedFunc) ClientOpt

+ func WithClientOnProcessFunc(fn OnTcpProcessFunc) ClientOpt

+ func WithClientReadBufferSize(size int) ClientOpt

+ func WithClientTlsConfig(s *tls.CmdrTlsConfig) ClientOpt

+ 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 func(buf []byte, in io.Reader, out io.Writer) (nn int, err error)

+ type Server struct

+ CmdrTlsConfig *tls.CmdrTlsConfig

+ func StartServer(addr string, opts ...ServerOpt) *Server

+ func (s *Server) Close() (err error)

+ func (s *Server) Start() (err error)

+ func (s *Server) Stop()

+ type ServerOpt func(*Server)

+ func WithLogger(l log.Logger) ServerOpt

+ func WithServerBufferSize(size int) ServerOpt

+ func WithServerConnectedWithClient(fn OnTcpServerConnectedWithClient) ServerOpt

+ func WithServerDisconnectedWithClient(fn OnTcpServerDisconnectedWithClient) ServerOpt

+ func WithServerListening(fn OnTcpServerListening) ServerOpt

+ func WithServerOnProcessFunc(onProcess OnTcpServerProcessFunc) ServerOpt

+ func WithServerReadWriter(onCreateReadWriter OnTcpServerCreateReadWriter) ServerOpt

+ func WithTlsConfig(s *tls.CmdrTlsConfig) ServerOpt