ws

Documentation

Index

• type WebSocketChannels
• type WebSocketServer
  • func NewWebSocketServer(bgCtx context.Context) WebSocketServer

Types

type WebSocketChannels

type WebSocketChannels interface {
	GetChannels(topic string) (senderChannel chan<- interface{}, broadcastChannel chan<- interface{}, receiverChannel <-chan error)
	SendReply(message interface{})
}

WebSocketChannels is provided to allow us to do a blocking send to a namespace that will complete once a client connects on it We also provide a channel to listen on for closing of the connection, to allow a select to wake on a blocking send

type WebSocketServer

type WebSocketServer interface {
	WebSocketChannels
	Handler(w http.ResponseWriter, r *http.Request)
	Close()
}

WebSocketServer is the full server interface with the init call

func NewWebSocketServer

func NewWebSocketServer(bgCtx context.Context) WebSocketServer

NewWebSocketServer create a new server with a simplified interface