controllers

Documentation

Index

• func AddManagerIndices(indexer client.FieldIndexer) error
• func RBACGenerateName(account *configv1alpha1.Account) string
• func Register(mgr manager.Manager) error
• func ResyncPeriod() func() time.Duration
• type AccountReconciler
  • func (r *AccountReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AccountReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Context
  • func NewControllerContext(mgr manager.Manager, stopChan <-chan struct{}) *Context
  • func (c *Context) Start()
• type NamespaceEventHandler
  • func (e *NamespaceEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *NamespaceEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *NamespaceEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *NamespaceEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type TemplateInstanceReconciler
  • func (r *TemplateInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TemplateInstanceReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func AddManagerIndices

func AddManagerIndices(indexer client.FieldIndexer) error

AddManagerIndices adds the needed manager indices for faster listing of resources

func RBACGenerateName

func RBACGenerateName(account *configv1alpha1.Account) string

func Register

func Register(mgr manager.Manager) error

Register registers the webhooks to the manager

func ResyncPeriod

func ResyncPeriod() func() time.Duration

ResyncPeriod returns a function which generates a duration each time it is invoked; this is so that multiple controllers don't get into lock-step and all hammer the apiserver with list requests simultaneously.

Types

type AccountReconciler

type AccountReconciler struct {
	client.Client
	Log    loghelper.Logger
	Scheme *runtime.Scheme
}

AccountReconciler reconciles a Account object

func (*AccountReconciler) Reconcile

func (r *AccountReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for an Account object and makes changes based on the state read

func (*AccountReconciler) SetupWithManager

func (r *AccountReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager adds the controller to the manager

type Context

type Context struct {
	// The controller runtime manager
	Manager manager.Manager

	// The global stop chan
	StopChan <-chan struct{}

	// SharedInformers is a generic shared informer factory that is used by multiple controller together, informers
	// stored here are different from informers in the controller-runtime manager, which should be preferred if possible
	SharedInformers informers.SharedInformerFactory

	// ObjectOrMetadataInformers creates generic informers for each group version resource
	ObjectOrMetadataInformers controller.InformerFactory

	// InformersStarted is closed as soon as the informer factories were started
	InformersStarted chan struct{}

	// DiscoveryFunc is able to discover available api resources in the cluster
	DiscoveryFunc func() ([]*metav1.APIResourceList, error)
}

Context holds informations for native kubernetes controllers that need access to a sharedindexfactory

func NewControllerContext

func NewControllerContext(mgr manager.Manager, stopChan <-chan struct{}) *Context

NewControllerContext creates a new controller context

func (*Context) Start

func (c *Context) Start()

Start starts the informer factories

type NamespaceEventHandler

type NamespaceEventHandler struct {
	Log logr.Logger
}

NamespaceEventHandler handles events

func (*NamespaceEventHandler) Create

func (e *NamespaceEventHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

Create implements EventHandler

func (*NamespaceEventHandler) Delete

func (e *NamespaceEventHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

Delete implements EventHandler

func (*NamespaceEventHandler) Generic

func (e *NamespaceEventHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*NamespaceEventHandler) Update

func (e *NamespaceEventHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler

type TemplateInstanceReconciler

type TemplateInstanceReconciler struct {
	client.Client

	Log    loghelper.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

TemplateInstanceReconciler reconciles a template instance object

func (*TemplateInstanceReconciler) Reconcile

func (r *TemplateInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for an Account object and makes changes based on the state read

func (*TemplateInstanceReconciler) SetupWithManager

func (r *TemplateInstanceReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager adds the controller to the manager