server

Documentation

Index

• Variables
• func ExportClients(hub *Hub) map[uint64]*bash.Client
• type Header
  • func (h *Header) ID() uint64
  • func (h *Header) MsgType() MsgType
  • func (h *Header) String() string
  • func (h *Header) Version() uint8
• type Hub
  • func NewHub() *Hub
  • func (hub *Hub) Close() (err error)
  • func (hub *Hub) NewClientSession(conn net.Conn) (err error)
  • func (hub *Hub) Serve(l net.Listener) (err error)
  • func (hub *Hub) ServeConn(conn net.Conn) (err error)
• type MsgType

Variables

var (
	ErrClientNotExists = fmt.Errorf("client session is not exists")
	ErrClientIDReused  = fmt.Errorf("client id is reused. %w", ErrClientNotExists)
)

Functions

func ExportClients

func ExportClients(hub *Hub) map[uint64]*bash.Client

Types

type Header

type Header [12]byte

func (*Header) ID

func (h *Header) ID() uint64

func (*Header) MsgType

func (h *Header) MsgType() MsgType

func (*Header) String

func (h *Header) String() string

func (*Header) Version

func (h *Header) Version() uint8

type Hub

type Hub struct {
	OnSessionOpen func(bash.Session) func()
	Timeout       time.Duration
	// contains filtered or unexported fields
}

func NewHub

func NewHub() *Hub

func (*Hub) Close

func (hub *Hub) Close() (err error)

func (*Hub) NewClientSession

func (hub *Hub) NewClientSession(conn net.Conn) (err error)

func (*Hub) Serve

func (hub *Hub) Serve(l net.Listener) (err error)

func (*Hub) ServeConn

func (hub *Hub) ServeConn(conn net.Conn) (err error)

type MsgType

type MsgType uint8

const (
	MsgToSession MsgType = iota
	MsgInitSession
)