controllers

Documentation

Index

• type CustomMatcher
• type EnqueueRequestsForCustomIndexField
  • func (e *EnqueueRequestsForCustomIndexField) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestsForCustomIndexField) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestsForCustomIndexField) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestsForCustomIndexField) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type ImageStreamMatcher
  • func (i *ImageStreamMatcher) Match(imageStreamTag metav1.Object) ([]openlibertyv1beta2.OpenLibertyApplication, error)
• type ReconcileOpenLiberty
  • func (r *ReconcileOpenLiberty) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *ReconcileOpenLiberty) SetupWithManager(mgr ctrl.Manager) error
• type ReconcileOpenLibertyDump
  • func (r *ReconcileOpenLibertyDump) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *ReconcileOpenLibertyDump) SetupWithManager(mgr ctrl.Manager) error
• type ReconcileOpenLibertyTrace
  • func (r *ReconcileOpenLibertyTrace) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *ReconcileOpenLibertyTrace) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ReconcileOpenLibertyTrace) UpdateStatus(issue error, conditionType openlibertyv1beta2.OperationStatusConditionType, ...) (reconcile.Result, error)

Types

type CustomMatcher

type CustomMatcher interface {
	Match(metav1.Object) ([]openlibertyv1beta2.OpenLibertyApplication, error)
}

CustomMatcher is an interface for matching apps that satisfy a custom logic

type EnqueueRequestsForCustomIndexField

type EnqueueRequestsForCustomIndexField struct {
	handler.Funcs
	Matcher CustomMatcher
}

EnqueueRequestsForCustomIndexField enqueues reconcile Requests for OpenLiberty Applications if the app is relying on the modified resource

func (*EnqueueRequestsForCustomIndexField) Create

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

Create implements EventHandler

func (*EnqueueRequestsForCustomIndexField) Delete

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

Delete implements EventHandler

func (*EnqueueRequestsForCustomIndexField) Generic

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

Generic implements EventHandler

func (*EnqueueRequestsForCustomIndexField) Update

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

Update implements EventHandler

type ImageStreamMatcher

type ImageStreamMatcher struct {
	Klient          client.Client
	WatchNamespaces []string
}

ImageStreamMatcher implements CustomMatcher for Image Streams

func (*ImageStreamMatcher) Match

func (i *ImageStreamMatcher) Match(imageStreamTag metav1.Object) ([]openlibertyv1beta2.OpenLibertyApplication, error)

Match returns all applications using the input ImageStreamTag

type ReconcileOpenLiberty

type ReconcileOpenLiberty struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	oputils.ReconcilerBase
	Log logr.Logger
	// contains filtered or unexported fields
}

ReconcileOpenLiberty reconciles a OpenLiberty object

func (*ReconcileOpenLiberty) Reconcile

func (r *ReconcileOpenLiberty) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ReconcileOpenLiberty) SetupWithManager

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

type ReconcileOpenLibertyDump

type ReconcileOpenLibertyDump struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client     client.Client
	Scheme     *runtime.Scheme
	Recorder   record.EventRecorder
	RestConfig *rest.Config
	Log        logr.Logger
}

ReconcileOpenLibertyDump reconciles a OpenLibertyDump object

func (*ReconcileOpenLibertyDump) Reconcile

func (r *ReconcileOpenLibertyDump) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*ReconcileOpenLibertyDump) SetupWithManager

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

type ReconcileOpenLibertyTrace

type ReconcileOpenLibertyTrace struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client     client.Client
	Scheme     *runtime.Scheme
	Recorder   record.EventRecorder
	RestConfig *rest.Config
	Log        logr.Logger
}

ReconcileOpenLibertyTrace reconciles a OpenLibertyTrace object

func (*ReconcileOpenLibertyTrace) Reconcile

func (r *ReconcileOpenLibertyTrace) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*ReconcileOpenLibertyTrace) SetupWithManager

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

func (*ReconcileOpenLibertyTrace) UpdateStatus

func (r *ReconcileOpenLibertyTrace) UpdateStatus(issue error, conditionType openlibertyv1beta2.OperationStatusConditionType, instance openlibertyv1beta2.OpenLibertyTrace, newStatus corev1.ConditionStatus, podName string, podChanged bool) (reconcile.Result, error)

UpdateStatus updates the status