ws

Documentation

Index

• type WebSocketChannels
• type WebSocketServer
  • func NewWebSocketServer() WebSocketServer

Types

type WebSocketChannels

type WebSocketChannels interface {
	GetChannels(topic string) (chan<- interface{}, chan<- interface{}, <-chan error, <-chan struct{})
	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
	NewConnection(w http.ResponseWriter, r *http.Request, p httprouter.Params)
	Close()
}

WebSocketServer is the full server interface with the init call

func NewWebSocketServer

func NewWebSocketServer() WebSocketServer

NewWebSocketServer create a new server with a simplified interface