gn

May 11, 2022

Changes in this version

type Buffer

+ func (b *Buffer) ReadAll() []byte

type Conn

+ func (c *Conn) WriteWithEncoder(bytes []byte) error

type Encoder

+ EncodeToWriter func(w io.Writer, bytes []byte) error

type Option

+ func WithDecoder(decoder Decoder) Option

+ func WithEncoder(encoder Encoder) Option

May 7, 2022

Changes in this version

type Conn

+ func (c *Conn) OnMessage(bytes []byte)

Sep 18, 2021

Changes in this version

type Buffer

+ func (b *Buffer) Cap() int

+ func (b *Buffer) GetBuf() []byte

type Conn

+ func (c *Conn) GetBuffer() *Buffer

Aug 4, 2021

Changes in this version

+ var ErrNotEnough = errors.New("not enough")

+ type Buffer struct

+ Buf []byte

+ func NewBuffer(bytes []byte) *Buffer

+ func (b *Buffer) Len() int

+ func (b *Buffer) Read(offset, limit int) ([]byte, error)

+ func (b *Buffer) ReadFromFD(fd int) error

+ func (b *Buffer) ReadFromReader(reader io.Reader) (int, error)

+ func (b *Buffer) Seek(len int) ([]byte, error)

type Conn

+ func (c *Conn) CloseRead() error

Nov 29, 2020

Changes in this version

+ const EpollClose — linux/amd64

+ const EventTimeout

+ func GetLogger() logger

type Option

+ func WithReadBufferLen(len int) Option

Oct 9, 2020

Changes in this version

type Option

+ func WithConnectEventQueueLen(num int) Option

+ func WithIOEventQueueLen(num int) Option

Sep 30, 2020

Changes in this version

+ func NewHeaderLenEncoder(headerLen, writeBufferLen int) *headerLenEncoder

+ type Decoder interface

+ Decode func(c *Conn) error

+ func NewHeaderLenDecoder(headerLen, readMaxLen int) Decoder

+ type Encoder interface

+ EncodeToFD func(fd int32, bytes []byte) error

Sep 29, 2020

Changes in this version

+ const EventClose

+ const EventConn

+ const EventIn

+ func SetLogger(l logger)

+ type Event struct

+ Fd int32

+ Type int32

+ type Option interface

+ func WithAcceptGNum(num int) Option

+ func WithHeaderLen(len int) Option

+ func WithIOGNum(num int) Option

+ func WithReadMaxLen(len int) Option

+ func WithTimeout(timeoutTicker, timeout time.Duration) Option

+ func WithWriteLen(len int) Option

type Server

+ func (s *Server) GetConnsNum() int64

+ func (s *Server) HandleEvent(event Event)

Apr 22, 2020

Changes in this version

+ const EpollListener — linux/amd64

+ const EpollRead — linux/amd64

+ var ErrReadTimeout = errors.New("tcp read timeout")

+ var Log logger = newDefaultLog()

+ func Decode(c *Conn) error

+ func Encode(bytes []byte) []byte

+ func EncodeToFD(fd int, bytes []byte) error

+ func EpollCreate() (*epoll, error) — linux/amd64

+ func InitCodec(headerLen, readMaxLen, writeLen int)

+ func TimeEncoder(t time.Time, enc zapcore.PrimitiveArrayEncoder)

+ type Conn struct

+ func (c *Conn) Close() error

+ func (c *Conn) GetAddr() string

+ func (c *Conn) GetData() interface{}

+ func (c *Conn) GetFd() int

+ func (c *Conn) Read() error

+ func (c *Conn) SetData(data interface{})

+ func (c *Conn) Write(bytes []byte) (int, error)

+ type Handler interface

+ OnClose func(c *Conn, err error)

+ OnConnect func(c *Conn)

+ OnMessage func(c *Conn, bytes []byte)

+ type Server struct

+ func NewServer(port int, handler Handler, headerLen, readMaxLen, writeLen, gNum int) (*Server, error)

+ func (s *Server) GetConn(fd int) (*Conn, bool)

+ func (s *Server) Run()

+ func (s *Server) SetTimeout(ticker, timeout time.Duration)

+ func (s *Server) Stop()