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 WaitForNoPodFound(ctx context.Context, kubeClient kubernetes.Interface, ...) error
• func WaitForSensorDeploymentReady(ctx context.Context, kubeClient kubernetes.Interface, ...) error
• func WaitForSensorReady(ctx context.Context, sensorClient sensorpkg.SensorInterface, sensorName string, ...) error
• type PodLogCheckOption
  • func PodLogCheckOptionWithCount(c int) PodLogCheckOption
  • func PodLogCheckOptionWithTimeout(t time.Duration) PodLogCheckOption

Functions

func EventSourcePodLogContains

func EventSourcePodLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, eventSourceName, regex string, options ...PodLogCheckOption) (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, options ...PodLogCheckOption) bool

func SensorPodLogContains

func SensorPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, sensorName, regex string, options ...PodLogCheckOption) (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 WaitForNoPodFound

func WaitForNoPodFound(ctx context.Context, kubeClient kubernetes.Interface, namespace, labelSelector 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

Types

type PodLogCheckOption

type PodLogCheckOption func(*podLogCheckOptions)

func PodLogCheckOptionWithCount

func PodLogCheckOptionWithCount(c int) PodLogCheckOption

func PodLogCheckOptionWithTimeout

func PodLogCheckOptionWithTimeout(t time.Duration) PodLogCheckOption