source

Documentation

Index

• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• type KogitoSourceSubResourcesReconciler
  • func (kbsrr *KogitoSourceSubResourcesReconciler) Reconcile(ctx context.Context, b psbinding.Bindable) error
  • func (kbsrr *KogitoSourceSubResourcesReconciler) ReconcileDeletion(ctx context.Context, b psbinding.Bindable) error

Functions

func NewController

func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl

NewController for the KogitoSource Bindable interface See: https://github.com/knative/pkg/tree/main/webhook/psbinding for reference

Types

type KogitoSourceSubResourcesReconciler

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

func (*KogitoSourceSubResourcesReconciler) Reconcile

func (kbsrr *KogitoSourceSubResourcesReconciler) Reconcile(ctx context.Context, b psbinding.Bindable) error

Reconcile we try to discover the Sink URI to define it in our Status

func (*KogitoSourceSubResourcesReconciler) ReconcileDeletion

func (kbsrr *KogitoSourceSubResourcesReconciler) ReconcileDeletion(ctx context.Context, b psbinding.Bindable) error