server

Documentation

Index

• type HeadsUpServer
  • func ProvideHeadsUpServer(store *store.Store) HeadsUpServer
  • func (s HeadsUpServer) Router() http.Handler
  • func (s HeadsUpServer) ViewJSON(w http.ResponseWriter, req *http.Request)
  • func (s HeadsUpServer) ViewWebsocket(w http.ResponseWriter, req *http.Request)
• type WebsocketSubscriber
  • func NewWebsocketSubscriber(conn *websocket.Conn) WebsocketSubscriber
  • func (ws WebsocketSubscriber) OnChange(ctx context.Context, s store.RStore)
  • func (ws WebsocketSubscriber) Stream(ctx context.Context, store *store.Store)

Types

type HeadsUpServer

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

func ProvideHeadsUpServer

func ProvideHeadsUpServer(store *store.Store) HeadsUpServer

func (HeadsUpServer) Router

func (s HeadsUpServer) Router() http.Handler

func (HeadsUpServer) ViewJSON

func (s HeadsUpServer) ViewJSON(w http.ResponseWriter, req *http.Request)

func (HeadsUpServer) ViewWebsocket

func (s HeadsUpServer) ViewWebsocket(w http.ResponseWriter, req *http.Request)

type WebsocketSubscriber

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

func NewWebsocketSubscriber

func NewWebsocketSubscriber(conn *websocket.Conn) WebsocketSubscriber

func (WebsocketSubscriber) OnChange

func (ws WebsocketSubscriber) OnChange(ctx context.Context, s store.RStore)

func (WebsocketSubscriber) Stream

func (ws WebsocketSubscriber) Stream(ctx context.Context, store *store.Store)