broker

package
v0.35.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

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 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 WithAnnotation added in v0.35.0 

func WithAnnotation(key, value string) BrokerOption

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

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(uri *apis.URL) 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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.