controllers

Documentation

Index

• Variables
• func NewClientBuilder(deferred *DeferredClient) cluster.ClientBuilder
• type ClientBuilder
  • func (b ClientBuilder) Build(cache cache.Cache, config *rest.Config, options client.Options) (client.Client, error)
  • func (b ClientBuilder) WithUncached(objs ...client.Object) cluster.ClientBuilder
• 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)
  • func (c *ControllerBuilder) SetUp(_ context.Context, _ 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)
  • func (m *TiltServerControllerManager) SetUp(ctx context.Context, st store.RStore) error
  • func (m *TiltServerControllerManager) TearDown(_ context.Context)

Variables

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

var WireSet = wire.NewSet(
	NewTiltServerControllerManager,

	v1alpha1.NewScheme,
	NewControllerBuilder,
	NewClientBuilder,

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

	controllerSet,
)

Functions

func NewClientBuilder

func NewClientBuilder(deferred *DeferredClient) cluster.ClientBuilder

Types

type ClientBuilder

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

func (ClientBuilder) Build

func (b ClientBuilder) Build(cache cache.Cache, config *rest.Config, options client.Options) (client.Client, error)

func (ClientBuilder) WithUncached

func (b ClientBuilder) WithUncached(objs ...client.Object) cluster.ClientBuilder

type Controller

type Controller interface {
	reconcile.Reconciler
	SetClient(client ctrlclient.Client)
	SetupWithManager(mgr ctrl.Manager) error
}

func ProvideControllers

func ProvideControllers(
	fileWatch *filewatch.Controller,
	cmds *cmd.Controller,
	podlogstreams *podlogstream.Controller) []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)

func (*ControllerBuilder) SetUp

func (c *ControllerBuilder) SetUp(_ context.Context, _ 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, builder cluster.ClientBuilder) (*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)

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, st store.RStore) error

func (*TiltServerControllerManager) TearDown

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