controllerruntime

Documentation

Index

• func ApplyLabels(parent client.Object, resource client.Object, opts *LabelOpts)
• func ComputeReadyCondition(obj conditions.Setter, t ...string)
• func CreateOrPatch(ctx context.Context, r Reconciler, obj client.Object, ...) error
• func ExtractLabelSelector(resource client.Object) map[string]string
• func FilterLabelSelector(labels map[string]string) map[string]string
• func GetLabelSelector(parent client.Object, opts *LabelOpts) map[string]string
• func GetLabels(parent client.Object, opts *LabelOpts) map[string]string
• func GetResourceName(parent client.Object, suffixes ...string) string
• func IsDependencyNotReady(o conditions.Getter) bool
• func IsImporting(o conditions.Getter) bool
• func LabelOwned(owner client.Object, object client.Object) (*source.Kind, handler.EventHandler, builder.Predicates)
• func ObserveGenerationChange(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, ...) error
• func Patch(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, ...) error
• func SetDependencyCondition(to conditions.Setter, dependencies ...Dependency)
• func SetResourceNamespacedName(parent client.Object, resource client.Object, suffixes ...string)
• type Dependency
• type LabelOpts
• type Object
• type PatchOpts
• type Reconciler
• type Result
  • func Initialize(ctx context.Context, r Reconciler, req ctrl.Request, o Object) (*patch.SerialPatcher, *Result)
  • func InstallJob(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, o Object, ...) *Result
  • func WrapResult(result ctrl.Result, err error) *Result
  • func (r *Result) Unwrap() (ctrl.Result, error)

Functions

func ApplyLabels

func ApplyLabels(parent client.Object, resource client.Object, opts *LabelOpts)

func ComputeReadyCondition

func ComputeReadyCondition(obj conditions.Setter, t ...string)

func CreateOrPatch

func CreateOrPatch(ctx context.Context, r Reconciler, obj client.Object, mutate controllerutil.MutateFn) error

func ExtractLabelSelector

func ExtractLabelSelector(resource client.Object) map[string]string

func FilterLabelSelector

func FilterLabelSelector(labels map[string]string) map[string]string

func GetLabelSelector

func GetLabelSelector(parent client.Object, opts *LabelOpts) map[string]string

func GetLabels

func GetLabels(parent client.Object, opts *LabelOpts) map[string]string

func GetResourceName

func GetResourceName(parent client.Object, suffixes ...string) string

func IsDependencyNotReady

func IsDependencyNotReady(o conditions.Getter) bool

func IsImporting

func IsImporting(o conditions.Getter) bool

func LabelOwned

func LabelOwned(owner client.Object, object client.Object) (*source.Kind, handler.EventHandler, builder.Predicates)

func ObserveGenerationChange

func ObserveGenerationChange(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, o conditions.Setter) error

func Patch

func Patch(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, obj conditions.Setter, opts PatchOpts) error

func SetDependencyCondition

func SetDependencyCondition(to conditions.Setter, dependencies ...Dependency)

func SetResourceNamespacedName

func SetResourceNamespacedName(parent client.Object, resource client.Object, suffixes ...string)

Types

type Dependency

type Dependency interface {
	// client.Object
	conditions.Setter
}

type LabelOpts

type LabelOpts struct {
	Component string
	Version   string
}

type Object

type Object interface {
	conditions.Setter
	GetSuspend() bool
	SetSuspend(bool)
	GetVersion() string
	SetVersion(string)
}

type PatchOpts

type PatchOpts struct {
	DisableReadyCondition           bool
	ReadyNegativePolarityConditions []string
}

type Reconciler

type Reconciler interface {
	client.Client
	Name() string
	OwnedConditions() []string
}

type Result

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

func Initialize

func Initialize(ctx context.Context, r Reconciler, req ctrl.Request, o Object) (*patch.SerialPatcher, *Result)

func InstallJob

func InstallJob(ctx context.Context, r Reconciler, patcher *patch.SerialPatcher, o Object, job *batchv1.Job, version string, f controllerutil.MutateFn) *Result

func WrapResult

func WrapResult(result ctrl.Result, err error) *Result

func (*Result) Unwrap

func (r *Result) Unwrap() (ctrl.Result, error)