webhooksource

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc adapter.EnvConfigAccessor, ...) adapter.Adapter
• func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl
• func NewEnvConfig() adapter.EnvConfigAccessor
• type ExtensionAttributesFrom
  • func (ea *ExtensionAttributesFrom) Decode(value string) error
• type MTAdapter
• type Reconciler
  • func (r *Reconciler) ReconcileKind(ctx context.Context, source *sourcesalphav1.WebhookSource) reconciler.Event

Functions

func NewAdapter

func NewAdapter(ctx context.Context, envAcc adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter

NewAdapter satisfies pkgadapter.AdapterConstructor.

func NewController

func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl

NewController ...

func NewEnvConfig

func NewEnvConfig() adapter.EnvConfigAccessor

NewEnvConfig satisfies pkgadapter.EnvConfigConstructor.

Types

type ExtensionAttributesFrom

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

ExtensionAttributesFrom defines the HTTP elements that should be used to populate CloudEvent extension attributes.

func (*ExtensionAttributesFrom) Decode

func (ea *ExtensionAttributesFrom) Decode(value string) error

Decode an array of KeyMountedValues

type MTAdapter

type MTAdapter interface {
	// Update is called when the source is ready and when the specification and/or status has changed.
	Update(ctx context.Context, source *sourcesalphav1.WebhookSource)

	// Remove is called when the source has been deleted.
	Remove(source *sourcesalphav1.WebhookSource)

	// RemoveAll is called when the adapter stopped leading
	RemoveAll(ctx context.Context)
}

MTAdapter is the interface the multi-tenant webhook adapter must implement.

type Reconciler

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

Reconciler reconciles WebhookSources

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, source *sourcesalphav1.WebhookSource) reconciler.Event