realtime

package

v1.5.1 Latest Latest Go to latest Published: Jun 20, 2023 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broker struct {
	Broadcast chan model.Command
	// contains filtered or unexported fields
}

Broker is used to hold all web socket connections

func NewBroker(v Validator, pubsub cache.Volatilizer, log *logger.Logger) *Broker

NewBroker returns a ready to use Broker for accepting web socket connections

func (b *Broker) Accept(w http.ResponseWriter, r *http.Request)

Accept turns a request into a web socket request and creates a new connection in the Broker

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

ConnectionData holds a channel for each web socket connection

type Validator func(context.Context, string) (string, error)

Validator validates a session token