message

Documentation

Index

• type Adapter
  • func NewAdapter() *Adapter
  • func (a Adapter) Exec(msg *Message) (bool, error)
  • func (a *Adapter) Register(msgtype string, handler func(*Message) error)
• type Message
  • func New() *Message

Types

type Adapter

type Adapter map[string]func(*Message) error

Adapter connection message adapter

func NewAdapter

func NewAdapter() *Adapter

NewAdapter create new message adapter

func (Adapter) Exec

func (a Adapter) Exec(msg *Message) (bool, error)

Exec exec message. Return if handler by message type exists and any error rasied.

func (*Adapter) Register

func (a *Adapter) Register(msgtype string, handler func(*Message) error)

Register register message handler by given type.

type Message

type Message struct {
	//Type message type
	Type string
	// Room message room id
	Room string
	//Data message data
	Data interface{}
}

Message connection message struct

func New

func New() *Message

New create new message.