engine

package

Versions in this module

v0

v0.8.0

Apr 22, 2019

Changes in this version

+ func ProvideSubscribers(hud hud.HeadsUpDisplay, pw *PodWatcher, sw *ServiceWatcher, plm *PodLogManager, ...) []store.Subscriber

v0.7.13

Apr 11, 2019

v0.7.12

Apr 11, 2019

Changes in this version

type RedirectToNextBuilder

+ func RedirectToNextBuilderInfof(msg string, a ...interface{}) RedirectToNextBuilder

+ func SilentRedirectToNextBuilderf(msg string, a ...interface{}) RedirectToNextBuilder

v0.7.11

Apr 8, 2019

Changes in this version

+ type AnalyticsReporter struct

+ func ProvideAnalyticsReporter(a analytics.Analytics, st *store.Store) *AnalyticsReporter

+ func (ar *AnalyticsReporter) OnChange(ctx context.Context, st store.RStore)

+ type BuildHandler func(target model.TargetSpec, state store.BuildState, ...) (store.BuildResult, error)

type BuildLogAction

+ func (le BuildLogAction) Message() []byte

+ func (le BuildLogAction) Time() time.Time

type BuildOrder

+ func (bo BuildOrder) String() string

type ConfigsReloadStartedAction

+ StartTime time.Time

type ConfigsReloadedAction

+ TiltIgnoreContents string

+ Warnings []string

+ type DeployIDAction struct

+ DeployID model.DeployID

+ TargetID model.TargetID

+ func NewDeployIDAction(id model.TargetID, dID model.DeployID) DeployIDAction

+ func NewDeployIDActionsForTargets(ids []model.TargetID, dID model.DeployID) []DeployIDAction

+ func (DeployIDAction) Action()

type DockerComposeLogAction

+ func (le DockerComposeLogAction) Message() []byte

+ func (le DockerComposeLogAction) Time() time.Time

type InitAction

+ ExecuteTiltfile bool

+ Warnings []string

+ WatchFiles bool

+ type KINDPusher interface

+ PushToKIND func(ctx context.Context, ref reference.NamedTagged, w io.Writer) error

+ func NewKINDPusher() KINDPusher

type LogAction

+ func (le LogAction) Message() []byte

+ func (le LogAction) Time() time.Time

type PodLogAction

+ func (le PodLogAction) Message() []byte

+ func (le PodLogAction) Time() time.Time

type SyncletBuildAndDeployer

+ func (sbd *SyncletBuildAndDeployer) UpdateInCluster(ctx context.Context, iTarget model.ImageTarget, state store.BuildState) (store.BuildResultSet, error)

+ type TargetQueue struct

+ func NewImageTargetQueue(iTargets []model.ImageTarget, state store.BuildStateSet) (*TargetQueue, error)

+ func (q *TargetQueue) CountDirty() int

+ func (q *TargetQueue) RunBuilds(handler BuildHandler) error

type TiltfileLogAction

+ func (le TiltfileLogAction) Message() []byte

+ func (le TiltfileLogAction) Time() time.Time

type UpdateMode

+ var UpdateModeKubectlExec UpdateMode = "exec"

v0.7.2

Feb 5, 2019

v0.7.1

Feb 5, 2019

Changes in this version

+ func TiltRunSelector() labels.Selector

+ type PodWatch struct

v0.7.0

Feb 1, 2019

v0.6.1

Jan 31, 2019

v0.6.0

Jan 31, 2019

Changes in this version

+ func NewImageAndCacheBuilder(ib build.ImageBuilder, cb build.CacheBuilder, updateMode UpdateMode) *imageAndCacheBuilder

+ func NewTiltfileLogWriter(s store.RStore) *tiltfileLogWriter

+ type TiltfileLogAction struct

+ Log []byte

+ func (TiltfileLogAction) Action()

v0.5.1

Jan 17, 2019

Changes in this version

+ var ConfigsTargetID = model.TargetID

type BuildStartedAction

+ ManifestName model.ManifestName

+ type WatchableTarget interface

+ Dependencies func() []string

+ ID func() model.TargetID

v0.5.0

Jan 14, 2019

Changes in this version

type SyncletManager

+ func (sm SyncletManager) OnChange(ctx context.Context, store store.RStore)

v0.4.3

Jan 10, 2019

v0.4.2

Jan 9, 2019

Changes in this version

+ type ProfilerManager struct

+ func NewProfilerManager() *ProfilerManager

+ func (p *ProfilerManager) OnChange(ctx context.Context, st store.RStore)

+ func (p *ProfilerManager) Start(ctx context.Context, filename string) error

+ func (p *ProfilerManager) Stop(ctx context.Context) error

v0.4.1

Jan 7, 2019

Changes in this version

+ func NewLogActionLogger(ctx context.Context, dispatch func(action store.Action)) logger.Logger

type ConfigsReloadedAction

+ FinishTime time.Time

+ StartTime time.Time

+ type DockerComposeBuildAndDeployer struct

+ func NewDockerComposeBuildAndDeployer(dcc dockercompose.DockerComposeClient) *DockerComposeBuildAndDeployer

+ func (bd *DockerComposeBuildAndDeployer) BuildAndDeploy(ctx context.Context, manifest model.Manifest, state store.BuildState) (br store.BuildResult, err error)

+ func (bd *DockerComposeBuildAndDeployer) PostProcessBuild(ctx context.Context, result, previousResult store.BuildResult)

+ type DockerComposeEventAction struct

+ Event dockercompose.Event

+ func (DockerComposeEventAction) Action()

+ type DockerComposeEventWatcher struct

+ func NewDockerComposeEventWatcher(dcc dockercompose.DockerComposeClient) *DockerComposeEventWatcher

+ func (w *DockerComposeEventWatcher) OnChange(ctx context.Context, st store.RStore)

+ type DockerComposeGlobalLogWriter struct

+ func (w DockerComposeGlobalLogWriter) Write(p []byte) (n int, err error)

+ type DockerComposeLogAction struct

+ Log []byte

+ ManifestName model.ManifestName

+ func (DockerComposeLogAction) Action()

+ type DockerComposeLogActionWriter struct

+ func (w DockerComposeLogActionWriter) Write(p []byte) (n int, err error)

+ type DockerComposeLogManager struct

+ func NewDockerComposeLogManager(dcc dockercompose.DockerComposeClient) *DockerComposeLogManager

+ func (m *DockerComposeLogManager) OnChange(ctx context.Context, st store.RStore)

type InitAction

+ Err error

+ FinishTime time.Time

+ InitManifests []model.ManifestName

+ StartTime time.Time

+ TriggerMode model.TriggerMode

type Upper

+ func (u Upper) Init(ctx context.Context, action InitAction) error

type WatchableManifest

+ Dockerignores func() []model.Dockerignore

v0.2.0

Dec 3, 2018

Changes in this version

+ const ConfigsManifestName

+ type BuildLogAction struct

+ Log []byte

+ ManifestName model.ManifestName

+ func (BuildLogAction) Action()

+ type BuildLogActionWriter struct

+ func (w BuildLogActionWriter) Write(p []byte) (n int, err error)

type BuildStartedAction

+ Reason model.BuildReason

+ type ConfigsController struct

+ func NewConfigsController() *ConfigsController

+ func (cc *ConfigsController) DisableForTesting(disabled bool)

+ func (cc *ConfigsController) OnChange(ctx context.Context, st store.RStore)

+ type ConfigsReloadStartedAction struct

+ FilesChanged map[string]bool

+ func (ConfigsReloadStartedAction) Action()

+ type ConfigsReloadedAction struct

+ ConfigFiles []string

+ Err error

+ GlobalYAML model.YAMLManifest

+ Manifests []model.Manifest

+ func (ConfigsReloadedAction) Action()

+ type DontFallBackError struct

+ func DontFallBackErrorf(msg string, a ...interface{}) DontFallBackError

+ func WrapDontFallBackError(err error) DontFallBackError

type GlobalYAMLApplyCompleteAction

+ Error error

+ type HardCancelReader struct

+ func NewHardCancelReader(ctx context.Context, reader io.Reader) HardCancelReader

+ func (r HardCancelReader) Read(b []byte) (int, error)

type InitAction

+ ConfigFiles []string

+ ManifestNames []model.ManifestName

+ type RedirectToNextBuilder struct

+ func RedirectToNextBuilderf(msg string, a ...interface{}) RedirectToNextBuilder

+ func WrapRedirectToNextBuilder(err error) RedirectToNextBuilder

type WatchManager

+ func (w *WatchManager) DisableForTesting()

v0.1.0

Nov 5, 2018

Changes in this version

+ var UpperReducer = store.Reducer(...)

type BuildController

+ func (c *BuildController) DisableForTesting()

+ type GlobalYAMLApplyCompleteAction struct

+ func (GlobalYAMLApplyCompleteAction) Action()

+ type GlobalYAMLApplyError struct

+ Error error

+ func (GlobalYAMLApplyError) Action()

+ type GlobalYAMLApplyStartedAction struct

+ func (GlobalYAMLApplyStartedAction) Action()

+ type GlobalYAMLBuildController struct

+ func NewGlobalYAMLBuildController(k8sClient k8s.Client) *GlobalYAMLBuildController

+ func (c *GlobalYAMLBuildController) OnChange(ctx context.Context, st *store.Store)

+ type GlobalYAMLManifestReloadedAction struct

+ GlobalYAML model.YAMLManifest

+ func (GlobalYAMLManifestReloadedAction) Action()

+ type HudStoppedAction struct

+ func NewHudStoppedAction(err error) HudStoppedAction

+ func (HudStoppedAction) Action()

+ type ImageController struct

+ func NewImageController(reaper build.ImageReaper) *ImageController

+ func (c *ImageController) OnChange(ctx context.Context, store *store.Store)

type InitAction

+ GlobalYAMLManifest model.YAMLManifest

+ TiltfilePath string

+ type LogAction struct

+ Log []byte

+ func (LogAction) Action()

type ServiceChangeAction

+ URL *url.URL

type Upper

+ func (u Upper) Dispatch(action store.Action)

+ func (u Upper) Start(ctx context.Context, args []string, watchMounts bool) error

+ func (u Upper) StartForTesting(ctx context.Context, manifests []model.Manifest, globalYAML model.YAMLManifest, ...) error

+ type WatchableManifest interface

+ ConfigMatcher func() (model.PathMatcher, error)

+ Dependencies func() []string

+ LocalRepos func() []model.LocalGithubRepo

+ ManifestName func() model.ManifestName

v0.0.1

Oct 24, 2018

Changes in this version

+ const ManifestNameLabel

+ const TiltRunIDLabel

+ var AllUpdateModes = []UpdateMode

+ var DeployerBaseWireSet = wire.NewSet(build.DefaultConsole, build.DefaultOut, wire.Value(build.Labels{}), ...)

+ var DeployerWireSet = wire.NewSet(DeployerBaseWireSet, NewSyncletManager)

+ var DeployerWireSetTest = wire.NewSet(DeployerBaseWireSet, NewSyncletManagerForTests)

+ var TiltRunID = uuid.New().String()

+ func ParseYAMLFromManifests(manifests ...model.Manifest) ([]k8s.K8sEntity, error)

+ func PopulatePortForwards(m model.Manifest, pod store.Pod) []model.PortForward

+ func ProvideTimerMaker() timerMaker

+ func TiltRunLabel() k8s.LabelPair

+ type BuildAndDeployer interface

+ BuildAndDeploy func(ctx context.Context, manifest model.Manifest, currentState store.BuildState) (store.BuildResult, error)

+ PostProcessBuild func(ctx context.Context, result, prevResult store.BuildResult)

+ type BuildCompleteAction struct

+ Error error

+ Result store.BuildResult

+ func NewBuildCompleteAction(result store.BuildResult, err error) BuildCompleteAction

+ func (BuildCompleteAction) Action()

+ type BuildController struct

+ func NewBuildController(b BuildAndDeployer) *BuildController

+ func (c *BuildController) OnChange(ctx context.Context, st *store.Store)

+ type BuildOrder []BuildAndDeployer

+ func DefaultBuildOrder(sbad *SyncletBuildAndDeployer, cbad *LocalContainerBuildAndDeployer, ...) BuildOrder

+ type BuildStartedAction struct

+ FilesChanged []string

+ Manifest model.Manifest

+ StartTime time.Time

+ func (BuildStartedAction) Action()

+ type CompositeBuildAndDeployer struct

+ func NewCompositeBuildAndDeployer(builders BuildOrder, shouldFallBack FallbackTester) *CompositeBuildAndDeployer

+ func (composite *CompositeBuildAndDeployer) BuildAndDeploy(ctx context.Context, manifest model.Manifest, currentState store.BuildState) (store.BuildResult, error)

+ func (composite *CompositeBuildAndDeployer) PostProcessBuild(ctx context.Context, result, prevResult store.BuildResult)

+ type DeployDiscovery struct

+ func NewDeployDiscovery(kCli k8s.Client, store *store.Store) *DeployDiscovery

+ func (d *DeployDiscovery) DeployInfoForImageBlocking(ctx context.Context, img reference.NamedTagged) (DeployInfo, error)

+ func (d *DeployDiscovery) EnsureDeployInfoFetchStarted(ctx context.Context, img reference.NamedTagged, ns k8s.Namespace)

+ func (d *DeployDiscovery) ForgetImage(img reference.NamedTagged) DeployInfo

+ type DeployInfo struct

+ func (d DeployInfo) Empty() bool

+ type ErrorAction struct

+ Error error

+ func NewErrorAction(err error) ErrorAction

+ func (ErrorAction) Action()

+ type FallbackTester func(error) bool

+ func DefaultShouldFallBack() FallbackTester

+ type FsWatcherMaker func() (watch.Notify, error)

+ func ProvideFsWatcherMaker() FsWatcherMaker

+ type ImageBuildAndDeployer struct

+ func NewImageBuildAndDeployer(b build.ImageBuilder, k8sClient k8s.Client, env k8s.Env, ...) *ImageBuildAndDeployer

+ func (ibd *ImageBuildAndDeployer) BuildAndDeploy(ctx context.Context, manifest model.Manifest, state store.BuildState) (br store.BuildResult, err error)

+ func (ibd *ImageBuildAndDeployer) PostProcessBuild(ctx context.Context, result, previousResult store.BuildResult)

+ func (ibd *ImageBuildAndDeployer) SetInjectSynclet(inject bool)

+ type InitAction struct

+ Manifests []model.Manifest

+ WatchMounts bool

+ func (InitAction) Action()

+ type LocalContainerBuildAndDeployer struct

+ func NewLocalContainerBuildAndDeployer(cu *build.ContainerUpdater, analytics analytics.Analytics, dd *DeployDiscovery) *LocalContainerBuildAndDeployer

+ func (cbd *LocalContainerBuildAndDeployer) BuildAndDeploy(ctx context.Context, manifest model.Manifest, state store.BuildState) (result store.BuildResult, err error)

+ func (cbd *LocalContainerBuildAndDeployer) PostProcessBuild(ctx context.Context, result, previousResult store.BuildResult)

+ type ManifestReloadedAction struct

+ Error *manifestErr

+ NewManifest model.Manifest

+ OldManifest model.Manifest

+ func (ManifestReloadedAction) Action()

+ type PodChangeAction struct

+ Pod *v1.Pod

+ func NewPodChangeAction(pod *v1.Pod) PodChangeAction

+ func (PodChangeAction) Action()

+ type PodLogAction struct

+ Log []byte

+ ManifestName model.ManifestName

+ PodID k8s.PodID

+ func (PodLogAction) Action()

+ type PodLogActionWriter struct

+ func (w PodLogActionWriter) Write(p []byte) (n int, err error)

+ type PodLogManager struct

+ func NewPodLogManager(kClient k8s.Client) *PodLogManager

+ func (m *PodLogManager) OnChange(ctx context.Context, st *store.Store)

+ type PodLogWatch struct

+ type PodWatcher struct

+ func NewPodWatcher(kCli k8s.Client) *PodWatcher

+ func (w *PodWatcher) OnChange(ctx context.Context, st *store.Store)

+ type PodWatcherMaker func(context.Context, *store.Store) error

+ type PortForwardController struct

+ func NewPortForwardController(kClient k8s.Client) *PortForwardController

+ func (m *PortForwardController) OnChange(ctx context.Context, st *store.Store)

+ type ServiceChangeAction struct

+ Service *v1.Service

+ func NewServiceChangeAction(service *v1.Service) ServiceChangeAction

+ func (ServiceChangeAction) Action()

+ type ServiceWatcher struct

+ func NewServiceWatcher(kCli k8s.Client) *ServiceWatcher

+ func (w *ServiceWatcher) OnChange(ctx context.Context, st *store.Store)

+ type ServiceWatcherMaker func(context.Context, *store.Store) error

+ type SyncletBuildAndDeployer struct

+ func NewSyncletBuildAndDeployer(dd *DeployDiscovery, sm SyncletManager) *SyncletBuildAndDeployer

+ func (sbd *SyncletBuildAndDeployer) BuildAndDeploy(ctx context.Context, manifest model.Manifest, state store.BuildState) (store.BuildResult, error)

+ func (sbd *SyncletBuildAndDeployer) PostProcessBuild(ctx context.Context, result, previousResult store.BuildResult)

+ type SyncletManager struct

+ func NewSyncletManager(kCli k8s.Client) SyncletManager

+ func NewSyncletManagerForTests(kCli k8s.Client, fakeCli synclet.SyncletClient) SyncletManager

+ func (sm SyncletManager) ClientForPod(ctx context.Context, podID k8s.PodID, ns k8s.Namespace) (synclet.SyncletClient, error)

+ func (sm SyncletManager) ForgetPod(ctx context.Context, podID k8s.PodID) error

+ type UpdateMode string

+ var UpdateModeAuto UpdateMode = "auto"

+ var UpdateModeContainer UpdateMode = "container"

+ var UpdateModeImage UpdateMode = "image"

+ var UpdateModeNaive UpdateMode = "naive"

+ var UpdateModeSynclet UpdateMode = "synclet"

+ func ProvideUpdateMode(flag UpdateModeFlag, env k8s.Env) (UpdateMode, error)

+ type UpdateModeFlag UpdateMode

+ type Upper struct

+ func NewUpper(ctx context.Context, b BuildAndDeployer, k8s k8s.Client, ...) Upper

+ func (u Upper) CreateManifests(ctx context.Context, manifests []model.Manifest, watchMounts bool) error

+ func (u Upper) RunHud(ctx context.Context) error

+ type WatchManager struct

+ func NewWatchManager(watcherMaker FsWatcherMaker, timerMaker timerMaker) *WatchManager

+ func (w *WatchManager) OnChange(ctx context.Context, st *store.Store)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL