resources

Documentation

Index

• Constants
• func DeclareQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) (wabbit.Queue, error)
• func DeleteQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) error
• func DispatcherLabels(brokerName string) map[string]string
• func ExchangeName(brokerName string) string
• func MakeBinding(transport http.RoundTripper, args *BindingArgs) error
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• type BindingArgs
• type DispatcherArgs
• type QueueArgs

Constants

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

Functions

func DeclareQueue

func DeclareQueue(dialerFunc dialer.DialerFunc, args *QueueArgs) (wabbit.Queue, error)

DeclareQueue declares the Trigger's Queue.

func DeleteQueue

func DeleteQueue(dialerFunc dialer.DialerFunc, 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(transport http.RoundTripper, 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.

Types

type BindingArgs

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

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

type DispatcherArgs

type DispatcherArgs struct {
	Trigger *eventingv1.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 QueueArgs

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

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