resources

Documentation

Index

• Constants
• func DeclareQueue(args *QueueArgs) (*amqp.Queue, error)
• func DeleteQueue(args *QueueArgs) error
• func DispatcherLabels(brokerName string) map[string]string
• func ExchangeName(brokerName string) string
• func MakeBinding(args *BindingArgs) error
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• func MakeDispatcherScaledObject(args *DispatcherScaledObjectArgs) *kedav1alpha1.ScaledObject
• type BindingArgs
• type DispatcherArgs
• type DispatcherScaledObjectArgs
• type QueueArgs

Constants

const (
	DefaultManagementPort = 15672
	BindingKey            = "x-knative-trigger"
)

Functions

func DeclareQueue

func DeclareQueue(args *QueueArgs) (*amqp.Queue, error)

DeclareQueue declares the Trigger's Queue.

func DeleteQueue

func DeleteQueue(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 ExchangeName

func ExchangeName(brokerName string) string

ExchangeName derives the Exchange name from the Broker name

func MakeBinding

func MakeBinding(args *BindingArgs) error

MakeBinding declares the Binding from the Broker's Exchange to the Trigger's Queue.

func MakeDispatcherDeployment

func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment

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

func MakeDispatcherScaledObject

func MakeDispatcherScaledObject(args *DispatcherScaledObjectArgs) *kedav1alpha1.ScaledObject

Types

type BindingArgs

type BindingArgs struct {
	Trigger                *eventingv1beta1.Trigger
	RoutingKey             string
	BrokerURL              string
	RabbitmqManagementPort int
}

BindingArgs are the arguments to create a Trigger's Binding to a RabbitMQ Exchange.

type DispatcherArgs

type DispatcherArgs struct {
	Trigger *eventingv1beta1.Trigger
	Image   string
	//ServiceAccountName string
	RabbitMQHost       string
	RabbitMQSecretName string
	QueueName          string
	BrokerUrlSecretKey string
	BrokerIngressURL   *apis.URL
	Subscriber         *apis.URL
}

DispatcherArgs are the arguments to create a Broker's Dispatcher Deployment.

type DispatcherScaledObjectArgs

type DispatcherScaledObjectArgs struct {
	DispatcherDeployment      *v1.Deployment
	QueueName                 string
	Trigger                   *v1beta1.Trigger
	BrokerUrlSecretKey        string
	TriggerAuthenticationName string
}

type QueueArgs

type QueueArgs struct {
	Trigger     *eventingv1beta1.Trigger
	RabbitmqURL string
}

QueueArgs are the arguments to create a Trigger's RabbitMQ Queue.