tcp

Documentation

Index

• Constants
• func Connect(addr string, timeout int32, f func(err error, sock *Socket))
• type ConnectQ
  • func NewConnectQ() *ConnectQ
  • func (self *ConnectQ) Close()
  • func (self *ConnectQ) Connect(f func(done func()), delay int32)
  • func (self *ConnectQ) Open()
• type Server
  • func CreateServer() *Server
  • func (self *Server) Listen(addr string) *Server
  • func (self *Server) OnConnection(f func(sock *Socket)) *Server
  • func (self *Server) OnError(f func(err error)) *Server
  • func (self *Server) Stop()
• type Socket
  • func (self *Socket) Close()
  • func (self *Socket) HeartBeat(ms uint32)
  • func (self *Socket) OnClose(f func())
  • func (self *Socket) OnData(f func(buf []byte))
  • func (self *Socket) RemoteAddr() string
  • func (self *Socket) RemoteIP() string
  • func (self *Socket) RemotePort() int32
  • func (self *Socket) Send(buf []byte)
  • func (self *Socket) TcpNoDelay(b bool)

Constants

const (
	C_read_buf_size  = 4096
	C_max_write_size = 4096
	C_qw_max_size    = 10000
)

Functions

func Connect

func Connect(addr string, timeout int32, f func(err error, sock *Socket))

Types

type ConnectQ

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

func NewConnectQ

func NewConnectQ() *ConnectQ

func (*ConnectQ) Close

func (self *ConnectQ) Close()

func (*ConnectQ) Connect

func (self *ConnectQ) Connect(f func(done func()), delay int32)

func (*ConnectQ) Open

func (self *ConnectQ) Open()

type Server

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

func CreateServer

func CreateServer() *Server

func (*Server) Listen

func (self *Server) Listen(addr string) *Server

func (*Server) OnConnection

func (self *Server) OnConnection(f func(sock *Socket)) *Server

func (*Server) OnError

func (self *Server) OnError(f func(err error)) *Server

func (*Server) Stop

func (self *Server) Stop()

type Socket

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

func (*Socket) Close

func (self *Socket) Close()

func (*Socket) HeartBeat

func (self *Socket) HeartBeat(ms uint32)

func (*Socket) OnClose

func (self *Socket) OnClose(f func())

func (*Socket) OnData

func (self *Socket) OnData(f func(buf []byte))

func (*Socket) RemoteAddr

func (self *Socket) RemoteAddr() string

func (*Socket) RemoteIP

func (self *Socket) RemoteIP() string

func (*Socket) RemotePort

func (self *Socket) RemotePort() int32

func (*Socket) Send

func (self *Socket) Send(buf []byte)

func (*Socket) TcpNoDelay

func (self *Socket) TcpNoDelay(b bool)