resources

Documentation

Index

• Constants
• func BindingLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string
• func DispatcherLabels(brokerName string) map[string]string
• 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 NewTriggerDLQ(ctx context.Context, b *eventingv1.Broker, t *eventingv1.Trigger) *rabbitv1beta1.Queue
• func NewTriggerDLQBinding(ctx context.Context, broker *eventingv1.Broker, trigger *eventingv1.Trigger) (*rabbitv1beta1.Binding, error)
• func QueueLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string
• type DispatcherArgs

Constants

const (
	DefaultManagementPort = 15672
	BindingKey            = "x-knative-trigger"
	DLQBindingKey         = "x-knative-dlq"
	TriggerDLQBindingKey  = "x-knative-trigger-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 DispatcherLabels

func DispatcherLabels(brokerName string) map[string]string

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

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 NewTriggerDLQ

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

func NewTriggerDLQBinding

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

NewTriggerDLQBinding creates a binding for a Trigger DLX.

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 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
	DLX                bool
}

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