event

package

v0.0.0-...-8ce2061 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openshift/ptp-operator

Links

Open Source Insights

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 ¶

View Source

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
)

View Source

const DeleteBackground = "deleteBackground"

View Source

const DeleteForeground = "deleteForeground"

Variables ¶

View Source

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

event.go

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