server

Documentation

Index

• Constants
• func SendToTriggerQueue(st store.RStore, name string) error
• type AppendToTriggerQueueAction
  • func (AppendToTriggerQueueAction) Action()
• type HeadsUpServer
  • func ProvideHeadsUpServer(ctx context.Context, store *store.Store, assetServer assets.Server, ...) (*HeadsUpServer, error)
  • func (s *HeadsUpServer) DispatchAction(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) DumpEngineJSON(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleAnalytics(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleAnalyticsOpt(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleNewSnapshot(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleTrigger(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) Router() http.Handler
  • func (s *HeadsUpServer) SnapshotJSON(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) ViewJSON(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) ViewWebsocket(w http.ResponseWriter, req *http.Request)
• type HeadsUpServerController
  • func ProvideHeadsUpServerController(host model.WebHost, port model.WebPort, hudServer *HeadsUpServer, ...) *HeadsUpServerController
  • func (s *HeadsUpServerController) OnChange(ctx context.Context, st store.RStore)
  • func (s *HeadsUpServerController) TearDown(ctx context.Context)
• type WebsocketConn
• type WebsocketSubscriber
  • func NewWebsocketSubscriber(conn WebsocketConn) WebsocketSubscriber
  • func (ws WebsocketSubscriber) OnChange(ctx context.Context, s store.RStore)
  • func (ws WebsocketSubscriber) Stream(ctx context.Context, store *store.Store)
  • func (ws WebsocketSubscriber) TearDown(ctx context.Context)

Constants

const TiltTokenCookieName = "Tilt-Token"

Functions

func SendToTriggerQueue

func SendToTriggerQueue(st store.RStore, name string) error

Types

type AppendToTriggerQueueAction

type AppendToTriggerQueueAction struct {
	Name model.ManifestName
}

func (AppendToTriggerQueueAction) Action

func (AppendToTriggerQueueAction) Action()

type HeadsUpServer

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

func ProvideHeadsUpServer

func ProvideHeadsUpServer(
	ctx context.Context,
	store *store.Store,
	assetServer assets.Server,
	analytics *tiltanalytics.TiltAnalytics,
	uploader cloud.SnapshotUploader) (*HeadsUpServer, error)

func (*HeadsUpServer) DispatchAction

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

func (*HeadsUpServer) DumpEngineJSON

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

Dump the JSON engine over http. Only intended for 'tilt dump engine'.

func (*HeadsUpServer) HandleAnalytics

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

func (*HeadsUpServer) HandleAnalyticsOpt

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

func (*HeadsUpServer) HandleNewSnapshot

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

func (*HeadsUpServer) HandleTrigger

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

func (*HeadsUpServer) Router

func (s *HeadsUpServer) Router() http.Handler

func (*HeadsUpServer) SnapshotJSON

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

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 HeadsUpServerController

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

func ProvideHeadsUpServerController

func ProvideHeadsUpServerController(host model.WebHost, port model.WebPort, hudServer *HeadsUpServer, assetServer assets.Server, webURL model.WebURL, noBrowser model.NoBrowser) *HeadsUpServerController

func (*HeadsUpServerController) OnChange

func (s *HeadsUpServerController) OnChange(ctx context.Context, st store.RStore)

func (*HeadsUpServerController) TearDown

func (s *HeadsUpServerController) TearDown(ctx context.Context)

type WebsocketConn

type WebsocketConn interface {
	NextReader() (int, io.Reader, error)
	Close() error
	WriteJSON(v interface{}) error
	NextWriter(messageType int) (io.WriteCloser, error)
}

type WebsocketSubscriber

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

func NewWebsocketSubscriber

func NewWebsocketSubscriber(conn WebsocketConn) 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)

Should be called exactly once. Consumes messages until the socket closes.

func (WebsocketSubscriber) TearDown

func (ws WebsocketSubscriber) TearDown(ctx context.Context)