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
	RabbitMQCASecretName string
	QueueName            string
	BrokerUrlSecretKey   string
	BrokerIngressURL     *apis.URL
	Subscriber           *apis.URL
	DLX                  bool
	Configs              reconcilersource.ConfigAccessor
	ResourceRequirements corev1.ResourceRequirements
}

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