resources

Documentation

Index

• Constants
• 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
• type BindingArgs
• type DispatcherArgs
• type QueueArgs

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 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 or from the Triggers DLX to the Triggers DLQ dispatchers queue.

func MakeDispatcherDeployment

func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment

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

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