server

Nov 13, 2023

Changes in this version

type Context

+ func NewContext(parent context.Context) *Context

Nov 8, 2023

Changes in this version

type Context

+ func (c *Context) Init(ctx context.Context)

Nov 19, 2022

Changes in this version

type IService

+ IsClosed func() bool

type TcpService

+ func (t *TcpService) IsClosed() bool

type WebSocketService

+ func (t *WebSocketService) IsClosed() bool

Aug 31, 2022

Changes in this version

type Server

+ OnSuccess func(*Server)

Jul 18, 2022

Changes in this version

+ type Config struct

+ Host string

+ PConfig connection.PacketConfig

+ Port int

+ func (c *Config) Load(path string) error

+ func (c *Config) Yaml(path string) error

+ type Context struct

+ func (c *Context) Connection() connection.IConnection

+ func (c *Context) Pack() connection.IPacket

+ func (c *Context) Reset()

+ func (c *Context) SetConnection(conn connection.IConnection)

+ func (c *Context) SetPack(pack connection.IPacket)

+ func (c *Context) SetSpanId(spanId string)

+ func (c *Context) SetTraceId(traceId string)

+ func (c *Context) SpanId() string

+ func (c *Context) TraceId() string

+ type HostInfo struct

+ Host string

+ Port int

+ type IHandler interface

+ Close func(connection.IConnection) error

+ Connect func(connection.IConnection) error

+ Packet func([]byte) (connection.IPacket, error)

+ Receive func(*Context) error

+ type IService interface

+ Accept func() (connection.IConnection, error)

+ Close func()

+ Listen func(host string, port int) error

+ Shutdown func()

+ type Server struct

+ func NewServer(config Config) *Server

+ func (s *Server) Close(fd int) error

+ func (s *Server) Maintain()

+ func (s *Server) Run()

+ func (s *Server) Send(pack connection.IPacket, fd int) error

+ func (s *Server) SetHandler(handler IHandler) *Server

+ func (s *Server) SetService(service IService) *Server

+ func (s *Server) Shutdown()

+ type TcpService struct

+ func NewTcpService(connMax int) *TcpService

+ func (t *TcpService) Accept() (connection.IConnection, error)

+ func (t *TcpService) Close()

+ func (t *TcpService) Listen(host string, port int) error

+ func (t *TcpService) Shutdown()

+ type WebSocketService struct

+ func NewWebSocketService(connMax int) *WebSocketService

+ func (t *WebSocketService) Accept() (connection.IConnection, error)

+ func (t *WebSocketService) Close()

+ func (t *WebSocketService) Listen(host string, port int) error

+ func (t *WebSocketService) Shutdown()