resources

package

v0.41.0 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/knative-extensions/eventing-rabbitmq

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

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 ¶ added in v0.34.0

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

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

Source Files ¶

View all Source files

dispatcher.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL