util

Documentation

Index

• Constants
• func Logger(h http.Handler) http.Handler
• func NewEventActivation(name string, namespace string, sourceID string) *eaApis.EventActivation
• func NewSubscriberDeployment(sbscrImg string) *appsv1.Deployment
• 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 (
	// v1 endpoints
	SubServer1EventsPath  = "/v1/events"
	SubServer1StatusPath  = "/v1/status"
	SubServer1ResultsPath = "/v1/results"

	// v2 endpoints
	SubServer2EventsPath  = "/v2/events"
	SubServer2StatusPath  = "/v2/status"
	SubServer2ResultsPath = "/v2/results"

	// v3 endpoints
	SubServer3EventsPath  = "/v3/events"
	SubServer3StatusPath  = "/v3/status"
	SubServer3ResultsPath = "/v3/results"
)

Subscribers Servers API paths

const (
	// SubscriberName used in the tests
	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, sourceID string) *eaApis.EventActivation

NewEventActivation creates a new event activation

func NewSubscriberDeployment

func NewSubscriberDeployment(sbscrImg string) *appsv1.Deployment

NewSubscriberDeployment creates a new v1.Deployment instance.

func NewSubscriberServerWithPort

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

NewSubscriberServerWithPort creates a new HTTP server with multiple endpoints acting as an event subscriber

func NewSubscriberService

func NewSubscriberService() *apiv1.Service

NewSubscriberService creates a new v1.Service instance.

func NewSubscription

func NewSubscription(name string, namespace string, subscriberEventEndpointURL string, eventType string, eventTypeVersion string,
	sourceID string) *apiv1.Subscription

NewSubscription creates a new subscription