util

package
v0.0.0-...-a52e8f6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 30, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
const (
	// SubscriberName used in the tests
	SubscriberName = "test-core-event-bus-subscriber"
)

Variables

This section is empty.

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

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL