core

Apr 1, 2023

Changes in this version

+ const DefaultConnectMaxWait

+ const DefaultConnectWaitMut

+ const DefaultConnectWaitStart

+ const DefaultKeepAlive

+ const DefaultMaxConnNum

+ const HeartbeatTime

+ const TCPMaxPackageSize

+ const TimeoutTime

+ const UpdateInterval

+ var DefaultClientOptions = ClientOptions

+ var DefaultServerOptions = ServerOptions

+ var ErrInvalidAddress = errors.New("invalid address input")

+ var ErrInvalidAgent = errors.New("agent invalid")

+ var ErrInvalidCodec = errors.New("codec invalid")

+ var ErrInvalidGetAgentFunc = errors.New("invalid new agent function")

+ var ErrPacketSplit = errors.New("network packet split")

+ var ErrTooLessLength = errors.New("buffer too less length")

+ var ErrTooMoreLength = errors.New("buffer too more length")

+ func VerifyAddress(address string) bool

+ type Agent interface

+ OnClose func(conn Conn)

+ OnConnect func(conn Conn)

+ OnMessage func(b []byte, conn Conn)

+ type Client interface

+ IsConnected func() bool

+ Start func(address string, newAgent GetAgent, opts ...ClientOption) error

+ type ClientOption func(*ClientOptions)

+ func WithClientContext(context map[string]interface{}) ClientOption

+ func WithReconnect(reconnect bool) ClientOption

+ type ClientOptions struct

+ Context map[string]interface{}

+ Reconnect bool

+ type Codec interface

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

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

+ type CodecConn interface

+ BufferLength func() (size int)

+ Read func() (buf []byte)

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

+ ResetBuffer func()

+ ShiftN func(n int) (size int)

+ type Conn interface

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ Write func(b []byte) (n int, err error)

+ type GetAgent func() Agent

+ type ID uint64

+ func GenerateID() ID

+ type Object interface

+ Close func()

+ Run func()

+ type Server interface

+ GetConnNum func() (num int)

+ Start func(address string, newAgent GetAgent, opts ...ServerOption) error

+ type ServerOption func(*ServerOptions)

+ func WithMaxConnNum(maxConnNum int) ServerOption

+ func WithServerContext(context map[string]interface{}) ServerOption

+ type ServerOptions struct

+ Context map[string]interface{}

+ MaxConnNum int