server

package

v0.9.1 Latest Latest Go to latest Published: Jul 1, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

type FanConn interface {
	WriteMessage(int, []byte) error
	NextReader() (int, io.Reader, error)
	Close() error
}

A websocket that we only write messages to

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

func (a FanOutAction) Empty() bool

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

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

A room where messages from a source are broadcast to all the followers.

func NewRoom(version model.WebVersion) *Room

func (r *Room) AddFan(ctx context.Context, conn FanConn)

Add a fan that consumes messages from the source. Calling AddFan() after Close() will error.

func (r *Room) Close()

Only close the room when we know AddFan can't be called.

func (r *Room) ConsumeSource(ctx context.Context) error

Receive messages from the source websocket and put them through the state loop.

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

func ProvideSailServer(assetServer assets.Server) SailServer

func (s SailServer) Router() http.Handler

type SourceConn interface {
	ReadMessage() (int, []byte, error)
	Close() error
}

A websocket that we only read messages from