server

Documentation

Index

• Constants
• Variables
• func ProvideMemConn() *memconn.Provider
• 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 APIServerConfig
  • func ProvideTiltServerOptions(ctx context.Context, host model.WebHost, port model.WebPort, ...) (*APIServerConfig, error)
• type AppendToTriggerQueueAction
  • func (AppendToTriggerQueueAction) Action()
• type DynamicInterface
  • func ProvideTiltDynamic(config *APIServerConfig) (DynamicInterface, error)
• 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) HandleMetricsOpt(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleNewSnapshot(w http.ResponseWriter, req *http.Request)
  • func (s *HeadsUpServer) HandleOverrideTriggerMode(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(port model.WebPort, apiServerConfig *APIServerConfig, hudServer *HeadsUpServer, ...) *HeadsUpServerController
  • func (s *HeadsUpServerController) OnChange(ctx context.Context, st store.RStore)
  • func (s *HeadsUpServerController) SetUp(ctx context.Context, st store.RStore) error
  • func (s *HeadsUpServerController) TearDown(ctx context.Context)
• type Interface
  • func ProvideTiltInterface(config *APIServerConfig) (Interface, error)
• type LogStreamer
  • func NewLogStreamer(resources []string, p *hud.IncrementalPrinter) *LogStreamer
  • func (ls *LogStreamer) Handle(v proto_webview.View) error
• type OverrideTriggerModeAction
  • func (OverrideTriggerModeAction) Action()
• 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"

Variables

var WireSet = wire.NewSet(
	ProvideMemConn,
	ProvideTiltServerOptions,
	ProvideTiltInterface,
	ProvideTiltDynamic,
	ProvideHeadsUpServer,
	ProvideHeadsUpServerController,
)

Functions

func ProvideMemConn

func ProvideMemConn() *memconn.Provider

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 APIServerConfig

type APIServerConfig = apiserver.Config

func ProvideTiltServerOptions

func ProvideTiltServerOptions(ctx context.Context, host model.WebHost, port model.WebPort, tiltBuild model.TiltBuild, memconn *memconn.Provider) (*APIServerConfig, error)

Configures the Tilt API server.

type AppendToTriggerQueueAction

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

func (AppendToTriggerQueueAction) Action

func (AppendToTriggerQueueAction) Action()

type DynamicInterface

type DynamicInterface = dynamic.Interface

func ProvideTiltDynamic

func ProvideTiltDynamic(config *APIServerConfig) (DynamicInterface, error)

Provide a dynamic API client for the Tilt server.

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,
	metrics *metrics.ModeController,
	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) HandleMetricsOpt

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

func (*HeadsUpServer) HandleNewSnapshot

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

func (*HeadsUpServer) HandleOverrideTriggerMode

func (s *HeadsUpServer) HandleOverrideTriggerMode(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(
	port model.WebPort,
	apiServerConfig *APIServerConfig,
	hudServer *HeadsUpServer,
	assetServer assets.Server,
	webURL model.WebURL) *HeadsUpServerController

func (*HeadsUpServerController) OnChange

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

func (*HeadsUpServerController) SetUp

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

Merge the APIServer and the Tilt Web server into a single handler, and attach them both to the public listener.

func (*HeadsUpServerController) TearDown

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

type Interface

type Interface = tiltapi.Interface

func ProvideTiltInterface

func ProvideTiltInterface(config *APIServerConfig) (Interface, error)

Provide a typed API client for the Tilt server.

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 OverrideTriggerModeAction

type OverrideTriggerModeAction struct {
	ManifestNames []model.ManifestName
	TriggerMode   model.TriggerMode
}

TODO: a way to clear an override

func (OverrideTriggerModeAction) Action

func (OverrideTriggerModeAction) Action()

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)