server

Documentation

Index

• Constants
• func SendToTriggerQueue(st store.RStore, name string, buildReason model.BuildReason) error
• func StreamLogs(ctx context.Context, follow bool, url model.WebURL, resources []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) HandleSetTiltfileArgs(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 LogStreamer
  • func NewLogStreamer(resources []string, p *hud.IncrementalPrinter) *LogStreamer
  • func (ls *LogStreamer) Handle(v proto_webview.View) error
• type SetTiltfileArgsAction
  • func (SetTiltfileArgsAction) Action()
• type ViewHandler
• type WebsocketConn
• type WebsocketReader
  • func (wsr *WebsocketReader) Listen(ctx context.Context) error
• type WebsocketSubscriber
  • func NewWebsocketSubscriber(ctx context.Context, 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, buildReason model.BuildReason) error

func StreamLogs

func StreamLogs(ctx context.Context, follow bool, url model.WebURL, resources []string, printer *hud.IncrementalPrinter) error

Types

type AppendToTriggerQueueAction

type AppendToTriggerQueueAction struct {
	Name   model.ManifestName
	Reason model.BuildReason
}

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) HandleSetTiltfileArgs

func (s *HeadsUpServer) HandleSetTiltfileArgs(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) *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 LogStreamer

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

func NewLogStreamer

func NewLogStreamer(resources []string, p *hud.IncrementalPrinter) *LogStreamer

func (*LogStreamer) Handle

func (ls *LogStreamer) Handle(v proto_webview.View) error

type SetTiltfileArgsAction

type SetTiltfileArgsAction struct {
	Args []string
}

func (SetTiltfileArgsAction) Action

func (SetTiltfileArgsAction) Action()

type ViewHandler

type ViewHandler interface {
	Handle(v proto_webview.View) error
}

type WebsocketConn

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

type WebsocketReader

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

func (*WebsocketReader) Listen

func (wsr *WebsocketReader) Listen(ctx context.Context) error

type WebsocketSubscriber

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

func NewWebsocketSubscriber

func NewWebsocketSubscriber(ctx context.Context, 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)