controllers

package
v0.20.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrClientNotInitialized = errors.New("controller client not initialized")
View Source 
var WireSet = wire.NewSet(
	NewTiltServerControllerManager,

	v1alpha1.NewScheme,
	NewControllerBuilder,
	NewClientBuilder,

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

	cmd.WireSet,
	controllerSet,
	uiresource.WireSet,
	uisession.WireSet,
)

Functions

func NewClientBuilder added in v0.19.0 

func NewClientBuilder(deferred *DeferredClient) cluster.ClientBuilder

Types

type ClientBuilder added in v0.19.0 

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

func (ClientBuilder) Build added in v0.19.0 

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

func (ClientBuilder) WithUncached added in v0.19.0 

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

type Controller added in v0.18.12 

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

func ProvideControllers added in v0.18.12 

func ProvideControllers(
	fileWatch *filewatch.Controller,
	cmds *cmd.Controller,
	podlogstreams *podlogstream.Controller,
	kubernetesDiscovery *kubernetesdiscovery.Reconciler,
	uis *uisession.Reconciler,
	uir *uiresource.Reconciler) []Controller

type ControllerBuilder added in v0.18.12 

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

func NewControllerBuilder added in v0.18.12 

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

func (*ControllerBuilder) OnChange added in v0.18.12 

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

func (*ControllerBuilder) SetUp added in v0.18.12 

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

func (*ControllerBuilder) TearDown added in v0.19.0 

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

type DeferredClient added in v0.19.0 

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

func ProvideDeferredClient added in v0.19.0 

func ProvideDeferredClient() *DeferredClient

func (*DeferredClient) Create added in v0.19.0 

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

func (*DeferredClient) Delete added in v0.19.0 

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

func (*DeferredClient) DeleteAllOf added in v0.19.0 

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

func (*DeferredClient) Get added in v0.19.0 

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

func (*DeferredClient) List added in v0.19.0 

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

func (*DeferredClient) Patch added in v0.19.0 

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

func (*DeferredClient) RESTMapper added in v0.19.0 

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

func (*DeferredClient) Scheme added in v0.19.0 

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

func (*DeferredClient) Status added in v0.19.0 

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

func (*DeferredClient) Update added in v0.19.0 

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 added in v0.18.12 

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

func (*TiltServerControllerManager) GetManager added in v0.18.12 

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)

Source Files

View all Source files

Directories

Path Synopsis
core
cmd
filewatch
filewatch/fsevent
kubernetesdiscovery
podlogstream
portforward
uiresource
uisession

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.