tcp

Documentation

Index

• type Linker
  • func NewLinker(handle uint64, remoteIp string, remotePort int, conn net.Conn, mode ServerMode) *Linker
  • func (l *Linker) Handle() uint64
  • func (l *Linker) Heartbeat() time.Time
  • func (l *Linker) Init(event TCPEvent)
  • func (l *Linker) Ip() string
  • func (l *Linker) Port() int
  • func (l *Linker) Recv()
  • func (l *Linker) RecvSize() int32
  • func (l *Linker) Send(data []byte) (error, int)
  • func (l *Linker) SendSize() int32
• type Packet
• type PacketMode
• type ServerMode
• type TCPClient
  • func NewTCPClient() *TCPClient
  • func (k *TCPClient) AddLinker(linker *Linker)
  • func (k *TCPClient) CreateHandler() uint64
  • func (k *TCPClient) Init(event TCPEvent)
  • func (k *TCPClient) OnDisconnect(handle uint64, remoteIp string, remotePort int)
  • func (k *TCPClient) OnError(handle uint64, remoteIp string, remotePort int, err error)
  • func (k *TCPClient) OnRead(handle uint64, remoteIp string, remotePort int, data []byte, size int) bool
  • func (k *TCPClient) OnSend(handle uint64, remoteIp string, remotePort int, size int)
  • func (k *TCPClient) Send(handle uint64, data []byte) (error, int)
  • func (k *TCPClient) Start(listen string) (error, uint64)
• type TCPEvent
• type TCPServer
  • func NewTCPServer() *TCPServer
  • func (k *TCPServer) AddLinker(linker *Linker)
  • func (k *TCPServer) CreateHandler() uint64
  • func (k *TCPServer) Init(event TCPEvent)
  • func (k *TCPServer) OnDisconnect(handle uint64, remoteIp string, remotePort int)
  • func (k *TCPServer) OnError(handle uint64, remoteIp string, remotePort int, err error)
  • func (k *TCPServer) OnRead(handle uint64, remoteIp string, remotePort int, data []byte, size int) bool
  • func (k *TCPServer) OnSend(handle uint64, remoteIp string, remotePort int, size int)
  • func (k *TCPServer) Send(handle uint64, data []byte) (error, int)
  • func (k *TCPServer) Start(listen string) error

Types

type Linker

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

func NewLinker

func NewLinker(handle uint64, remoteIp string, remotePort int, conn net.Conn, mode ServerMode) *Linker

func (*Linker) Handle

func (l *Linker) Handle() uint64

func (*Linker) Heartbeat

func (l *Linker) Heartbeat() time.Time

func (*Linker) Init

func (l *Linker) Init(event TCPEvent)

func (*Linker) Ip

func (l *Linker) Ip() string

func (*Linker) Port

func (l *Linker) Port() int

func (*Linker) Recv

func (l *Linker) Recv()

func (*Linker) RecvSize

func (l *Linker) RecvSize() int32

func (*Linker) Send

func (l *Linker) Send(data []byte) (error, int)

func (*Linker) SendSize

func (l *Linker) SendSize() int32

type Packet

type Packet struct {
	Mode PacketMode
	Size int32
}

type PacketMode

type PacketMode uint8

const (
	HeartBeat PacketMode = iota
	Message
)

type ServerMode

type ServerMode uint8

const (
	Server ServerMode = iota
	Client
)

type TCPClient

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

func NewTCPClient

func NewTCPClient() *TCPClient

func (*TCPClient) AddLinker

func (k *TCPClient) AddLinker(linker *Linker)

func (*TCPClient) CreateHandler

func (k *TCPClient) CreateHandler() uint64

func (*TCPClient) Init

func (k *TCPClient) Init(event TCPEvent)

func (*TCPClient) OnDisconnect

func (k *TCPClient) OnDisconnect(handle uint64, remoteIp string, remotePort int)

func (*TCPClient) OnError

func (k *TCPClient) OnError(handle uint64, remoteIp string, remotePort int, err error)

func (*TCPClient) OnRead

func (k *TCPClient) OnRead(handle uint64, remoteIp string, remotePort int, data []byte, size int) bool

func (*TCPClient) OnSend

func (k *TCPClient) OnSend(handle uint64, remoteIp string, remotePort int, size int)

func (*TCPClient) Send

func (k *TCPClient) Send(handle uint64, data []byte) (error, int)

func (*TCPClient) Start

func (k *TCPClient) Start(listen string) (error, uint64)

type TCPEvent

type TCPEvent interface {
	OnSend(handle uint64, remoteIp string, remotePort int, size int)
	OnRead(handle uint64, remoteIp string, remotePort int, data []byte, size int) bool
	OnDisconnect(handle uint64, remoteIp string, remotePort int)
	OnError(handle uint64, remoteIp string, remotePort int, err error)
}

type TCPServer

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

func NewTCPServer

func NewTCPServer() *TCPServer

func (*TCPServer) AddLinker

func (k *TCPServer) AddLinker(linker *Linker)

func (*TCPServer) CreateHandler

func (k *TCPServer) CreateHandler() uint64

func (*TCPServer) Init

func (k *TCPServer) Init(event TCPEvent)

func (*TCPServer) OnDisconnect

func (k *TCPServer) OnDisconnect(handle uint64, remoteIp string, remotePort int)

func (*TCPServer) OnError

func (k *TCPServer) OnError(handle uint64, remoteIp string, remotePort int, err error)

func (*TCPServer) OnRead

func (k *TCPServer) OnRead(handle uint64, remoteIp string, remotePort int, data []byte, size int) bool

func (*TCPServer) OnSend

func (k *TCPServer) OnSend(handle uint64, remoteIp string, remotePort int, size int)

func (*TCPServer) Send

func (k *TCPServer) Send(handle uint64, data []byte) (error, int)

func (*TCPServer) Start

func (k *TCPServer) Start(listen string) error