gnet

Dec 28, 2021

Changes in this version

+ const MaxBytesToWritePerLoop — darwin/amd64, linux/amd64

+ const MaxIovSize — darwin/amd64, linux/amd64

Dec 5, 2021

Changes in this version

+ type Client struct — darwin/amd64, linux/amd64

+ func NewClient(eventHandler EventHandler, opts ...Option) (cli *Client, err error)

+ func (cli *Client) Dial(network, address string) (Conn, error)

+ func (cli *Client) Start() error

+ func (cli *Client) Stop() (err error)

type Conn

+ AsyncWritev func(bs [][]byte) error

type EventHandler

+ AfterWrite func(c Conn, b []byte)

type EventServer

+ func (es *EventServer) AfterWrite(c Conn, b []byte)

type Option

+ func WithReuseAddr(reuseAddr bool) Option

type Options

+ ReuseAddr bool

Jul 11, 2021

Changes in this version

+ const TaskBufferCap — windows/amd64

Jun 28, 2021

Changes in this version

type Option

+ func WithLogLevel(lvl zapcore.Level) Option

+ func WithLogPath(fileName string) Option

type Options

+ LogLevel zapcore.Level

+ LogPath string

Apr 7, 2021

Changes in this version

type Option

+ func WithSocketRecvBuffer(recvBuf int) Option

+ func WithSocketSendBuffer(sendBuf int) Option

type Options

+ SocketRecvBuffer int

+ SocketSendBuffer int

Feb 27, 2021

Changes in this version

type Option

+ func WithReadBufferCap(readBufferCap int) Option

type Options

+ ReadBufferCap int

Feb 9, 2021

Changes in this version

type Option

+ func WithTCPNoDelay(tcpNoDelay TCPSocketOpt) Option

type Options

+ TCPNoDelay TCPSocketOpt

+ type TCPSocketOpt int

+ const TCPDelay

+ const TCPNoDelay

Nov 20, 2020

Changes in this version

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

type Server

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

Sep 13, 2020

Changes in this version

type Option

+ func WithLockOSThread(lockOSThread bool) Option

type Options

+ LockOSThread bool

Jun 7, 2020

Changes in this version

+ var ErrUnsupportedPlatform = errors.New("unsupported platform in gnet")

+ var ErrUnsupportedProtocol = errors.New("unsupported protocol on this platform")

May 11, 2020

Changes in this version

type EventHandler

+ OnShutdown func(server Server)

type EventServer

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

Apr 2, 2020

Changes in this version

+ type LoadBalancing int

+ const LeastConnections

+ const RoundRobin

+ const SourceAddrHash

type Option

+ func WithLoadBalancing(lb LoadBalancing) Option

type Options

+ LB LoadBalancing

type Server

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

Mar 13, 2020

Changes in this version

+ var CRLFByte = byte('\n')

+ var ErrCRLFNotFound = errors.New("there is no CRLF")

+ var ErrDelimiterNotFound = errors.New("there is no such a delimiter")

+ var ErrInvalidFixedLength = errors.New("invalid fixed length of bytes")

+ var ErrProtocolNotSupported = errors.New("not supported protocol on this platform")

+ var ErrServerShutdown = errors.New("server is going to be shutdown")

+ var ErrTooLessLength = errors.New("adjusted frame length is less than zero")

+ var ErrUnexpectedEOF = errors.New("there is no enough data")

+ var ErrUnsupportedLength = errors.New("unsupported lengthFieldLength. (expected: 1, 2, 3, 4, or 8)")

+ type BuiltInFrameCodec struct

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

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

type Conn

+ AsyncWrite func(buf []byte) error

+ BufferLength func() (size int)

+ Close func() error

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

+ SendTo func(buf []byte) error

+ ShiftN func(n int) (size int)

+ 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)

+ 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) 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 IEventLoopGroup interface

+ type LengthFieldBasedFrameCodec struct

+ func NewLengthFieldBasedFrameCodec(encoderConfig EncoderConfig, decoderConfig 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 Logger interface

+ Printf func(format string, args ...interface{})

+ type Option func(opts *Options)

+ func WithCodec(codec ICodec) Option

+ func WithLogger(logger Logger) Option

+ func WithMulticore(multicore bool) Option

+ func WithNumEventLoop(numEventLoop int) Option

+ func WithOptions(options Options) Option

+ func WithReusePort(reusePort bool) Option

+ func WithTCPKeepAlive(tcpKeepAlive time.Duration) Option

+ func WithTicker(ticker bool) Option

type Options

+ Codec ICodec

+ Logger Logger

+ Multicore bool

+ NumEventLoop int

+ ReusePort bool

+ Ticker bool

type Server

+ Addr net.Addr

+ Multicore bool

+ NumEventLoop int

+ ReusePort bool

+ TCPKeepAlive time.Duration

Sep 21, 2019

Changes in this version

type Conn

+ Advance func(int)

+ Read func() ([]byte, []byte)

+ ResetBuffer func()

+ Write func([]byte)

Sep 17, 2019

Changes in this version

+ func Serve(events Events, addr ...string) error

+ type Action int

+ const Close

+ const Detach

+ const None

+ const Shutdown

+ type Conn interface

+ AddrIndex func() int

+ Context func() interface{}

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ SetContext func(interface{})

+ Wake func()

+ type Events struct

+ Multicore bool

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

+ OnDetached func(c Conn, rwc io.ReadWriteCloser) (action Action)

+ OnInitComplete func(server Server) (action Action)

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

+ PreWrite func()

+ React func(c Conn, inBuf *ringbuffer.RingBuffer) (out []byte, action Action)

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

+ type Options struct

+ TCPKeepAlive time.Duration

+ type Server struct

+ Addrs []net.Addr

+ NumLoops int