server

package

Go to main page

Versions in this module

v1

v1.0.5

Jun 8, 2023

Changes in this version

type Server

+ func (s *Server) TotalConnect() int

v1.0.4

Jun 5, 2023

v1.0.3

Mar 19, 2023

Changes in this version

type BaseConnect

+ func (c *BaseConnect) IsUDP() bool

type Option

+ func WithUDPPacketBufferLength(length uint) Option

type Options

+ UDPPacketBufferLength uint

type Server

+ func UDP(ip string, port int, opts ...Option) *Server

v1.0.2

Sep 20, 2022

v1.0.1

Sep 8, 2022

Changes in this version

type BaseConnect

+ func (c *BaseConnect) GetQueryStringParam() url.Values

v1.0.0

Jul 22, 2022

v0

v0.1.7

Jun 19, 2022

Changes in this version

+ type MiddlewareGroup struct

+ func (m *MiddlewareGroup) AddRouter(msgID uint32, router iface.IRouter)

+ func (m *MiddlewareGroup) GetMiddlewares() []iface.MiddlewareFunc

+ func (m *MiddlewareGroup) GetRouters() map[uint32]iface.IRouter

type RouterMgr

+ func (r *RouterMgr) Conversion(middlewares []iface.MiddlewareFunc) []iface.IStage

+ func (r *RouterMgr) Dispatch(ctx iface.IContext, options *Options)

+ func (r *RouterMgr) NewGroup(callable iface.MiddlewareFunc, more ...iface.MiddlewareFunc) iface.IMiddlewareGroup

+ func (r *RouterMgr) ResolveGroup() error

type Server

+ func (s *Server) Group(callable iface.MiddlewareFunc, more ...iface.MiddlewareFunc) iface.IMiddlewareGroup

+ func (s *Server) Use(callable iface.MiddlewareFunc) *Server

v0.1.6

Apr 13, 2022

v0.1.5

Mar 20, 2022

Changes in this version

+ const BINMODE

+ const CLOSE

+ const CONTINUATION

+ const PING

+ const PONG

+ const TEXTMODE

+ type BaseConnect struct

+ Address net.Addr

+ func (c *BaseConnect) Binary(bytes []byte) (int, error)

+ func (c *BaseConnect) Close() error

+ func (c *BaseConnect) GetAddress() net.Addr

+ func (c *BaseConnect) GetCertificate() tls.Certificate

+ func (c *BaseConnect) GetConnectMgr() iface.IConnectManager

+ func (c *BaseConnect) GetEpFd() int

+ func (c *BaseConnect) GetFd() int

+ func (c *BaseConnect) GetHandshakeCompleted() bool

+ func (c *BaseConnect) GetID() int

+ func (c *BaseConnect) GetLastMessageTime() time.Time

+ func (c *BaseConnect) GetPacker() iface.IPacker

+ func (c *BaseConnect) GetPoller() iface.IPoller

+ func (c *BaseConnect) GetTLSEnable() bool

+ func (c *BaseConnect) GetTLSLayer() *tls.Conn

+ func (c *BaseConnect) GetWriteBuff() ([]byte, bool)

+ func (c *BaseConnect) LocalAddr() net.Addr

+ func (c *BaseConnect) ProceedWrite() error

+ func (c *BaseConnect) Read(bs []byte) (int, error)

+ func (c *BaseConnect) RemoteAddr() net.Addr

+ func (c *BaseConnect) Send(msgID uint32, bs []byte) (int, error)

+ func (c *BaseConnect) SetDeadline(t time.Time) error

+ func (c *BaseConnect) SetEpFd(epfd int)

+ func (c *BaseConnect) SetHandshakeCompleted()

+ func (c *BaseConnect) SetLastMessageTime(duration time.Time)

+ func (c *BaseConnect) SetPoller(poller iface.IPoller)

+ func (c *BaseConnect) SetReadDeadline(t time.Time) error

+ func (c *BaseConnect) SetState(state common.ConnectState)

+ func (c *BaseConnect) SetWriteBuff(bytes []byte)

+ func (c *BaseConnect) SetWriteDeadline(t time.Time) error

+ func (c *BaseConnect) Text(bytes []byte) (int, error)

+ func (c *BaseConnect) Write(dataPack []byte) (int, error)

type Options

+ Application common.ApplicationMode

+ WebsocketHandler iface.IWebsocketHandler

type Server

+ func Websocket(ip string, port int, handler iface.IWebsocketHandler, opts ...Option) *Server

v0.1.4

Mar 6, 2022

Changes in this version

type Option

+ func WithTLSConfig(config *tls.Config) Option

type Options

+ TlsConfig *tls.Config

v0.1.3

Mar 3, 2022

Changes in this version

type Connect

+ func (c *Connect) NonBlockingRead() (iface.IMessage, error)

+ func (c *Connect) ProceedWrite() error

v0.1.2

Mar 1, 2022

v0.1.1

Mar 1, 2022

Changes in this version

type Connect

+ func (c *Connect) GetConnectMgr() iface.IConnectManager

type ConnectManager

+ func (c *ConnectManager) GetConnects() []iface.IConnect

v0.1.0

Feb 28, 2022

Changes in this version

type Connect

+ func (c *Connect) GetCertificate() tls.Certificate

+ func (c *Connect) GetHandshakeCompleted() bool

+ func (c *Connect) GetTLSEnable() bool

+ func (c *Connect) GetTLSLayer() *tls.Conn

+ func (c *Connect) LocalAddr() net.Addr

+ func (c *Connect) RemoteAddr() net.Addr

+ func (c *Connect) Send(msgID uint32, bytes []byte) (int, error)

+ func (c *Connect) SetDeadline(t time.Time) error

+ func (c *Connect) SetHandshakeCompleted()

+ func (c *Connect) SetReadDeadline(t time.Time) error

+ func (c *Connect) SetWriteDeadline(t time.Time) error

type Option

+ func WithTls(certFile, keyFile string) Option

type Options

+ TlsCertificate *tls.Certificate

+ TlsEnable bool

v0.0.9

Feb 25, 2022

Changes in this version

type Connect

+ func (c *Connect) GetPoller() iface.IPoller

v0.0.8

Feb 24, 2022

Changes in this version

type Connect

+ func (c *Connect) GetLastMessageTime() time.Time

+ func (c *Connect) SetLastMessageTime(duration time.Time)

type ConnectManager

+ func (c *ConnectManager) HeartbeatCheck()

type Option

+ func WithHeartbeatCheckInterval(interval time.Duration) Option

+ func WithHeartbeatIdleTime(idleTime time.Duration) Option

+ func WithMaxBodyLength(length uint32) Option

type Options

+ HeartbeatCheckInterval time.Duration

+ HeartbeatIdleTime time.Duration

+ MaxBodyLength uint32

v0.0.7

Feb 24, 2022

v0.0.6

Feb 21, 2022

Changes in this version

type Connect

+ func (c *Connect) SetState(state common.ConnectState)

v0.0.5

Feb 16, 2022

v0.0.4

Feb 16, 2022

v0.0.3

Jan 26, 2022

Changes in this version

type Connect

+ func (c *Connect) GetWriteBuff() []byte

+ func (c *Connect) SetPoller(poller iface.IPoller)

+ func (c *Connect) SetWriteBuff(bytes []byte)

v0.0.2

Jan 25, 2022

Changes in this version

type Option

+ func WithHooks(hooks iface.IHooks) Option

type Options

+ Hooks iface.IHooks

v0.0.1

Jan 25, 2022

Changes in this version

+ type BaseRouter struct

+ func (b *BaseRouter) Do(request iface.IRequest)

+ type Connect struct

+ Address net.Addr

+ func (c *Connect) Close() error

+ func (c *Connect) GetAddress() net.Addr

+ func (c *Connect) GetEpFd() int

+ func (c *Connect) GetFd() int

+ func (c *Connect) GetID() int

+ func (c *Connect) GetPacker() iface.IPacker

+ func (c *Connect) Read(bs []byte) (int, error)

+ func (c *Connect) SetEpFd(epfd int)

+ func (c *Connect) Write(msgID uint32, bytes []byte) (int, error)

+ type ConnectManager struct

+ func NewConnectManager() *ConnectManager

+ func (c *ConnectManager) Add(conn iface.IConnect) int

+ func (c *ConnectManager) ClearAll()

+ func (c *ConnectManager) ClearByEpFd(epfd int)

+ func (c *ConnectManager) Get(connID int) iface.IConnect

+ func (c *ConnectManager) Len() int

+ func (c *ConnectManager) Remove(conn iface.IConnect)

+ type Option = func(opts *Options)

+ func WithLogOutput(output io.Writer) Option

+ func WithNumEventLoop(numEventLoop int) Option

+ func WithPacker(packer iface.IPacker) Option

+ func WithTCPKeepAlive(duration time.Duration) Option

+ type Options struct

+ LogOutput io.Writer

+ NumEventLoop int

+ NumWorker int

+ Packer iface.IPacker

+ TCPKeepAlive time.Duration

+ type RouterMgr struct

+ func NewRouterMgr() *RouterMgr

+ func (r *RouterMgr) Add(msgID uint32, router iface.IRouter)

+ func (r *RouterMgr) Do(request iface.IRequest) error

+ func (r *RouterMgr) Get(msgID uint32) (iface.IRouter, error)

+ type Server struct

+ func New(ip string, port int, opts ...Option) *Server

+ func (s *Server) AddRouter(msgID uint32, router iface.IRouter)

+ func (s *Server) Start()

+ func (s *Server) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL