resources

Documentation

Index

• func DispatcherLabels(brokerName string) map[string]string
• func DispatcherName(brokerName string) string
• func IngressLabels(brokerName string) map[string]string
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• func MakeIngressDeployment(args *IngressArgs) *appsv1.Deployment
• func MakeIngressService(b *eventingv1.Broker) *corev1.Service
• type DispatcherArgs
• type IngressArgs

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(brokerName string) string

func IngressLabels

func IngressLabels(brokerName string) map[string]string

IngressLabels generates the labels present on all resources representing the ingress 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 MakeIngressDeployment

func MakeIngressDeployment(args *IngressArgs) *appsv1.Deployment

MakeIngressDeployment creates the in-memory representation of the Broker's ingress Deployment.

func MakeIngressService

func MakeIngressService(b *eventingv1.Broker) *corev1.Service

MakeIngressService creates the in-memory representation of the Broker's ingress Service.

Types

type DispatcherArgs

type DispatcherArgs struct {
	Delivery *eventingduckv1.DeliverySpec
	Broker   *eventingv1.Broker
	Image    string
	//ServiceAccountName string
	RabbitMQSecretName   string
	RabbitMQCASecretName string
	RabbitMQVhost        string
	QueueName            string
	BrokerUrlSecretKey   string
	BrokerIngressURL     *apis.URL
	Subscriber           *duckv1.Addressable
	DLX                  bool
	Configs              reconcilersource.ConfigAccessor
	ResourceRequirements corev1.ResourceRequirements
}

DispatcherArgs are the arguments to create a Broker's Dispatcher Deployment that handles DeadLetterSink deliveries.

type IngressArgs

type IngressArgs struct {
	Broker *eventingv1.Broker
	Image  string
	//ServiceAccountName string
	RabbitMQSecretName   string
	RabbitMQCASecretName string
	BrokerUrlSecretKey   string
	RabbitMQVhost        string
	Configs              reconcilersource.ConfigAccessor
	ResourceRequirements corev1.ResourceRequirements
}

IngressArgs are the arguments to create a Broker's ingress Deployment.