server

Documentation

Index

• type AddFanAction
• type FanConn
• type FanOutAction
  • func (a FanOutAction) Empty() bool
• type Room
  • func NewRoom(version model.WebVersion) *Room
  • func (r *Room) AddFan(ctx context.Context, conn FanConn)
  • func (r *Room) Close()
  • func (r *Room) ConsumeSource(ctx context.Context) error
• type SailServer
  • func ProvideSailServer(assetServer assets.Server) SailServer
  • func (s SailServer) Router() http.Handler
• type SourceConn

Types

type AddFanAction

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

type FanConn

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

A websocket that we only write messages to

type FanOutAction

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

func (FanOutAction) Empty

func (a FanOutAction) Empty() bool

type Room

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

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

func NewRoom

func NewRoom(version model.WebVersion) *Room

func (*Room) AddFan

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 (*Room) Close

func (r *Room) Close()

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

func (*Room) ConsumeSource

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

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

type SailServer

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

func ProvideSailServer

func ProvideSailServer(assetServer assets.Server) SailServer

func (SailServer) Router

func (s SailServer) Router() http.Handler

type SourceConn

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

A websocket that we only read messages from