websocket

package

v0.57.0 Latest Latest Go to latest Published: Apr 15, 2026 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

func NewBroker() *Broker

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

Init the websocketBroker

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

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

func NewClient(conn *websocket.Conn) Client

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

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 struct {
	// contains filtered or unexported fields
}

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