gnet

Jul 2, 2021

Changes in this version

type EventServer

+ func (es *EventServer) PollerPreInit()

+ func (es *EventServer) PollerProc() error

+ func (es *EventServer) PollerWaitTimeOut() int

Jul 2, 2021

Changes in this version

type EventHandler

+ PollerPreInit func()

+ PollerProc func() error

+ PollerWaitTimeOut func() int

Jun 30, 2021

Changes in this version

+ type ConnFd struct

+ Fd interface{}

+ NetAddr net.Addr

+ Sa interface{}

+ func NewTCPConnFd(network, addr string, opts ...Option) (connFd *ConnFd, err error)

Jun 30, 2021

Changes in this version

+ var CRLFByte = byte('\n')

+ func AddTCPConnector(svr *Server, connFd *ConnFd, connIdx interface{}) (c *conn, err error) — darwin/amd64, linux/amd64

+ func AddTCPConnector(svr *Server, connFd *ConnFd, connIdx interface{}) (c *stdConn, err error) — windows/amd64

+ func Serve(eventHandler EventHandler, protoAddr string, opts ...Option) (err error)

+ func Stop(ctx context.Context, protoAddr string) error

+ type Action int

+ const Close

+ const None

+ const Shutdown

+ type BuiltInFrameCodec struct

+ func (cc *BuiltInFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *BuiltInFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type Conn interface

+ AsyncWrite func(buf []byte) error

+ BufferLength func() (size int)

+ Close func() error

+ Context func() (ctx interface{})

+ LocalAddr func() (addr net.Addr)

+ Read func() (buf []byte)

+ ReadN func(n int) (size int, buf []byte)

+ RemoteAddr func() (addr net.Addr)

+ ResetBuffer func()

+ SendTo func(buf []byte) error

+ SetContext func(ctx interface{})

+ ShiftN func(n int) (size int)

+ Wake func() error

+ type DecoderConfig struct

+ ByteOrder binary.ByteOrder

+ InitialBytesToStrip int

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthFieldOffset int

+ type DelimiterBasedFrameCodec struct

+ func NewDelimiterBasedFrameCodec(delimiter byte) *DelimiterBasedFrameCodec

+ func (cc *DelimiterBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *DelimiterBasedFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type EncoderConfig struct

+ ByteOrder binary.ByteOrder

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthIncludesLengthFieldLength bool

+ type EventHandler interface

+ OnClosed func(c Conn, err error) (action Action)

+ OnInitComplete func(server Server) (action Action)

+ OnOpened func(c Conn) (out []byte, action Action)

+ OnShutdown func(server Server)

+ PreWrite func()

+ React func(frame []byte, c Conn) (out []byte, action Action)

+ Tick func() (delay time.Duration, action Action)

+ type EventServer struct

+ func (es *EventServer) OnClosed(c Conn, err error) (action Action)

+ func (es *EventServer) OnInitComplete(svr Server) (action Action)

+ func (es *EventServer) OnOpened(c Conn) (out []byte, action Action)

+ func (es *EventServer) OnShutdown(svr Server)

+ func (es *EventServer) PreWrite()

+ func (es *EventServer) React(frame []byte, c Conn) (out []byte, action Action)

+ func (es *EventServer) Tick() (delay time.Duration, action Action)

+ type FixedLengthFrameCodec struct

+ func NewFixedLengthFrameCodec(frameLength int) *FixedLengthFrameCodec

+ func (cc *FixedLengthFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *FixedLengthFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type ICodec interface

+ Decode func(c Conn) ([]byte, error)

+ Encode func(c Conn, buf []byte) ([]byte, error)

+ type LengthFieldBasedFrameCodec struct

+ func NewLengthFieldBasedFrameCodec(ec EncoderConfig, dc DecoderConfig) *LengthFieldBasedFrameCodec

+ func (cc *LengthFieldBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *LengthFieldBasedFrameCodec) Encode(c Conn, buf []byte) (out []byte, err error)

+ type LineBasedFrameCodec struct

+ func (cc *LineBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *LineBasedFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type LoadBalancing int

+ const LeastConnections

+ const RoundRobin

+ const SourceAddrHash

+ type Option func(opts *Options)

+ func WithCodec(codec ICodec) Option

+ func WithLoadBalancing(lb LoadBalancing) Option

+ func WithLockOSThread(lockOSThread bool) Option

+ func WithLogLevel(lvl zapcore.Level) Option

+ func WithLogPath(fileName string) Option

+ func WithLogger(logger logging.Logger) Option

+ func WithMulticore(multicore bool) Option

+ func WithNumEventLoop(numEventLoop int) Option

+ func WithOptions(options Options) Option

+ func WithReadBufferCap(readBufferCap int) Option

+ func WithReusePort(reusePort bool) Option

+ func WithSocketRecvBuffer(recvBuf int) Option

+ func WithSocketSendBuffer(sendBuf int) Option

+ func WithTCPKeepAlive(tcpKeepAlive time.Duration) Option

+ func WithTCPNoDelay(tcpNoDelay TCPSocketOpt) Option

+ func WithTicker(ticker bool) Option

+ type Options struct

+ Codec ICodec

+ LB LoadBalancing

+ LockOSThread bool

+ LogLevel zapcore.Level

+ LogPath string

+ Logger logging.Logger

+ Multicore bool

+ NumEventLoop int

+ ReadBufferCap int

+ ReusePort bool

+ SocketRecvBuffer int

+ SocketSendBuffer int

+ TCPKeepAlive time.Duration

+ TCPNoDelay TCPSocketOpt

+ Ticker bool

+ type Server struct

+ Addr net.Addr

+ Multicore bool

+ NumEventLoop int

+ ReusePort bool

+ TCPKeepAlive time.Duration

+ func (s Server) CountConnections() (count int)

+ func (s Server) DupFd() (dupFD int, err error)

+ type TCPSocketOpt int

+ const TCPDelay

+ const TCPNoDelay