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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PodPortForward ¶
func PodsLogContains ¶
func SensorPodLogContains ¶
func WaitForEventBusReady ¶
func WaitForEventBusReady(ctx context.Context, eventBusClient eventbuspkg.EventBusInterface, eventBusName string, timeout time.Duration) error
func WaitForEventSourceReady ¶
func WaitForEventSourceReady(ctx context.Context, eventSourceClient eventsourcepkg.EventSourceInterface, eventSourceName string, timeout time.Duration) error
func WaitForSensorReady ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.