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 appconnector.Interface, name string, applicationOptions ...ApplicationOption) error

func CreateApplicationMapping

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

func CreateServiceInstance

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

func CreateSubscriber

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

func CreateTrigger

func CreateTrigger(messaging messaging.Interface, name, namespace string, triggeroptions ...TriggerOption) error

func SendCloudEvent

func SendCloudEvent(target, payload, eventType, eventTypeVersion string) error

func SendLegacyEvent

func SendLegacyEvent(target, payload, eventType, eventTypeVersion string) error

func WaitForApplication

func WaitForApplication(appConnector appconnector.Interface, messaging messaging.Interface, serving serving.Interface, name string, retryOptions ...retry.Option) error

func WaitForBroker

func WaitForBroker(messaging messaging.Interface, name, namespace string, retryOptions ...retry.Option) error

func WaitForChannel

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

func WaitForHttpSource

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

func WaitForServiceInstance

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

func WaitForSubscriber

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

func WaitForTrigger

func WaitForTrigger(messaging messaging.Interface, name, namespace string, retryOptions ...retry.Option) error

Types

type ApplicationOption

type ApplicationOption func(*appconnectorv1alpha1.Application)

func WithAPIService

func WithAPIService(id, gatewayUrl string) ApplicationOption

func WithAccessLabel

func WithAccessLabel(label string) ApplicationOption

func WithEventService

func WithEventService(id string) ApplicationOption

func WithoutInstallation

func WithoutInstallation() ApplicationOption

type EventMeshTest

type EventMeshTest struct {
	// contains filtered or unexported fields
}

func NewEventMeshTest

func NewEventMeshTest() (*EventMeshTest, error)

func (*EventMeshTest) CreateResources

func (em *EventMeshTest) CreateResources(t *testing.T, namespace string)

func (*EventMeshTest) TestResources

func (em *EventMeshTest) TestResources(t *testing.T, namespace string)

type LegacyEvent

type LegacyEvent struct {
	EventType        string    `json:"event-type"`
	EventTypeVersion string    `json:"event-type-version"`
	EventID          string    `json:"event-id"`
	EventTime        time.Time `json:"event-time"`
	Data             string    `json:"data"`
}

type SubscriberOption

type SubscriberOption func(deployment *appsv1.Deployment)

type TriggerOption

type TriggerOption func(trigger *v1alpha1.Trigger)

func WithBroker

func WithBroker(broker string) TriggerOption

func WithFilter

func WithFilter(eventTypeVersion, eventType, source string) TriggerOption

func WithRefSubscriber

func WithRefSubscriber(ref *corev1.ObjectReference) TriggerOption

func WithURISubscriber

func WithURISubscriber(target string) TriggerOption