v0.41.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 58 Imported by: 0




View Source
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"
View Source
const (
	DeadLetterSinkNotConfigured       = "DeadLetterSinkNotConfigured"
	DeadLetterSinkNotConfiguredReason = "No dead letter sink is configured."
View Source
const BrokerClass = "RabbitMQBroker"
View Source
const (
	ComponentName = "rabbitmq-broker-controller"


This section is empty.


func MarkDLXFailed added in v0.19.0

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

func MarkDLXNotConfigured added in v0.27.0

func MarkDLXNotConfigured(bs *eventingv1.BrokerStatus)

func MarkDLXReady added in v0.19.0

func MarkDLXReady(bs *eventingv1.BrokerStatus)

func MarkDeadLetterSinkFailed added in v0.19.0

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

func MarkDeadLetterSinkNotConfigured added in v0.27.0

func MarkDeadLetterSinkNotConfigured(bs *eventingv1.BrokerStatus)

func MarkDeadLetterSinkReady added in v0.19.0

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 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.


type BrokerOption

type BrokerOption func(*v1.Broker)

BrokerOption enables further configuration of a Broker.

func WithAnnotation added in v0.35.0

func WithAnnotation(key, value string) BrokerOption

func WithBrokerAddress

func WithBrokerAddress(address *duckv1.Addressable) 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

WithBrokerConfig sets the Broker's config KReference.

func WithBrokerDelivery added in v0.19.0

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 WithBrokerUID added in v0.22.0

func WithBrokerUID(uid string) BrokerOption

WithBrokerUID sets the UID for a Broker. Handy for testing ownerrefs.

func WithDLXFailed added in v0.23.0

func WithDLXFailed(reason, msg string) BrokerOption

WithDLXFailed sets DLX condition to failed.

func WithDLXNotConfigured added in v0.27.0

func WithDLXNotConfigured() BrokerOption

WithDLXNotConfigured sets DLX condition to configured.

func WithDLXReady added in v0.19.0

func WithDLXReady() BrokerOption

WithDLXReady sets DLX condition to ready.

func WithDeadLetterSinkFailed added in v0.19.0

func WithDeadLetterSinkFailed(reason, msg string) BrokerOption

WithDeadLetterSinkFailed sets DeadLetterSink condition to failed.

func WithDeadLetterSinkNotConfigured added in v0.27.0

func WithDeadLetterSinkNotConfigured() BrokerOption

WithDeadLetterSinkNotConfigured sets DeadLetterSink condition to ready, but not configured.

func WithDeadLetterSinkReady added in v0.19.0

func WithDeadLetterSinkReady() BrokerOption

WithDeadLetterSinkReady sets DeadLetterSink condition to ready.

func WithDeadLetterSinkResolvedFailed added in v0.27.0

func WithDeadLetterSinkResolvedFailed(reason, msg string) BrokerOption

func WithDeadLetterSinkResolvedNotConfigured added in v0.27.0

func WithDeadLetterSinkResolvedNotConfigured() BrokerOption

func WithDeadLetterSinkResolvedSucceeded added in v0.27.0

func WithDeadLetterSinkResolvedSucceeded(addr *duckv1.Addressable) BrokerOption

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) 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.


Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL