tcpx

Documentation

Index

• Variables
• func GetTCPAddr(network string, address string) (*net.TCPAddr, error)
• func TCPAddrEqual(addr1 *net.TCPAddr, addr2 *net.TCPAddr) bool
• type ITCPClient
  • func NewTCP4Client() ITCPClient
  • func NewTCP6Client() ITCPClient
  • func NewTCPClient() ITCPClient
• type ITCPServer
  • func NewTCP4Server() ITCPServer
  • func NewTCP6Server() ITCPServer
  • func NewTCPServer() ITCPServer
• type TCPClient
  • func (c *TCPClient) CloseClient() error
  • func (c *TCPClient) OpenClient(params netx.SockParams) error
• type TCPServer
  • func (s *TCPServer) CloseConnection(address string) (err error, ok bool)
  • func (s *TCPServer) Connections() int
  • func (s *TCPServer) SendBytesTo(data []byte, rAddress ...string) error
  • func (s *TCPServer) SendPackTo(pack []byte, rAddress ...string) error
  • func (s *TCPServer) StartServer(params netx.SockParams) error
  • func (s *TCPServer) StopServer() error

Variables

var TcpDataBlockHandler = bytex.NewDefaultDataBlockHandler()

Functions

func GetTCPAddr

func GetTCPAddr(network string, address string) (*net.TCPAddr, error)

func TCPAddrEqual

func TCPAddrEqual(addr1 *net.TCPAddr, addr2 *net.TCPAddr) bool

Types

type ITCPClient

type ITCPClient interface {
	netx.ISockClient
}

func NewTCP4Client

func NewTCP4Client() ITCPClient

func NewTCP6Client

func NewTCP6Client() ITCPClient

func NewTCPClient

func NewTCPClient() ITCPClient

type ITCPServer

type ITCPServer interface {
	netx.ISockServer
	eventx.IEventDispatcher
}

func NewTCP4Server

func NewTCP4Server() ITCPServer

func NewTCP6Server

func NewTCP6Server() ITCPServer

func NewTCPServer

func NewTCPServer() ITCPServer

type TCPClient

type TCPClient struct {
	netx.SockClientBase
}

func (*TCPClient) CloseClient

func (c *TCPClient) CloseClient() error

func (*TCPClient) OpenClient

func (c *TCPClient) OpenClient(params netx.SockParams) error

type TCPServer

type TCPServer struct {
	eventx.EventDispatcher
	netx.SockServerBase
	lang.ChannelLimit
	// contains filtered or unexported fields
}

func (*TCPServer) CloseConnection

func (s *TCPServer) CloseConnection(address string) (err error, ok bool)

func (*TCPServer) Connections

func (s *TCPServer) Connections() int

func (*TCPServer) SendBytesTo

func (s *TCPServer) SendBytesTo(data []byte, rAddress ...string) error

func (*TCPServer) SendPackTo

func (s *TCPServer) SendPackTo(pack []byte, rAddress ...string) error

func (*TCPServer) StartServer

func (s *TCPServer) StartServer(params netx.SockParams) error

func (*TCPServer) StopServer

func (s *TCPServer) StopServer() error