Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckEvent

func CheckEvent(target, eventType, eventTypeVersion string, retryOptions ...retry.Option) error

func CreateApplication

func CreateApplication(appConnectorInterface appconnectorclientset.Interface, name string, applicationOptions ...ApplicationOption) error

func CreateApplicationMapping

func CreateApplicationMapping(appBroker appbrokerclientset.Interface, name, namespace string) error

func CreateServiceInstance

func CreateServiceInstance(serviceCatalogInterface servicecatalogclientset.Interface, serviceId, namespace string) error

func CreateSubscriber

func CreateSubscriber(k8s k8s.Interface, name, namespace string, subscriberOptions ...SubscriberOption) error

func CreateTrigger

func CreateTrigger(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, name, namespace string, triggeroptions ...TriggerOption) error

func DeleteBroker

func DeleteBroker(eventingInf eventingclientv1alpha1.EventingV1alpha1Interface, name, namespace string, retryOptions ...retry.Option) error

func RemoveBrokerInjectionLabel

func RemoveBrokerInjectionLabel(k8sInf kubernetes.Interface, namespace string, retryOptions ...retry.Option) error

func SendEvent

func SendEvent(target, eventType, eventTypeVersion string) error

func WaitForApplication

func WaitForApplication(appConnector appconnectorclientset.Interface, messaging messagingv1alpha1clientset.MessagingV1alpha1Interface, serving servingclientset.Interface, name string, retryOptions ...retry.Option) error

func WaitForBroker

func WaitForBroker(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, name, namespace string, retryOptions ...retry.Option) error

func WaitForChannel

func WaitForChannel(messaging messagingv1alpha1clientset.MessagingV1alpha1Interface, name, namespace string, retryOptions ...retry.Option) error

func WaitForHttpSource

func WaitForHttpSource(serving servingclientset.Interface, name, namespace string, retryOptions ...retry.Option) error

func WaitForServiceInstance

func WaitForServiceInstance(serviceCatalog servicecatalogclientset.Interface, name, namespace string, retryOptions ...retry.Option) error

func WaitForSubscriber

func WaitForSubscriber(k8s k8s.Interface, name, namespace string) error

func WaitForTrigger

func WaitForTrigger(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, subName, namespace string, retryOptions ...retry.Option) error

Types

type ApplicationOption

type ApplicationOption func(*appconnectorv1alpha1.Application)

func WithAccessLabel

func WithAccessLabel(label string) ApplicationOption

func WithEventService

func WithEventService(id string) ApplicationOption

type SubscriberOption

type SubscriberOption func(deployment *appsv1.Deployment)

type TriggerOption

type TriggerOption func(trigger *v1alpha1.Trigger)

func WithFilter

func WithFilter(eventTypeVersion, eventType, source string) TriggerOption

func WithURISubscriber

func WithURISubscriber(target string) TriggerOption