util

Documentation

Index

• Constants
• func Logger(h http.Handler) http.Handler
• func NewEventActivation(name string, namespace string, sourceEnvironment string, ...) *eaApis.EventActivation
• func NewSubscriberDeployment(sbscrImg string) *appsv1.Deployment
• func NewSubscriberServerV1() *httptest.Server
• func NewSubscriberServerV2() *httptest.Server
• func NewSubscriberServerWithPort(port int, stop chan bool) *http.Server
• func NewSubscriberService() *apiv1.Service
• func NewSubscription(name string, namespace string, subscriberEventEndpointURL string, ...) *apiv1.Subscription

Constants

const (
	SubServer1EventsPath  = "/v1/events"
	SubServer1StatusPath  = "/v1/status"
	SubServer1ResultsPath = "/v1/results"
	SubServer2EventsPath  = "/v2/events"
	SubServer2StatusPath  = "/v2/status"
	SubServer2ResultsPath = "/v2/results"
)

Subscribers Servers API paths

const (
	SubscriberName = "test-core-event-bus-subscriber"
)

Functions

func Logger

func Logger(h http.Handler) http.Handler

Logger ...

func NewEventActivation

func NewEventActivation(name string,
	namespace string,
	sourceEnvironment string,
	sourceNamespace string,
	sourceType string) *eaApis.EventActivation

NewEventActivation creates a new event activation

func NewSubscriberDeployment

func NewSubscriberDeployment(sbscrImg string) *appsv1.Deployment

func NewSubscriberServerV1

func NewSubscriberServerV1() *httptest.Server

NewSubscriberServerV1 ...

func NewSubscriberServerV2

func NewSubscriberServerV2() *httptest.Server

NewSubscriberServerV2 ...

func NewSubscriberServerWithPort

func NewSubscriberServerWithPort(port int, stop chan bool) *http.Server

NewSubscriberServerWithPort ...

func NewSubscriberService

func NewSubscriberService() *apiv1.Service

func NewSubscription

func NewSubscription(name string,
	namespace string,
	subscriberEventEndpointURL string,
	eventType string,
	eventTypeVersion string,
	sourceEnvironment string,
	sourceNamespace string,
	sourceType string) *apiv1.Subscription

NewSubscription creates a new subscription