event

Documentation

Index

• Constants
• Variables
• func ConfigurePrivilegedServiceAccount() error
• func CreateEventProxySidecar(nodeNameFull string) (err error)
• func CreateServiceSidecar() error
• func DeleteService(namespace, name string)
• func DeleteTestSidecarNamespace() error
• func Enable() bool
• func GetCloudEventProxyImageFromPod() (image string, err error)
• func InitPubSub()
• func MonitorPodLogsRegex() (term chan bool, err error)
• func PushInitialEvent(eventType string, timeout time.Duration) (err error)

Constants

const (
	ConsumerSidecarTestNamespace = "ptp-event-framework-test"
	ProviderSidecarTestNamespace = "openshift-ptp"
	TestSidecarName              = "cloud-proxy-sidecar"
	TestSidecarContainerName     = "sidecar"
	TestSidecarSaName            = "sidecar-sa"
	TestServiceName              = "consumer-events-subscription-service"
	TestSidecarSuccessLogString  = "rest service returned healthy status"
	ConsumerContainerName        = "consumer"
	CustomerCloudEventProxyPort  = 8089
	ProviderCloudEventProxyPort  = 9085
)

const DeleteBackground = "deleteBackground"

const DeleteForeground = "deleteForeground"

Variables

var (
	PubSub *chanpubsub.Pubsub
)

Functions

func ConfigurePrivilegedServiceAccount

func ConfigurePrivilegedServiceAccount() error

func CreateEventProxySidecar

func CreateEventProxySidecar(nodeNameFull string) (err error)

create ptp-events sidecar

func CreateServiceSidecar

func CreateServiceSidecar() error

create ptp events consumer service

func DeleteService

func DeleteService(namespace, name string)

delete Service

func DeleteTestSidecarNamespace

func DeleteTestSidecarNamespace() error

delete consumer sidecar pod and associated service

func Enable

func Enable() bool

enables event if ptp event is required

func GetCloudEventProxyImageFromPod

func GetCloudEventProxyImageFromPod() (image string, err error)

gets the cloud-event-proxy sidecar image from the ptp-operator pods

func InitPubSub

func InitPubSub()

func MonitorPodLogsRegex

func MonitorPodLogsRegex() (term chan bool, err error)

returns last Regex match in the logs for a given pod

func PushInitialEvent

func PushInitialEvent(eventType string, timeout time.Duration) (err error)

returns last Regex match in the logs for a given pod