Documentation
¶
Index ¶
- func CheckEvent(target string, statusCode int, retryOptions ...retry.Option) error
- func CreateApplication(appConnectorInterface appconnectorclientset.Interface, name string, ...) error
- func CreateApplicationMapping(appBroker appbrokerclientset.Interface, name, namespace string) error
- func CreateServiceInstance(serviceCatalogInterface servicecatalogclientset.Interface, ...) error
- func CreateSubscriber(k8s k8s.Interface, name, namespace string, ...) error
- func CreateTrigger(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, ...) error
- func DeleteBroker(eventingInf eventingclientv1alpha1.EventingV1alpha1Interface, ...) error
- func RemoveBrokerInjectionLabel(k8sInf kubernetes.Interface, namespace string, retryOptions ...retry.Option) error
- func SendEvent(target, eventType, eventTypeVersion string) error
- func WaitForApplication(appConnector appconnectorclientset.Interface, ...) error
- func WaitForBroker(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, ...) error
- func WaitForChannel(messaging messagingv1alpha1clientset.MessagingV1alpha1Interface, ...) error
- func WaitForHttpSource(sources sourcesv1alpha1.SourcesV1alpha1Interface, name, namespace string, ...) error
- func WaitForServiceInstance(serviceCatalog servicecatalogclientset.Interface, name, namespace string, ...) error
- func WaitForSubscriber(k8s k8s.Interface, name, namespace string) error
- func WaitForSubscriptionReady(dynamicClient dynamic.Interface, name, namespace string, ...) error
- func WaitForTrigger(eventingCli eventingclientv1alpha1.EventingV1alpha1Interface, ...) error
- type ApplicationOption
- type SubscriberOption
- type TriggerOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckEvent ¶
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 WaitForApplication ¶
func WaitForApplication(appConnector appconnectorclientset.Interface, messaging messagingv1alpha1clientset.MessagingV1alpha1Interface, sources sourcesv1alpha1.SourcesV1alpha1Interface, 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(sources sourcesv1alpha1.SourcesV1alpha1Interface, name, namespace string, retryOptions ...retry.Option) error
func WaitForServiceInstance ¶
func WaitForServiceInstance(serviceCatalog servicecatalogclientset.Interface, name, namespace string, retryOptions ...retry.Option) 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)
func WithSubscriberImage ¶
func WithSubscriberImage(image string) SubscriberOption
type TriggerOption ¶
func WithFilter ¶
func WithFilter(eventTypeVersion, eventType, source string) TriggerOption
func WithURISubscriber ¶
func WithURISubscriber(target string) TriggerOption
Source Files
Click to show internal directories.
Click to hide internal directories.