controllers

Documentation

Index

• Constants
• func CreateScheme() *runtime.Scheme
• func GetKnownStorageTypes() []client.Object
• func GetKnownTypes() []client.Object
• func MakeResourceGVKLookup(mgr ctrl.Manager, objs []client.Object) (map[schema.GroupKind]schema.GroupVersionKind, error)
• func NewRateLimiter(minBackoff time.Duration, maxBackoff time.Duration) workqueue.RateLimiter
• func RegisterAll(mgr ctrl.Manager, clientFactory ARMClientFactory, objs []client.Object, ...) error
• func RegisterWebhooks(mgr ctrl.Manager, objs []client.Object) error
• type ARMClientFactory
• type GenericReconciler
  • func (gr *GenericReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type LoggerFactory
• type Options

Constants

const NamespaceAnnotation = "serviceoperator.azure.com/operator-namespace"

NamespaceAnnotation defines the annotation name to use when marking a resource with the namespace of the managing operator.

Functions

func CreateScheme

func CreateScheme() *runtime.Scheme

func GetKnownStorageTypes

func GetKnownStorageTypes() []client.Object

func GetKnownTypes

func GetKnownTypes() []client.Object

func MakeResourceGVKLookup

func MakeResourceGVKLookup(mgr ctrl.Manager, objs []client.Object) (map[schema.GroupKind]schema.GroupVersionKind, error)

MakeResourceGVKLookup creates a map of schema.GroupKind to schema.GroupVersionKind. This can be used to look up the version of a GroupKind that is being reconciled.

func NewRateLimiter

func NewRateLimiter(minBackoff time.Duration, maxBackoff time.Duration) workqueue.RateLimiter

NewRateLimiter creates a new workqueue.Ratelimiter for use controlling the speed of reconciliation. It throttles individual requests exponentially and also controls for multiple requests.

func RegisterAll

func RegisterAll(mgr ctrl.Manager, clientFactory ARMClientFactory, objs []client.Object, options Options) error

func RegisterWebhooks

func RegisterWebhooks(mgr ctrl.Manager, objs []client.Object) error

Types

type ARMClientFactory

type ARMClientFactory func(genruntime.MetaObject) *genericarmclient.GenericClient

type GenericReconciler

type GenericReconciler struct {
	LoggerFactory        LoggerFactory
	ARMClientFactory     ARMClientFactory
	KubeClient           *kubeclient.Client
	ResourceResolver     *genruntime.Resolver
	Recorder             record.EventRecorder
	Name                 string
	Config               config.Values
	GVK                  schema.GroupVersionKind
	RequeueDelayOverride time.Duration
	PositiveConditions   *conditions.PositiveConditionBuilder
}

GenericReconciler reconciles resources

func (*GenericReconciler) Reconcile

func (gr *GenericReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile will take state in K8s and apply it to Azure

type LoggerFactory

type LoggerFactory func(genruntime.MetaObject) logr.Logger

type Options

type Options struct {
	controller.Options

	// options specific to our controller
	RequeueDelay  time.Duration
	Config        config.Values
	LoggerFactory func(obj metav1.Object) logr.Logger
}