reconciler

Documentation

Index

• func FindNamedPort(service *corev1.Service, namedPort string) (corev1.ServicePort, bool)
• func ServiceToKey(svcRef v1alpha1.ServiceReference) string
• func SplitKey(key string) types.NamespacedName
• func ToKey(objectMeta *metav1.ObjectMeta) string
• func ToNamespaceName(objectMeta *metav1.ObjectMeta) types.NamespacedName
• type HandleErrorFunc
• type HandleSuccessFunc
• type ReconcilerBase
  • func NewFromManager(mgr manager.Manager) ReconcilerBase
  • func NewReconcilerBase(client client.Client, scheme *runtime.Scheme, restConfig *rest.Config, ...) ReconcilerBase
  • func (r *ReconcilerBase) GetClient() client.Client
  • func (r *ReconcilerBase) GetRecorder() record.EventRecorder
  • func (r *ReconcilerBase) GetRestConfig() *rest.Config
  • func (d *ReconcilerBase) GetSecret(ref *corev1.SecretReference) (corev1.Secret, error)
  • func (r *ReconcilerBase) HandleError(ctx context.Context, objectMeta metav1.ObjectMeta, err error) (ctrl.Result, error)
  • func (r *ReconcilerBase) HandleOutcome(ctx context.Context, objectMeta metav1.ObjectMeta, err error) (ctrl.Result, error)

Functions

func FindNamedPort

func FindNamedPort(service *corev1.Service, namedPort string) (corev1.ServicePort, bool)

func ServiceToKey

func ServiceToKey(svcRef v1alpha1.ServiceReference) string

func SplitKey

func SplitKey(key string) types.NamespacedName

SplitKey will split the Key into a NamespaceName

func ToKey

func ToKey(objectMeta *metav1.ObjectMeta) string

ToKey will return a name from a ObjectMeta in the form of Namespace/Name. If no namespace is present then just Name.

func ToNamespaceName

func ToNamespaceName(objectMeta *metav1.ObjectMeta) types.NamespacedName

Types

type HandleErrorFunc

type HandleErrorFunc func(context.Context, metav1.ObjectMeta, error, time.Duration) (ctrl.Result, error)

type HandleSuccessFunc

type HandleSuccessFunc func(context.Context, metav1.ObjectMeta) (ctrl.Result, error)

type ReconcilerBase

type ReconcilerBase struct {
	OnError   HandleErrorFunc
	OnSuccess HandleSuccessFunc
	// contains filtered or unexported fields
}

func NewFromManager

func NewFromManager(mgr manager.Manager) ReconcilerBase

NewFromManager creates a new ReconcilerBase from a Manager

func NewReconcilerBase

func NewReconcilerBase(client client.Client, scheme *runtime.Scheme, restConfig *rest.Config, recorder record.EventRecorder, apireader client.Reader) ReconcilerBase

func (*ReconcilerBase) GetClient

func (r *ReconcilerBase) GetClient() client.Client

GetClient returns the OperatorSDK client

func (*ReconcilerBase) GetRecorder

func (r *ReconcilerBase) GetRecorder() record.EventRecorder

GetRecorder returns the K8s event recorder for the custom resource

func (*ReconcilerBase) GetRestConfig

func (r *ReconcilerBase) GetRestConfig() *rest.Config

GetRestConfig returns the rest config for the k8s client

func (*ReconcilerBase) GetSecret

func (d *ReconcilerBase) GetSecret(ref *corev1.SecretReference) (corev1.Secret, error)

func (*ReconcilerBase) HandleError

func (r *ReconcilerBase) HandleError(ctx context.Context, objectMeta metav1.ObjectMeta, err error) (ctrl.Result, error)

func (*ReconcilerBase) HandleOutcome

func (r *ReconcilerBase) HandleOutcome(ctx context.Context, objectMeta metav1.ObjectMeta, err error) (ctrl.Result, error)