websocket

Documentation

Index

• type Client
• type Clients
  • func (r *Clients) SendToAll(t string, data interface{})
  • func (clients *Clients) WebsocketRoute(c *gin.Context)
• type ErrNoSuchRoute
  • func (self *ErrNoSuchRoute) Error() string
• type Message
• type Router
  • func NewRouter() *Router
  • func (w *Router) AddClientConnectHandler(handler func() *Message)
  • func (w *Router) AddRoute(route string, handler func(*Message))
  • func (w *Router) Run(msg *Message) error
  • func (w *Router) RunOnClientConnectHandlers() []*Message

Types

type Client

type Client struct {
	Id string
	// contains filtered or unexported fields
}

type Clients

type Clients struct {
	sync.Mutex

	Router *Router `inject:""`
	// contains filtered or unexported fields
}

func (*Clients) SendToAll

func (r *Clients) SendToAll(t string, data interface{})

Message all the other clients

func (*Clients) WebsocketRoute

func (clients *Clients) WebsocketRoute(c *gin.Context)

type ErrNoSuchRoute

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

func (*ErrNoSuchRoute) Error

func (self *ErrNoSuchRoute) Error() string

type Message

type Message struct {
	Type string          `json:"type"`
	Data json.RawMessage `json:"data"`
	To   string          `json:"to"`
}

type Router

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

func NewRouter

func NewRouter() *Router

func (*Router) AddClientConnectHandler

func (w *Router) AddClientConnectHandler(handler func() *Message)

func (*Router) AddRoute

func (w *Router) AddRoute(route string, handler func(*Message))

func (*Router) Run

func (w *Router) Run(msg *Message) error

func (*Router) RunOnClientConnectHandlers

func (w *Router) RunOnClientConnectHandlers() []*Message