Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

meim

package module

Go to main page

Versions in this module

v1

v1.1.0-a

Jul 10, 2020

v1.0.3-a

Jun 10, 2020

v1.0.2

Jun 9, 2020

v1.0.2-dev

Jun 5, 2020

v1.0.1

Jun 5, 2020

Changes in this version

+ const DefaultMaxConn

+ const DefaultReadTimeout

+ const DefaultWriteTimeout

+ const MessageQueueLimit

+ var ErrorInvalidHeader = errors.New("invalid header")

+ var ErrorInvalidMessage = errors.New("invalid message")

+ var ErrorReadOutofRange = errors.New("read body length out of range")

+ var ErrorWriteOutofRange = errors.New("write body length out of range")

+ func EncodeInternalMessage(message *InternalMessage) ([]byte, error)

+ func EncodeLimitMessage(message *Message, limitSize int) ([]byte, error)

+ func EncodeMessage(message *Message) ([]byte, error)

+ func IsTimeout(err error) bool

+ func RegisterMakeListener(network string, ml MakeListener)

+ func WriteInternalMessage(conn io.Writer, msg *InternalMessage) error

+ func WriteLimitMessage(conn io.Writer, message *Message, limitSize int) error

+ func WriteMessage(conn io.Writer, message *Message) error

+ type Client struct

+ DC DataCreator

+ UID int64

+ UserData interface{}

+ Version int32

+ func NewClient(conn Conn) *Client

+ func (client *Client) Close()

+ func (client *Client) EnqueueEvent(fn func(*Client)) bool

+ func (client *Client) EnqueueMessage(msg *Message) bool

+ func (client *Client) EnqueueNonBlockMessage(msg *Message) bool

+ func (client *Client) EnsureEvent(fn func(*Client))

+ func (client *Client) FlushMessage()

+ func (client *Client) LocalAddr() net.Addr

+ func (client *Client) Log() string

+ func (client *Client) Run()

+ func (client *Client) SendLMessages()

+ func (client *Client) String() string

+ type ClientSet map[*Client]struct

+ func NewClientSet() ClientSet

+ func (set ClientSet) Add(c *Client)

+ func (set ClientSet) Clone() ClientSet

+ func (set ClientSet) Count() int

+ func (set ClientSet) IsMember(c *Client) bool

+ func (set ClientSet) Remove(c *Client)

+ type Conn interface

+ Close func() error

+ LocalAddr func() net.Addr

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

+ RemoteAddr func() net.Addr

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

+ type DataCreator interface

+ CreateBody func(cmd int) ProtocolBody

+ CreateHeader func() ProtocolHeader

+ GetCmd func(body interface{}) (int, bool)

+ GetCmd2 func(t reflect.Type) (int, bool)

+ GetDescription func(cmd int) string

+ type Dispatcher interface

+ DispatchMessage func(*InternalMessage) bool

+ type Exchanger struct

+ func NewMessageExchanger(broker MessageBroker, pusher Pusher, handler InternalMessageHandler, ...) *Exchanger

+ func (exc *Exchanger) DispatchMessage(msg *InternalMessage) bool

+ func (exc *Exchanger) PublishMessage(msg *InternalMessage) bool

+ func (exc *Exchanger) Run()

+ type ExternalImp struct

+ func NewExternalImp() *ExternalImp

+ func (e *ExternalImp) Clone() *ExternalImp

+ func (e *ExternalImp) HandleAuthClient(client *Client) bool

+ func (e *ExternalImp) HandleBeforeWriteMessage(client *Client, message *Message)

+ func (e *ExternalImp) HandleClientClosed(client *Client)

+ func (e *ExternalImp) HandleMessage(client *Client, msg *Message)

+ func (e *ExternalImp) SetBeforeWrite(h MessageHandler)

+ func (e *ExternalImp) SetDefaultHandler(h MessageHandler, filters ...Filter)

+ func (e *ExternalImp) SetMsgHandler(cmd int, h MessageHandler, filters ...Filter)

+ func (e *ExternalImp) SetOnAuthClient(h func(*Client) bool)

+ func (e *ExternalImp) SetOnClientClosed(h func(*Client))

+ type ExternalPlugin interface

+ HandleAuthClient func(*Client) bool

+ HandleBeforeWriteMessage func(*Client, *Message)

+ HandleClientClosed func(*Client)

+ HandleMessage func(*Client, *Message)

+ type Filter func(MessageHandler) MessageHandler

+ type InternalMessage struct

+ Receiver int64

+ Sender int64

+ Timestamp int64

+ func DecodeInternalMessgae(b []byte, dc DataCreator) (*InternalMessage, error)

+ func ReadInternalMessage(reader io.Reader, dc DataCreator) (*InternalMessage, error)

+ type InternalMessageHandler interface

+ HandleInternalMessage func(msg *InternalMessage)

+ type ListenerConfig struct

+ Address string

+ Network string

+ Options map[string]interface{}

+ TLSConfig *tls.Config

+ type MakeListener func(cfg *ListenerConfig) (ln net.Listener, err error)

+ type Message struct

+ Body ProtocolBody

+ Header ProtocolHeader

+ func DecodeMessage(b []byte, dc DataCreator) (*Message, error)

+ func ReadLimitMessage(reader io.Reader, dc DataCreator, limitSize int) (*Message, error)

+ func ReadMessage(reader io.Reader, dc DataCreator) (*Message, error)

+ func (m *Message) String() string

+ type MessageBroker interface

+ Close func()

+ Connect func()

+ ReceiveMessage func() (*InternalMessage, error)

+ SendMessage func(msg *InternalMessage) error

+ Subscribe func(uid int64)

+ SyncMessage func(msg *InternalMessage) (*InternalMessage, error)

+ UnSubscribe func(uid int64)

+ type MessageExchanger interface

+ type MessageHandler func(client *Client, msg *Message)

+ func FilterRecover(fn MessageHandler) MessageHandler

+ type NetConn struct

+ func NewNetConn(conn net.Conn, rto, wto time.Duration) *NetConn

+ func (conn *NetConn) Read(buff []byte) (int, error)

+ func (conn *NetConn) Write(b []byte) (int, error)

+ type NopPusher struct

+ func (p *NopPusher) PushMessage(msg *InternalMessage) bool

+ type OptionFn func(*Server)

+ func WithExternalPlugin(plugin ExternalPlugin) OptionFn

+ func WithListenAddr(addr string) OptionFn

+ func WithMaxConn(n int) OptionFn

+ func WithNetwork(network string) OptionFn

+ func WithOptions(ops map[string]interface{}) OptionFn

+ func WithReadTimeout(readTimeout time.Duration) OptionFn

+ func WithTLSConfig(cfg *tls.Config) OptionFn

+ func WithWriteTimeout(writeTimeout time.Duration) OptionFn

+ type ProtocolBody = ProtocolData

+ type ProtocolData interface

+ Decode func(b []byte) error

+ Encode func() ([]byte, error)

+ type ProtocolHeader interface

+ BodyLength func() int

+ Clone func() ProtocolHeader

+ Cmd func() int

+ Length func() int

+ Seq func() int

+ SetBodyLength func(n int)

+ SetCmd func(int)

+ SetSeq func(int)

+ SetVer func(v int)

+ Ver func() int

+ type Publisher interface

+ PublishMessage func(*InternalMessage) bool

+ type Pusher interface

+ PushMessage func(msg *InternalMessage) bool

+ type Router struct

+ func NewRouter() *Router

+ func (route *Router) AddClient(client *Client)

+ func (route *Router) FindClient(uid int64) *Client

+ func (route *Router) FindClientSet(uid int64) ClientSet

+ func (route *Router) IsOnline(uid int64) bool

+ func (route *Router) RemoveClient(client *Client) bool

+ type Server struct

+ func NewServer(options ...OptionFn) *Server

+ func NewServerWithConfig(cfg *ListenerConfig, options ...OptionFn) *Server

+ func (s *Server) ClientSet() ClientSet

+ func (s *Server) Close()

+ func (s *Server) Run()