link

Documentation

Index

• Variables
• func Accept(listener net.Listener) (net.Conn, error)
• type Channel
  • func NewChannel() *Channel
  • func (channel *Channel) Close()
  • func (channel *Channel) Fetch(callback func(*Session))
  • func (channel *Channel) FetchAndRemove(callback func(*Session))
  • func (channel *Channel) Get(key KEY) *Session
  • func (channel *Channel) Len() int
  • func (channel *Channel) Put(key KEY, session *Session)
  • func (channel *Channel) Remove(key KEY) bool
• type ClearSendChan
• type Codec
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleSession(session *Session)
• type KEY
• type Manager
  • func NewManager() *Manager
  • func (manager *Manager) Dispose()
  • func (manager *Manager) GetSession(sessionID uint64) *Session
  • func (manager *Manager) NewSession(codec Codec, sendChanSize int) *Session
• type Protocol
• type ProtocolFunc
  • func (pf ProtocolFunc) NewCodec(rw io.ReadWriter) (Codec, error)
• type Server
  • func Listen(network, address string, protocol Protocol, sendChanSize int, handler Handler) (*Server, error)
  • func NewServer(listener net.Listener, protocol Protocol, sendChanSize int, handler Handler) *Server
  • func (server *Server) GetSession(sessionID uint64) *Session
  • func (server *Server) Listener() net.Listener
  • func (server *Server) Serve() error
  • func (server *Server) Stop()
• type Session
  • func Dial(network, address string, protocol Protocol, sendChanSize int) (*Session, error)
  • func DialTimeout(network, address string, timeout time.Duration, protocol Protocol, ...) (*Session, error)
  • func NewSession(codec Codec, sendChanSize int) *Session
  • func (session *Session) AddCloseCallback(handler, key interface{}, callback func())
  • func (session *Session) Close() error
  • func (session *Session) Codec() Codec
  • func (session *Session) ID() uint64
  • func (session *Session) IsClosed() bool
  • func (session *Session) Receive() (interface{}, error)
  • func (session *Session) RemoveCloseCallback(handler, key interface{})
  • func (session *Session) Send(msg interface{}) error

Variables

var (
	SessionClosedError  = errors.New("Session Closed")
	SessionBlockedError = errors.New("Session Blocked")
)

Functions

func Accept

func Accept(listener net.Listener) (net.Conn, error)

Types

type Channel

type Channel struct {

	// channel state
	State interface{}
	// contains filtered or unexported fields
}

func NewChannel

func NewChannel() *Channel

func (*Channel) Close

func (channel *Channel) Close()

func (*Channel) Fetch

func (channel *Channel) Fetch(callback func(*Session))

func (*Channel) FetchAndRemove

func (channel *Channel) FetchAndRemove(callback func(*Session))

func (*Channel) Get

func (channel *Channel) Get(key KEY) *Session

func (*Channel) Len

func (channel *Channel) Len() int

func (*Channel) Put

func (channel *Channel) Put(key KEY, session *Session)

func (*Channel) Remove

func (channel *Channel) Remove(key KEY) bool

type ClearSendChan

type ClearSendChan interface {
	ClearSendChan(<-chan interface{})
}

type Codec

type Codec interface {
	Receive() (interface{}, error)
	Send(interface{}) error
	Close() error
}

type Handler

type Handler interface {
	HandleSession(*Session)
}

type HandlerFunc

type HandlerFunc func(*Session)

func (HandlerFunc) HandleSession

func (f HandlerFunc) HandleSession(session *Session)

type KEY

type KEY interface{}

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

NewManager 创建管理器

func (*Manager) Dispose

func (manager *Manager) Dispose()

Dispose 关闭所有Session

func (*Manager) GetSession

func (manager *Manager) GetSession(sessionID uint64) *Session

GetSession 获取session

func (*Manager) NewSession

func (manager *Manager) NewSession(codec Codec, sendChanSize int) *Session

NewSession 新session

type Protocol

type Protocol interface {
	NewCodec(rw io.ReadWriter) (Codec, error)
}

type ProtocolFunc

type ProtocolFunc func(rw io.ReadWriter) (Codec, error)

func (ProtocolFunc) NewCodec

func (pf ProtocolFunc) NewCodec(rw io.ReadWriter) (Codec, error)

type Server

type Server struct {
	// contains filtered or unexported fields
}

func Listen

func Listen(network, address string, protocol Protocol, sendChanSize int, handler Handler) (*Server, error)

func NewServer

func NewServer(listener net.Listener, protocol Protocol, sendChanSize int, handler Handler) *Server

func (*Server) GetSession

func (server *Server) GetSession(sessionID uint64) *Session

func (*Server) Listener

func (server *Server) Listener() net.Listener

func (*Server) Serve

func (server *Server) Serve() error

func (*Server) Stop

func (server *Server) Stop()

type Session

type Session struct {
	// contains filtered or unexported fields
}

func Dial

func Dial(network, address string, protocol Protocol, sendChanSize int) (*Session, error)

func DialTimeout

func DialTimeout(network, address string, timeout time.Duration, protocol Protocol, sendChanSize int) (*Session, error)

func NewSession

func NewSession(codec Codec, sendChanSize int) *Session

NewSession 新session

func (*Session) AddCloseCallback

func (session *Session) AddCloseCallback(handler, key interface{}, callback func())

AddCloseCallback 添加关闭回调函数

func (*Session) Close

func (session *Session) Close() error

Close 关闭session

func (*Session) Codec

func (session *Session) Codec() Codec

Codec 当前编解码器

func (*Session) ID

func (session *Session) ID() uint64

ID 获取当前sessionID

func (*Session) IsClosed

func (session *Session) IsClosed() bool

IsClosed 是否关闭

func (*Session) Receive

func (session *Session) Receive() (interface{}, error)

Receive 接收消息

func (*Session) RemoveCloseCallback

func (session *Session) RemoveCloseCallback(handler, key interface{})

RemoveCloseCallback 删除关闭回调函数

func (*Session) Send

func (session *Session) Send(msg interface{}) error

Send 消息发送