util

Documentation

Index

• func EventSourcePodLogContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)
• func PodPortForward(config *rest.Config, namespace, podName string, localPort, remotePort int, ...) error
• func PodsLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, regex string, ...) bool
• func SensorPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)
• func WaitForEventBusReady(ctx context.Context, eventBusClient eventbuspkg.EventBusInterface, ...) error
• func WaitForEventBusStatefulSetReady(ctx context.Context, kubeClient kubernetes.Interface, ...) error
• func WaitForEventSourceDeploymentReady(ctx context.Context, kubeClient kubernetes.Interface, ...) error
• func WaitForEventSourceReady(ctx context.Context, eventSourceClient eventsourcepkg.EventSourceInterface, ...) error
• func WaitForSensorDeploymentReady(ctx context.Context, kubeClient kubernetes.Interface, ...) error
• func WaitForSensorReady(ctx context.Context, sensorClient sensorpkg.SensorInterface, sensorName string, ...) error

Functions

func EventSourcePodLogContains

func EventSourcePodLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, eventSourceName, regex string, timeout time.Duration) (bool, error)

func PodPortForward

func PodPortForward(config *rest.Config, namespace, podName string, localPort, remotePort int, stopCh <-chan struct{}) error

func PodsLogContains

func PodsLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, regex string, podList *corev1.PodList, timeout time.Duration) bool

func SensorPodLogContains

func SensorPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, sensorName, regex string, timeout time.Duration) (bool, error)

func WaitForEventBusReady

func WaitForEventBusReady(ctx context.Context, eventBusClient eventbuspkg.EventBusInterface, eventBusName string, timeout time.Duration) error

func WaitForEventBusStatefulSetReady

func WaitForEventBusStatefulSetReady(ctx context.Context, kubeClient kubernetes.Interface, namespace, eventBusName string, timeout time.Duration) error

func WaitForEventSourceDeploymentReady

func WaitForEventSourceDeploymentReady(ctx context.Context, kubeClient kubernetes.Interface, namespace, eventSourceName string, timeout time.Duration) error

func WaitForEventSourceReady

func WaitForEventSourceReady(ctx context.Context, eventSourceClient eventsourcepkg.EventSourceInterface, eventSourceName string, timeout time.Duration) error

func WaitForSensorDeploymentReady

func WaitForSensorDeploymentReady(ctx context.Context, kubeClient kubernetes.Interface, namespace, sensorName string, timeout time.Duration) error

func WaitForSensorReady

func WaitForSensorReady(ctx context.Context, sensorClient sensorpkg.SensorInterface, sensorName string, timeout time.Duration) error