eventing

Documentation

Index

• type CloudEventSourceReconciler
  • func NewCloudEventSourceReconciler(c client.Client, e eventemitter.EventHandler) *CloudEventSourceReconciler
  • func (r *CloudEventSourceReconciler) EnsureEventSourceResourceFinalizer(ctx context.Context, logger logr.Logger, ...) error
  • func (r *CloudEventSourceReconciler) FinalizeEventSourceResource(ctx context.Context, logger logr.Logger, ...) error
  • func (r *CloudEventSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CloudEventSourceReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *CloudEventSourceReconciler) UpdatePromMetricsOnDelete(namespacedName string)

Types

type CloudEventSourceReconciler

type CloudEventSourceReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

CloudEventSourceReconciler reconciles a EventSource object

func NewCloudEventSourceReconciler

func NewCloudEventSourceReconciler(c client.Client, e eventemitter.EventHandler) *CloudEventSourceReconciler

NewCloudEventSourceReconciler creates a new CloudEventSourceReconciler

func (*CloudEventSourceReconciler) EnsureEventSourceResourceFinalizer

func (r *CloudEventSourceReconciler) EnsureEventSourceResourceFinalizer(ctx context.Context, logger logr.Logger, cloudEventSource *eventingv1alpha1.CloudEventSource) error

func (*CloudEventSourceReconciler) FinalizeEventSourceResource

func (r *CloudEventSourceReconciler) FinalizeEventSourceResource(ctx context.Context, logger logr.Logger, cloudEventSource *eventingv1alpha1.CloudEventSource, namespacedName string) error

func (*CloudEventSourceReconciler) Reconcile

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

Reconcile performs reconciliation on the identified EventSource resource based on the request information passed, returns the result and an error (if any).

func (*CloudEventSourceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*CloudEventSourceReconciler) UpdatePromMetricsOnDelete

func (r *CloudEventSourceReconciler) UpdatePromMetricsOnDelete(namespacedName string)

UpdatePromMetricsOnDelete is idempotent, so it can be called multiple times without side-effects