eventmesh

Documentation

Index

• Variables
• type Reconciler
  • func NewReconciler(client client.Client, logger *logger.Logger, recorder record.EventRecorder, ...) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req kctrl.Request) (kctrl.Result, error)
  • func (r *Reconciler) SetCredentials(credentials *eventmesh.OAuth2ClientCredentials)
  • func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error

Variables

var ErrInvalidSink = errors.New("invalid sink")

Types

type Reconciler

type Reconciler struct {
	client.Client

	Backend eventmesh.Backend
	Domain  string
	// contains filtered or unexported fields
}

Reconciler reconciles a Subscription object.

func NewReconciler

func NewReconciler(client client.Client, logger *logger.Logger, recorder record.EventRecorder,
	cfg env.Config, cleaner cleaner.Cleaner, eventMeshBackend eventmesh.Backend,
	credential *eventmesh.OAuth2ClientCredentials, mapper backendutils.NameMapper,
	subscriptionValidator validator.SubscriptionValidator, collector *metrics.Collector, domain string,
) *Reconciler

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req kctrl.Request) (kctrl.Result, error)

func (*Reconciler) SetCredentials

func (r *Reconciler) SetCredentials(credentials *eventmesh.OAuth2ClientCredentials)

SetCredentials sets the WebhookAuth credentials. WARNING: This functions should be used for testing purposes only.

func (*Reconciler) SetupUnmanaged

func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error

SetupUnmanaged creates a controller under the client control.