broker

Documentation

Index

• Constants
• func MarkDLXFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})
• func MarkDLXReady(bs *eventingv1.BrokerStatus)
• func MarkDeadLetterSinkFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})
• func MarkDeadLetterSinkReady(bs *eventingv1.BrokerStatus)
• func MarkExchangeFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})
• func MarkExchangeReady(bs *eventingv1.BrokerStatus)
• func MarkIngressFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})
• func MarkSecretFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})
• func MarkSecretReady(bs *eventingv1.BrokerStatus)
• func NewBroker(name, namespace string, o ...BrokerOption) *v1.Broker
• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• func PropagateIngressAvailability(bs *eventingv1.BrokerStatus, ep *corev1.Endpoints)
• func SetAddress(bs *eventingv1.BrokerStatus, url *apis.URL)
• func WithBrokerDeletionTimestamp(b *v1.Broker)
• func WithBrokerReady(b *v1.Broker)
• func WithInitBrokerConditions(b *v1.Broker)
• type BrokerOption
  • func WithBrokerAddress(address string) BrokerOption
  • func WithBrokerAddressURI(uri *apis.URL) BrokerOption
  • func WithBrokerClass(bc string) BrokerOption
  • func WithBrokerConfig(config *duckv1.KReference) BrokerOption
  • func WithBrokerDelivery(d *eventingduckv1.DeliverySpec) BrokerOption
  • func WithBrokerFinalizers(finalizers ...string) BrokerOption
  • func WithBrokerGeneration(gen int64) BrokerOption
  • func WithBrokerResourceVersion(rv string) BrokerOption
  • func WithBrokerStatusObservedGeneration(gen int64) BrokerOption
  • func WithDLXReady() BrokerOption
  • func WithDeadLetterSinkFailed(reason, msg string) BrokerOption
  • func WithDeadLetterSinkReady() BrokerOption
  • func WithExchangeFailed(reason, msg string) BrokerOption
  • func WithExchangeReady() BrokerOption
  • func WithIngressAvailable() BrokerOption
  • func WithIngressFailed(reason, msg string) BrokerOption
  • func WithSecretFailed(reason, msg string) BrokerOption
  • func WithSecretReady() BrokerOption
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, b *eventingv1.Broker) pkgreconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, b *eventingv1.Broker) pkgreconciler.Event
• type ReconcilerArgs

Constants

const (
	BrokerConditionExchange       apis.ConditionType = "ExchangeReady"
	BrokerConditionDLX            apis.ConditionType = "DLXReady"
	BrokerConditionDeadLetterSink apis.ConditionType = "DeadLetterSinkReady"
	BrokerConditionSecret         apis.ConditionType = "SecretReady"
	BrokerConditionIngress        apis.ConditionType = "IngressReady"
	BrokerConditionAddressable    apis.ConditionType = "Addressable"
)

Functions

func MarkDLXFailed

func MarkDLXFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})

func MarkDLXReady

func MarkDLXReady(bs *eventingv1.BrokerStatus)

func MarkDeadLetterSinkFailed

func MarkDeadLetterSinkFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})

func MarkDeadLetterSinkReady

func MarkDeadLetterSinkReady(bs *eventingv1.BrokerStatus)

func MarkExchangeFailed

func MarkExchangeFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})

func MarkExchangeReady

func MarkExchangeReady(bs *eventingv1.BrokerStatus)

func MarkIngressFailed

func MarkIngressFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})

func MarkSecretFailed

func MarkSecretFailed(bs *eventingv1.BrokerStatus, reason, format string, args ...interface{})

func MarkSecretReady

func MarkSecretReady(bs *eventingv1.BrokerStatus)

func NewBroker

func NewBroker(name, namespace string, o ...BrokerOption) *v1.Broker

NewBroker creates a Broker with BrokerOptions.

func NewController

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

NewController initializes the controller and is called by the generated code Registers event handlers to enqueue events

func PropagateIngressAvailability

func PropagateIngressAvailability(bs *eventingv1.BrokerStatus, ep *corev1.Endpoints)

func SetAddress

func SetAddress(bs *eventingv1.BrokerStatus, url *apis.URL)

SetAddress makes this Broker addressable by setting the URI. It also sets the BrokerConditionAddressable to true.

func WithBrokerDeletionTimestamp

func WithBrokerDeletionTimestamp(b *v1.Broker)

func WithBrokerReady

func WithBrokerReady(b *v1.Broker)

WithBrokerReady sets .Status to ready.

func WithInitBrokerConditions

func WithInitBrokerConditions(b *v1.Broker)

WithInitBrokerConditions initializes the Broker's conditions.

Types

type BrokerOption

type BrokerOption func(*v1.Broker)

BrokerOption enables further configuration of a Broker.

func WithBrokerAddress

func WithBrokerAddress(address string) BrokerOption

WithBrokerAddress sets the Broker's address.

func WithBrokerAddressURI

func WithBrokerAddressURI(uri *apis.URL) BrokerOption

WithBrokerAddressURI sets the Broker's address as URI.

func WithBrokerClass

func WithBrokerClass(bc string) BrokerOption

func WithBrokerConfig

func WithBrokerConfig(config *duckv1.KReference) BrokerOption

WithBrokerChannel sets the Broker's ChannelTemplateSpec to the specified CRD.

func WithBrokerDelivery

func WithBrokerDelivery(d *eventingduckv1.DeliverySpec) BrokerOption

func WithBrokerFinalizers

func WithBrokerFinalizers(finalizers ...string) BrokerOption

func WithBrokerGeneration

func WithBrokerGeneration(gen int64) BrokerOption

func WithBrokerResourceVersion

func WithBrokerResourceVersion(rv string) BrokerOption

func WithBrokerStatusObservedGeneration

func WithBrokerStatusObservedGeneration(gen int64) BrokerOption

func WithDLXReady

func WithDLXReady() BrokerOption

WithDLXReady() sets DLX condition to ready.

func WithDeadLetterSinkFailed

func WithDeadLetterSinkFailed(reason, msg string) BrokerOption

WithDeadLetterSinkFailed sets secret condition to ready.

func WithDeadLetterSinkReady

func WithDeadLetterSinkReady() BrokerOption

WithDeadLetterSinkReady() sets DeadLetterSink condition to ready.

func WithExchangeFailed

func WithExchangeFailed(reason, msg string) BrokerOption

WithExchangeFailed sets exchange condition to failed.

func WithExchangeReady

func WithExchangeReady() BrokerOption

WithExchangeReady sets exchange condition to ready.

func WithIngressAvailable

func WithIngressAvailable() BrokerOption

func WithIngressFailed

func WithIngressFailed(reason, msg string) BrokerOption

WithIngressFailed calls .Status.MarkIngressFailed on the Broker.

func WithSecretFailed

func WithSecretFailed(reason, msg string) BrokerOption

WithSecretFailed sets secret condition to ready.

func WithSecretReady

func WithSecretReady() BrokerOption

WithSecretReady sets secret condition to ready.

type Reconciler

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

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, b *eventingv1.Broker) pkgreconciler.Event

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, b *eventingv1.Broker) pkgreconciler.Event

type ReconcilerArgs

type ReconcilerArgs struct {
	IngressImage              string
	IngressServiceAccountName string
}

ReconcilerArgs are the arguments needed to create a broker.Reconciler.