resources

Documentation

Index

• Constants
• func DispatcherLabels(brokerName string) map[string]string
• func DispatcherName(triggerName string, dlq bool) string
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• type DispatcherArgs

Constants

const (
	ParallelismAnnotation = "rabbitmq.eventing.knative.dev/parallelism"
)

Functions

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 DispatcherName

func DispatcherName(triggerName string, dlq bool) string

func MakeDispatcherDeployment

func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment

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

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

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