tcp

Documentation

Index

• func Dial(addr string, ctx *lokas.Context) (*conn.Conn, error)
• func DialEx(addr string, ctx *lokas.Context, retryWait time.Duration) chan struct{}
• type Server
  • func NewServer(context *lokas.Context) *Server
  • func (this *Server) Broadcast(sessionIds []util.ID, data []byte)
  • func (this *Server) GetActiveConnNum() int
  • func (this *Server) Start(addr string) error
  • func (this *Server) Stop()

Functions

func Dial

func Dial(addr string, ctx *lokas.Context) (*conn.Conn, error)

func DialEx

func DialEx(addr string, ctx *lokas.Context, retryWait time.Duration) chan struct{}

Types

type Server

type Server struct {
	Context *lokas.Context
	// contains filtered or unexported fields
}

func NewServer

func NewServer(context *lokas.Context) *Server

NewServer create a new tcp server

func (*Server) Broadcast

func (this *Server) Broadcast(sessionIds []util.ID, data []byte)

Broadcast broadcast data to all active connections

func (*Server) GetActiveConnNum

func (this *Server) GetActiveConnNum() int

GetActiveConnNum get count of active connections

func (*Server) Start

func (this *Server) Start(addr string) error

Start start tcp server

func (*Server) Stop

func (this *Server) Stop()

Stop stop tcp server