resources

Documentation

Index

• Constants
• func BindingLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string
• func CreateBrokerDeadLetterQueueName(b *eventingv1.Broker) string
• func CreateTriggerQueueName(t *eventingv1.Trigger) string
• func DeclareQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) (wabbit.Queue, error)
• func DeleteQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) error
• func DispatcherLabels(brokerName string) map[string]string
• func MakeBinding(transport http.RoundTripper, args *BindingArgs) error
• func MakeDLQBinding(transport http.RoundTripper, args *BindingArgs) error
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• func NewBinding(ctx context.Context, broker *eventingv1.Broker, trigger *eventingv1.Trigger) (*rabbitv1beta1.Binding, error)
• func NewQueue(ctx context.Context, b *eventingv1.Broker, t *eventingv1.Trigger) *rabbitv1beta1.Queue
• func QueueLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string
• type BindingArgs
• type DispatcherArgs
• type QueueArgs

Constants

const (
	DefaultManagementPort = 15672
	BindingKey            = "x-knative-trigger"
	DLQBindingKey         = "x-knative-dlq"
)

const TriggerLabelKey = "eventing.knative.dev/trigger"

Functions

func BindingLabels

func BindingLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string

BindingLabels generates the labels present on the Queue linking the Broker / Trigger to the Binding.

func CreateBrokerDeadLetterQueueName

func CreateBrokerDeadLetterQueueName(b *eventingv1.Broker) string

func CreateTriggerQueueName

func CreateTriggerQueueName(t *eventingv1.Trigger) string

func DeclareQueue

func DeclareQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) (wabbit.Queue, error)

DeclareQueue declares the Trigger's Queue.

func DeleteQueue

func DeleteQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) error

DeleteQueue deletes the Trigger's Queue.

func DispatcherLabels

func DispatcherLabels(brokerName string) map[string]string

DispatcherLabels generates the labels present on all resources representing the dispatcher of the given Broker.

func MakeBinding

func MakeBinding(transport http.RoundTripper, args *BindingArgs) error

MakeBinding declares the Binding from the Broker's Exchange to the Trigger's Queue.

func MakeDLQBinding

func MakeDLQBinding(transport http.RoundTripper, args *BindingArgs) error

MakeDLQBinding declares the Binding from the Broker's DLX to the DLQ dispatchers Queue.

func MakeDispatcherDeployment

func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment

MakeDispatcherDeployment creates the in-memory representation of the Broker's Dispatcher Deployment.

func NewBinding

func NewBinding(ctx context.Context, broker *eventingv1.Broker, trigger *eventingv1.Trigger) (*rabbitv1beta1.Binding, error)

func NewQueue

func NewQueue(ctx context.Context, b *eventingv1.Broker, t *eventingv1.Trigger) *rabbitv1beta1.Queue

func QueueLabels

func QueueLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string

QueueLabels generates the labels present on the Queue linking the Broker / Trigger to the Queue.

Types

type BindingArgs

type BindingArgs struct {
	Trigger                *eventingv1.Trigger
	Broker                 *eventingv1.Broker // only for DLQ
	BindingName            string
	BindingKey             string
	RoutingKey             string
	SourceName             string
	BrokerURL              string
	RabbitmqManagementPort int
	AdminURL               string
	QueueName              string // only for DLQ
}

BindingArgs are the arguments to create a Trigger's Binding to a RabbitMQ Exchange.

type DispatcherArgs

type DispatcherArgs struct {
	Delivery *eventingduckv1.DeliverySpec
	Trigger  *eventingv1.Trigger
	Image    string
	//ServiceAccountName string
	RabbitMQHost       string
	RabbitMQSecretName string
	QueueName          string
	BrokerUrlSecretKey string
	BrokerIngressURL   *apis.URL
	Subscriber         *apis.URL
}

DispatcherArgs are the arguments to create a dispatcher deployment. There's one of these created for each trigger.

type QueueArgs

type QueueArgs struct {
	QueueName       string
	RabbitmqURL     string
	RabbitmqCluster string
	// If the queue is for Trigger, this holds the trigger so we can create a proper Owner Ref
	Trigger *eventingv1.Trigger
	// If non-empty, wire the queue into this DLX.
	DLX string
}

QueueArgs are the arguments to create a Trigger's RabbitMQ Queue.