tcp

Documentation

Index

• type Client
  • func NewClient(serveraddr string) *Client
  • func (c *Client) Send(msg []byte) error
  • func (c *Client) SetOnMsgRecv(handler OnClientMsgRecv) *Client
  • func (c *Client) SetOnStateChange(handler OnClientStateChange) *Client
  • func (c *Client) Start() error
  • func (c *Client) Stop()
• type ClientState
• type OnClientMsgRecv
• type OnClientStateChange
• type Server
  • func NewServer(addr string) *Server
  • func (s *Server) SetOnMsgRecv(handler OnClientMsgRecv) *Server
  • func (s *Server) SetOnPeerStateChange(handler OnClientStateChange) *Server
  • func (s *Server) Start() error
  • func (s *Server) Stop()

Types

type Client

type Client struct {
	ServerAddr string

	OnStateChange OnClientStateChange
	OnMsgRecv     OnClientMsgRecv

	Conn net.Conn

	State ClientState
	// contains filtered or unexported fields
}

func NewClient

func NewClient(serveraddr string) *Client

func (*Client) Send

func (c *Client) Send(msg []byte) error

func (*Client) SetOnMsgRecv

func (c *Client) SetOnMsgRecv(handler OnClientMsgRecv) *Client

func (*Client) SetOnStateChange

func (c *Client) SetOnStateChange(handler OnClientStateChange) *Client

func (*Client) Start

func (c *Client) Start() error

func (*Client) Stop

func (c *Client) Stop()

type ClientState

type ClientState int

const (
	ClientConnected ClientState = iota
	ClientDisconnected
)

type OnClientMsgRecv

type OnClientMsgRecv func(c *Client, msg []byte, err error)

type OnClientStateChange

type OnClientStateChange func(c *Client, newstate ClientState)

type Server

type Server struct {
	ServerAddr string

	OnClientStateChange OnClientStateChange
	OnClientMsgRecv     OnClientMsgRecv

	Listener net.Listener
	Conns    []net.Conn
}

func NewServer

func NewServer(addr string) *Server

func (*Server) SetOnMsgRecv

func (s *Server) SetOnMsgRecv(handler OnClientMsgRecv) *Server

func (*Server) SetOnPeerStateChange

func (s *Server) SetOnPeerStateChange(handler OnClientStateChange) *Server

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop()