websocket

Documentation

Index

• Variables
• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) Init(ctx context.Context, gorts *sdk.GoRoutines, pubSub cache.PubSub)
  • func (b *Broker) OnMessage(f func(m []byte))
• type Client
  • func NewClient(conn *websocket.Conn) Client
• type CommonClient
  • func (c *CommonClient) Close()
  • func (c *CommonClient) Listen(ctx context.Context, gorts *sdk.GoRoutines) error
  • func (c *CommonClient) OnMessage(f func([]byte))
  • func (c *CommonClient) Send(m interface{}) (err error)
  • func (c *CommonClient) UUID() string
• type Server
  • func NewServer() *Server
  • func (s *Server) AddClient(c Client)
  • func (s *Server) ClientIDs() []string
  • func (s *Server) Close()
  • func (s *Server) RemoveClient(uuid string)
  • func (s *Server) SendToClient(uuid string, i interface{}) error

Variables

var Upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool { return true },
}

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) Init

func (b *Broker) Init(ctx context.Context, gorts *sdk.GoRoutines, pubSub cache.PubSub)

Init the websocketBroker

func (*Broker) OnMessage

func (b *Broker) OnMessage(f func(m []byte))

type Client

type Client interface {
	UUID() string
	Listen(context.Context, *sdk.GoRoutines) error
	OnMessage(func([]byte))
	Send(interface{}) error
	Close()
}

func NewClient

func NewClient(conn *websocket.Conn) Client

type CommonClient

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

func (*CommonClient) Close

func (c *CommonClient) Close()

func (*CommonClient) Listen

func (c *CommonClient) Listen(ctx context.Context, gorts *sdk.GoRoutines) error

func (*CommonClient) OnMessage

func (c *CommonClient) OnMessage(f func([]byte))

func (*CommonClient) Send

func (c *CommonClient) Send(m interface{}) (err error)

func (*CommonClient) UUID

func (c *CommonClient) UUID() string

type Server

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

func NewServer

func NewServer() *Server

func (*Server) AddClient

func (s *Server) AddClient(c Client)

func (*Server) ClientIDs

func (s *Server) ClientIDs() []string

func (*Server) Close

func (s *Server) Close()

func (*Server) RemoveClient

func (s *Server) RemoveClient(uuid string)

func (*Server) SendToClient

func (s *Server) SendToClient(uuid string, i interface{}) error