easytcp

Oct 31, 2022

Changes in this version

type Server

+ func (s *Server) Run(addr string) error

+ func (s *Server) RunTLS(addr string, config *tls.Config) error

type Session

+ AfterCloseHook func() <-chan struct{}

+ AfterCreateHook func() <-chan struct{}

Jun 16, 2022

Changes in this version

type Message

+ func (m *Message) Reset(id interface{}, data []byte)

Jun 1, 2022

Changes in this version

+ type Message struct

+ func NewMessage(id interface{}, data []byte) *Message

+ func (m *Message) Data() []byte

+ func (m *Message) Get(key string) (value interface{}, exists bool)

+ func (m *Message) ID() interface{}

+ func (m *Message) MustGet(key string) interface{}

+ func (m *Message) Remove(key string)

+ func (m *Message) Set(key string, value interface{})

+ type MockPacker struct

+ func NewMockPacker(ctrl *gomock.Controller) *MockPacker

+ func (m *MockPacker) EXPECT() *MockPackerMockRecorder

+ func (m *MockPacker) Pack(arg0 *Message) ([]byte, error)

+ func (m *MockPacker) Unpack(arg0 io.Reader) (*Message, error)

+ type MockPackerMockRecorder struct

+ func (mr *MockPackerMockRecorder) Pack(arg0 interface{}) *gomock.Call

+ func (mr *MockPackerMockRecorder) Unpack(arg0 interface{}) *gomock.Call

type Session

+ Conn func() net.Conn

Mar 28, 2022

Changes in this version

type Server

+ func (s *Server) ServeTLS(addr string, config *tls.Config) error

Jan 10, 2022

Changes in this version

type Context

+ WithContext func(ctx context.Context) Context

type ServerOption

+ AsyncRouter bool

type Session

+ AllocateContext func() Context

+ SetID func(id interface{})

Dec 30, 2021

Changes in this version

+ func NewContext() *routeContext

type Context

+ MustSetRequest func(id, data interface{}) Context

+ MustSetResponse func(id, data interface{}) Context

+ Request func() *message.Entry

+ SetRequest func(id, data interface{}) error

+ SetRequestMessage func(entry *message.Entry) Context

+ SetResponseMessage func(entry *message.Entry) Context

+ SetSession func(sess Session) Context

type Session

+ Codec func() Codec

+ NewContext func() Context

+ Send func(ctx Context) bool

Oct 26, 2021

Changes in this version

type Context

+ func (c *Context) Encode(v interface{}) ([]byte, error)

+ func (c *Context) MustEncode(v interface{}) []byte

Oct 2, 2021

Changes in this version

+ const DefaultWriteAttemptTimes

type Context

+ func (c *Context) Copy() *Context

type ServerOption

+ WriteAttemptTimes int

Sep 15, 2021

Changes in this version

type ServerOption

+ WriteRetryTimes int

Sep 13, 2021

Changes in this version

+ const DefaultReqQueueSize

+ const DefaultRespQueueSize

type Context

+ func (c *Context) Remove(key string)

Sep 7, 2021

Changes in this version

type Context

+ func (c *Context) DecodeTo(data []byte, v interface{}) error

+ func (c *Context) GetResponse() *message.Entry

+ func (c *Context) MustBind(v interface{})

+ func (c *Context) MustDecodeTo(data []byte, v interface{})

+ func (c *Context) MustGet(key string) interface{}

+ func (c *Context) Send(id, data interface{}) error

+ func (c *Context) SendTo(sess *Session, id, data interface{}) error

+ func (c *Context) SetResponse(id interface{}, data []byte)

type DefaultPacker

+ MaxDataSize int

type ServerOption

+ ReqQueueSize int

+ RespQueueSize int

Aug 6, 2021

Changes in this version

+ type MsgpackCodec struct

+ func (m *MsgpackCodec) Decode(data []byte, v interface{}) error

+ func (m *MsgpackCodec) Encode(v interface{}) ([]byte, error)

type ServerOption

+ DoNotPrintRoutes bool

Jul 30, 2021

Changes in this version

+ const RespKey

+ var ErrServerStopped = fmt.Errorf("server stopped")

+ func SetLogger(lg Logger)

+ type Codec interface

+ Decode func(data []byte, v interface{}) error

+ Encode func(v interface{}) ([]byte, error)

+ type Context struct

+ func (c *Context) Bind(v interface{}) error

+ func (c *Context) Deadline() (deadline time.Time, ok bool)

+ func (c *Context) Done() <-chan struct{}

+ func (c *Context) Err() error

+ func (c *Context) Get(key string) (interface{}, bool)

+ func (c *Context) Message() *message.Entry

+ func (c *Context) Response(id interface{}, data interface{}) (*message.Entry, error)

+ func (c *Context) Session() *Session

+ func (c *Context) Set(key string, value interface{})

+ func (c *Context) Value(key interface{}) interface{}

+ type DefaultLogger struct

+ func (d *DefaultLogger) Errorf(format string, args ...interface{})

+ func (d *DefaultLogger) Tracef(format string, args ...interface{})

+ type DefaultPacker struct

+ MaxSize int

+ func NewDefaultPacker() *DefaultPacker

+ func (d *DefaultPacker) Pack(entry *message.Entry) ([]byte, error)

+ func (d *DefaultPacker) Unpack(reader io.Reader) (*message.Entry, error)

+ type Error interface

+ Fatal func() bool

+ type HandlerFunc func(ctx *Context) (*message.Entry, error)

+ type JsonCodec struct

+ func (c *JsonCodec) Decode(data []byte, v interface{}) error

+ func (c *JsonCodec) Encode(v interface{}) ([]byte, error)

+ type Logger interface

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

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

+ var Log Logger = newLogger()

+ type MiddlewareFunc func(next HandlerFunc) HandlerFunc

+ type Packer interface

+ Pack func(entry *message.Entry) ([]byte, error)

+ Unpack func(reader io.Reader) (*message.Entry, error)

+ type ProtobufCodec struct

+ func (p *ProtobufCodec) Decode(data []byte, v interface{}) error

+ func (p *ProtobufCodec) Encode(v interface{}) ([]byte, error)

+ type Router struct

+ type Server struct

+ Codec Codec

+ Listener net.Listener

+ OnSessionClose func(sess *Session)

+ OnSessionCreate func(sess *Session)

+ Packer Packer

+ func NewServer(opt *ServerOption) *Server

+ func (s *Server) AddRoute(msgID interface{}, handler HandlerFunc, middlewares ...MiddlewareFunc)

+ func (s *Server) NotFoundHandler(handler HandlerFunc)

+ func (s *Server) Serve(addr string) error

+ func (s *Server) Stop() error

+ func (s *Server) Use(middlewares ...MiddlewareFunc)

+ type ServerOption struct

+ Codec Codec

+ DontPrintRoutes bool

+ Packer Packer

+ ReadBufferSize int

+ ReadTimeout time.Duration

+ SocketReadBufferSize int

+ SocketSendDelay bool

+ SocketWriteBufferSize int

+ WriteBufferSize int

+ WriteTimeout time.Duration

+ type Session struct

+ func (s *Session) Close()

+ func (s *Session) ID() string

+ func (s *Session) SendResp(respMsg *message.Entry) error

+ type SessionManager struct

+ Sessions sync.Map

+ func Sessions() *SessionManager

+ func (m *SessionManager) Add(s *Session)

+ func (m *SessionManager) Get(id string) *Session

+ func (m *SessionManager) Range(fn func(id string, sess *Session) (next bool))

+ func (m *SessionManager) Remove(id string)

+ type SessionOption struct

+ Codec Codec

+ Packer Packer

+ ReadBufferSize int

+ WriteBufferSize int

+ type UnpackError struct

+ Err error

+ func (pe *UnpackError) Error() string

+ func (pe *UnpackError) Fatal() bool