connections

Documentation

Index

• Variables
• type ConnectionGroup
  • func NewConnectionGroup(logger logrus.FieldLogger, connectionLimit int, width, height uint8) (*ConnectionGroup, error)
  • func (cg *ConnectionGroup) BroadcastMessageTimeout(message string, timeout time.Duration) bool
  • func (cg *ConnectionGroup) GetCount() int
  • func (cg *ConnectionGroup) GetLimit() int
  • func (cg *ConnectionGroup) GetObjects() []interface{}
  • func (cg *ConnectionGroup) GetRate() uint32
  • func (cg *ConnectionGroup) GetWorldHeight() uint8
  • func (cg *ConnectionGroup) GetWorldWidth() uint8
  • func (cg *ConnectionGroup) Handle(connectionWorker *ConnectionWorker) error
  • func (cg *ConnectionGroup) IsEmpty() bool
  • func (cg *ConnectionGroup) IsFull() bool
  • func (cg *ConnectionGroup) SetLimit(limit int)
  • func (cg *ConnectionGroup) Start()
  • func (cg *ConnectionGroup) Stop()
• type ConnectionGroupManager
  • func NewConnectionGroupManager(logger logrus.FieldLogger, groupLimit, connsLimit int) (*ConnectionGroupManager, error)
  • func (m *ConnectionGroupManager) Add(group *ConnectionGroup) (int, error)
  • func (m *ConnectionGroupManager) Capacity() float32
  • func (m *ConnectionGroupManager) Delete(group *ConnectionGroup) error
  • func (m *ConnectionGroupManager) Get(id int) (*ConnectionGroup, error)
  • func (m *ConnectionGroupManager) GroupCount() int
  • func (m *ConnectionGroupManager) GroupLimit() int
  • func (m *ConnectionGroupManager) Groups() map[int]*ConnectionGroup
  • func (m *ConnectionGroupManager) IsFull() bool
• type ConnectionWorker
  • func NewConnectionWorker(conn *websocket.Conn, logger logrus.FieldLogger) *ConnectionWorker
  • func (cw *ConnectionWorker) Start(stop <-chan struct{}, game *game.Game, broadcast *broadcast.GroupBroadcast, ...) error
• type ErrAddGroup
  • func (e ErrAddGroup) Error() string
• type ErrDeleteGroup
  • func (e ErrDeleteGroup) Error() string
• type ErrHandleConnection
  • func (e *ErrHandleConnection) Error() string
• type ErrStartConnectionWorker
  • func (e ErrStartConnectionWorker) Error() string
• type InputMessage
  • func (j *InputMessage) UnmarshalJSON(input []byte) error
  • func (j *InputMessage) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
• type InputMessageType
  • func (t InputMessageType) String() string
  • func (t *InputMessageType) UnmarshalJSON(data []byte) error
• type OutputMessage
  • func (j *OutputMessage) MarshalJSON() ([]byte, error)
  • func (j *OutputMessage) MarshalJSONBuf(buf fflib.EncodingBuffer) error
• type OutputMessageType
  • func (t OutputMessageType) MarshalJSON() ([]byte, error)
  • func (t OutputMessageType) String() string

Variables

var (
	ErrGroupLimitReached = ErrAddGroup("limit group count reached")
	ErrCannotGetID       = ErrAddGroup("cannot get id for group")
	ErrConnsLimitReached = ErrAddGroup("cannot reserve connections for group: connections count reached")
)

var (
	ErrDeleteNotEmptyGroup = ErrDeleteGroup("group is not empty")
	ErrDeleteNotFoundGroup = ErrDeleteGroup("group not found")
)

var ErrGroupIsFull = errors.New("group is full")

var ErrNotFoundGroup = errors.New("not found group")

var ErrUnknownInputMessageType = errors.New("unknown input message type")

Types

type ConnectionGroup

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

func NewConnectionGroup

func NewConnectionGroup(logger logrus.FieldLogger, connectionLimit int, width, height uint8) (*ConnectionGroup, error)

func (*ConnectionGroup) BroadcastMessageTimeout

func (cg *ConnectionGroup) BroadcastMessageTimeout(message string, timeout time.Duration) bool

func (*ConnectionGroup) GetCount

func (cg *ConnectionGroup) GetCount() int

func (*ConnectionGroup) GetLimit

func (cg *ConnectionGroup) GetLimit() int

func (*ConnectionGroup) GetObjects

func (cg *ConnectionGroup) GetObjects() []interface{}

func (*ConnectionGroup) GetRate

func (cg *ConnectionGroup) GetRate() uint32

func (*ConnectionGroup) GetWorldHeight

func (cg *ConnectionGroup) GetWorldHeight() uint8

func (*ConnectionGroup) GetWorldWidth

func (cg *ConnectionGroup) GetWorldWidth() uint8

func (*ConnectionGroup) Handle

func (cg *ConnectionGroup) Handle(connectionWorker *ConnectionWorker) error

func (*ConnectionGroup) IsEmpty

func (cg *ConnectionGroup) IsEmpty() bool

func (*ConnectionGroup) IsFull

func (cg *ConnectionGroup) IsFull() bool

func (*ConnectionGroup) SetLimit

func (cg *ConnectionGroup) SetLimit(limit int)

func (*ConnectionGroup) Start

func (cg *ConnectionGroup) Start()

func (*ConnectionGroup) Stop

func (cg *ConnectionGroup) Stop()

type ConnectionGroupManager

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

func NewConnectionGroupManager

func NewConnectionGroupManager(logger logrus.FieldLogger, groupLimit, connsLimit int) (*ConnectionGroupManager, error)

func (*ConnectionGroupManager) Add

func (m *ConnectionGroupManager) Add(group *ConnectionGroup) (int, error)

func (*ConnectionGroupManager) Capacity

func (m *ConnectionGroupManager) Capacity() float32

func (*ConnectionGroupManager) Delete

func (m *ConnectionGroupManager) Delete(group *ConnectionGroup) error

func (*ConnectionGroupManager) Get

func (m *ConnectionGroupManager) Get(id int) (*ConnectionGroup, error)

func (*ConnectionGroupManager) GroupCount

func (m *ConnectionGroupManager) GroupCount() int

func (*ConnectionGroupManager) GroupLimit

func (m *ConnectionGroupManager) GroupLimit() int

func (*ConnectionGroupManager) Groups

func (m *ConnectionGroupManager) Groups() map[int]*ConnectionGroup

func (*ConnectionGroupManager) IsFull

func (m *ConnectionGroupManager) IsFull() bool

type ConnectionWorker

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

func NewConnectionWorker

func NewConnectionWorker(conn *websocket.Conn, logger logrus.FieldLogger) *ConnectionWorker

func (*ConnectionWorker) Start

func (cw *ConnectionWorker) Start(stop <-chan struct{}, game *game.Game, broadcast *broadcast.GroupBroadcast, gamePreparedMessages <-chan *websocket.PreparedMessage) error

type ErrAddGroup

type ErrAddGroup string

func (ErrAddGroup) Error

func (e ErrAddGroup) Error() string

type ErrDeleteGroup

type ErrDeleteGroup string

func (ErrDeleteGroup) Error

func (e ErrDeleteGroup) Error() string

type ErrHandleConnection

type ErrHandleConnection struct {
	Err error
}

func (*ErrHandleConnection) Error

func (e *ErrHandleConnection) Error() string

type ErrStartConnectionWorker

type ErrStartConnectionWorker string

func (ErrStartConnectionWorker) Error

func (e ErrStartConnectionWorker) Error() string

type InputMessage

type InputMessage struct {
	Type    InputMessageType `json:"type"`
	Payload string           `json:"payload"`
}

ffjson: noencoder

func (*InputMessage) UnmarshalJSON

func (j *InputMessage) UnmarshalJSON(input []byte) error

UnmarshalJSON umarshall json - template of ffjson

func (*InputMessage) UnmarshalJSONFFLexer

func (j *InputMessage) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

UnmarshalJSONFFLexer fast json unmarshall - template ffjson

type InputMessageType

type InputMessageType uint8

const (
	InputMessageTypeSnakeCommand InputMessageType = iota
	InputMessageTypeBroadcast
)

func (InputMessageType) String

func (t InputMessageType) String() string

func (*InputMessageType) UnmarshalJSON

func (t *InputMessageType) UnmarshalJSON(data []byte) error

type OutputMessage

type OutputMessage struct {
	Type    OutputMessageType `json:"type"`
	Payload interface{}       `json:"payload"`
}

ffjson: nodecoder

func (*OutputMessage) MarshalJSON

func (j *OutputMessage) MarshalJSON() ([]byte, error)

MarshalJSON marshal bytes to json - template

func (*OutputMessage) MarshalJSONBuf

func (j *OutputMessage) MarshalJSONBuf(buf fflib.EncodingBuffer) error

MarshalJSONBuf marshal buff to json - template

type OutputMessageType

type OutputMessageType uint8

const (
	OutputMessageTypeGame OutputMessageType = iota
	OutputMessageTypePlayer
	OutputMessageTypeBroadcast
)

func (OutputMessageType) MarshalJSON

func (t OutputMessageType) MarshalJSON() ([]byte, error)

func (OutputMessageType) String

func (t OutputMessageType) String() string