controllers

Documentation

Index

• Variables
• type Controller
  • func ProvideControllers(fileWatch *filewatch.Controller, cmds *cmd.Controller, ...) []Controller
• type ControllerBuilder
  • func NewControllerBuilder(tscm *TiltServerControllerManager, controllers []Controller) *ControllerBuilder
  • func (c *ControllerBuilder) OnChange(_ context.Context, _ store.RStore, _ store.ChangeSummary) error
  • func (c *ControllerBuilder) SetUp(ctx context.Context, st store.RStore) error
  • func (c *ControllerBuilder) TearDown(ctx context.Context)
• type DeferredClient
  • func ProvideDeferredClient() *DeferredClient
  • func (d *DeferredClient) Create(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.CreateOption) error
  • func (d *DeferredClient) Delete(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.DeleteOption) error
  • func (d *DeferredClient) DeleteAllOf(ctx context.Context, obj ctrlclient.Object, ...) error
  • func (d *DeferredClient) Get(ctx context.Context, key ctrlclient.ObjectKey, obj ctrlclient.Object) error
  • func (d *DeferredClient) List(ctx context.Context, list ctrlclient.ObjectList, opts ...ctrlclient.ListOption) error
  • func (d *DeferredClient) Patch(ctx context.Context, obj ctrlclient.Object, patch ctrlclient.Patch, ...) error
  • func (d *DeferredClient) RESTMapper() meta.RESTMapper
  • func (d *DeferredClient) Scheme() *runtime.Scheme
  • func (d *DeferredClient) Status() ctrlclient.StatusWriter
  • func (d *DeferredClient) Update(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.UpdateOption) error
• type TiltServerControllerManager
  • func NewTiltServerControllerManager(config *server.APIServerConfig, scheme *runtime.Scheme, ...) (*TiltServerControllerManager, error)
  • func (m *TiltServerControllerManager) GetClient() ctrlclient.Client
  • func (m *TiltServerControllerManager) GetManager() ctrl.Manager
  • func (m *TiltServerControllerManager) OnChange(_ context.Context, _ store.RStore, _ store.ChangeSummary) error
  • func (m *TiltServerControllerManager) SetUp(ctx context.Context, _ store.RStore) error
  • func (m *TiltServerControllerManager) TearDown(_ context.Context)
• type UncachedObjects
  • func ProvideUncachedObjects() UncachedObjects

Variables

var ErrClientNotInitialized = errors.New("controller client not initialized")

var WireSet = wire.NewSet(
	NewTiltServerControllerManager,

	NewControllerBuilder,
	ProvideUncachedObjects,

	ProvideDeferredClient,
	wire.Bind(new(ctrlclient.Client), new(*DeferredClient)),

	cmd.WireSet,
	controllerSet,
	uiresource.WireSet,
	uisession.WireSet,
	uibutton.WireSet,
	tiltfile.WireSet,
	extensionrepo.WireSet,
	extension.WireSet,
)

Types

type Controller

type Controller interface {
	reconcile.Reconciler
	CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)
}

func ProvideControllers

func ProvideControllers(
	fileWatch *filewatch.Controller,
	cmds *cmd.Controller,
	podlogstreams *podlogstream.Controller,
	kubernetesDiscovery *kubernetesdiscovery.Reconciler,
	kubernetesApply *kubernetesapply.Reconciler,
	uis *uisession.Reconciler,
	uir *uiresource.Reconciler,
	uib *uibutton.Reconciler,
	pfr *portforward.Reconciler,
	tfr *tiltfile.Reconciler,
	extr *extension.Reconciler,
	extrr *extensionrepo.Reconciler) []Controller

type ControllerBuilder

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

func NewControllerBuilder

func NewControllerBuilder(tscm *TiltServerControllerManager, controllers []Controller) *ControllerBuilder

func (*ControllerBuilder) OnChange

func (c *ControllerBuilder) OnChange(_ context.Context, _ store.RStore, _ store.ChangeSummary) error

func (*ControllerBuilder) SetUp

func (c *ControllerBuilder) SetUp(ctx context.Context, st store.RStore) error

func (*ControllerBuilder) TearDown

func (c *ControllerBuilder) TearDown(ctx context.Context)

type DeferredClient

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

func ProvideDeferredClient

func ProvideDeferredClient() *DeferredClient

func (*DeferredClient) Create

func (d *DeferredClient) Create(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.CreateOption) error

func (*DeferredClient) Delete

func (d *DeferredClient) Delete(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.DeleteOption) error

func (*DeferredClient) DeleteAllOf

func (d *DeferredClient) DeleteAllOf(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.DeleteAllOfOption) error

func (*DeferredClient) Get

func (d *DeferredClient) Get(ctx context.Context, key ctrlclient.ObjectKey, obj ctrlclient.Object) error

func (*DeferredClient) List

func (d *DeferredClient) List(ctx context.Context, list ctrlclient.ObjectList, opts ...ctrlclient.ListOption) error

func (*DeferredClient) Patch

func (d *DeferredClient) Patch(ctx context.Context, obj ctrlclient.Object, patch ctrlclient.Patch, opts ...ctrlclient.PatchOption) error

func (*DeferredClient) RESTMapper

func (d *DeferredClient) RESTMapper() meta.RESTMapper

func (*DeferredClient) Scheme

func (d *DeferredClient) Scheme() *runtime.Scheme

func (*DeferredClient) Status

func (d *DeferredClient) Status() ctrlclient.StatusWriter

func (*DeferredClient) Update

func (d *DeferredClient) Update(ctx context.Context, obj ctrlclient.Object, opts ...ctrlclient.UpdateOption) error

type TiltServerControllerManager

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

func NewTiltServerControllerManager

func NewTiltServerControllerManager(config *server.APIServerConfig, scheme *runtime.Scheme, deferredClient *DeferredClient, uncachedObjects UncachedObjects) (*TiltServerControllerManager, error)

func (*TiltServerControllerManager) GetClient

func (m *TiltServerControllerManager) GetClient() ctrlclient.Client

func (*TiltServerControllerManager) GetManager

func (m *TiltServerControllerManager) GetManager() ctrl.Manager

func (*TiltServerControllerManager) OnChange

func (m *TiltServerControllerManager) OnChange(_ context.Context, _ store.RStore, _ store.ChangeSummary) error

OnChange is a no-op but used to get initialized in upper along with the API server

func (*TiltServerControllerManager) SetUp

func (m *TiltServerControllerManager) SetUp(ctx context.Context, _ store.RStore) error

func (*TiltServerControllerManager) TearDown

func (m *TiltServerControllerManager) TearDown(_ context.Context)

type UncachedObjects

type UncachedObjects []ctrlclient.Object

func ProvideUncachedObjects

func ProvideUncachedObjects() UncachedObjects