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, args *BindingArgs) (*rabbitv1beta1.Binding, error)
• func NewPolicy(args *QueueArgs) *rabbitv1beta1.Policy
• func NewQueue(ctx context.Context, args *QueueArgs) *rabbitv1beta1.Queue
• func QueueLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string
• type BindingArgs
• type DispatcherArgs
• type QueueArgs

Constants

const (
	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, args *BindingArgs) (*rabbitv1beta1.Binding, error)

func NewPolicy

func NewPolicy(args *QueueArgs) *rabbitv1beta1.Policy

func NewQueue

func NewQueue(ctx context.Context, args *QueueArgs) *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 {
	Name                     string
	Namespace                string
	RabbitMQClusterName      string
	RabbitMQClusterNamespace string
	Source                   string
	Destination              string
	Owner                    metav1.OwnerReference
	Labels                   map[string]string
	Filters                  map[string]string
	ClusterName              string
}

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
	Configs            reconcilersource.ConfigAccessor
}

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

type QueueArgs

type QueueArgs struct {
	Name                     string
	Namespace                string
	RabbitMQClusterNamespace string
	RabbitMQClusterName      string
	Owner                    metav1.OwnerReference
	Labels                   map[string]string
	DLXName                  *string
}