tcp

Documentation

Index

• Constants
• type Protocol
• type TcpClient
  • func NewTcpClient(connectAddr string, protocol *Protocol, pinitwg *sync.WaitGroup) *TcpClient
  • func (c *TcpClient) Init()
  • func (c *TcpClient) Protocol() *Protocol
  • func (c *TcpClient) Shutdown()
• type TcpServer
  • func NewTcpServer(listenAddr string, protocol *Protocol, pinitwg *sync.WaitGroup) *TcpServer
  • func (s *TcpServer) Init()
  • func (s *TcpServer) Protocol() *Protocol
  • func (s *TcpServer) Shutdown()

Constants

const TcpDialTimeout time.Duration = 5 * time.Second

const TcpKeepIntvl time.Duration = 47 * time.Second // prime number that I chose for keep alive

const TcpReconIntvl time.Duration = 15 * time.Second

Types

type Protocol

type Protocol interface {
	Name() string
	Close()
	ReadLoop(*net.Conn)
}

type TcpClient

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

func NewTcpClient

func NewTcpClient(connectAddr string, protocol *Protocol, pinitwg *sync.WaitGroup) *TcpClient

func (*TcpClient) Init

func (c *TcpClient) Init()

func (*TcpClient) Protocol

func (c *TcpClient) Protocol() *Protocol

func (*TcpClient) Shutdown

func (c *TcpClient) Shutdown()

type TcpServer

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

func NewTcpServer

func NewTcpServer(listenAddr string, protocol *Protocol, pinitwg *sync.WaitGroup) *TcpServer

func (*TcpServer) Init

func (s *TcpServer) Init()

func (*TcpServer) Protocol

func (s *TcpServer) Protocol() *Protocol

func (*TcpServer) Shutdown

func (s *TcpServer) Shutdown()