tcp

Documentation

Index

• type Client
  • func NewClient(conn net.Conn, timeout time.Duration, buff []byte) Client
• type Server
  • func NewServer(sock net.Listener, onConn onConnection) *Server
  • func (s *Server) GracefulShutdown() error
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Types

type Client

type Client interface {
	Read() ([]byte, error)
	Unread([]byte)
	Write([]byte) error
	Remote() net.Addr
	Close() error
}

func NewClient

func NewClient(conn net.Conn, timeout time.Duration, buff []byte) Client

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(sock net.Listener, onConn onConnection) *Server

func (*Server) GracefulShutdown

func (s *Server) GracefulShutdown() error

GracefulShutdown stops a listener, but leaving all the connections free to end their lives peacefully

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error

Stop shuts listener and ALL the connections down