k8s

Documentation

Index

• func IsPodReady(pod *corev1.Pod) bool
• func TunnelForReceiverMock(ctx context.Context, t *testing.T) *terrak8s.Tunnel
• func WaitUntilPodsAvailable(t *testing.T, options *k8s.KubectlOptions, filters v1.ListOptions, minPods int, ...)
• func WaitUntilPodsAvailableE(t *testing.T, options *k8s.KubectlOptions, filters v1.ListOptions, minPods int, ...) error

Functions

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

Simplified version of https://github.com/kubernetes/kubernetes/blob/5835544ca568b757a8ecae5c153f317e5736700e/pkg/api/v1/pod/util.go#L294

func TunnelForReceiverMock

func TunnelForReceiverMock(
	ctx context.Context,
	t *testing.T,
) *terrak8s.Tunnel

TunnelForReceiverMock creates a tunnel with port forward to receiver-mock service.

func WaitUntilPodsAvailable

func WaitUntilPodsAvailable(
	t *testing.T,
	options *k8s.KubectlOptions,
	filters v1.ListOptions,
	minPods int,
	sleepDuration time.Duration,
	sleepBetweenRetries time.Duration,
)

Same as WaitUntilPodsAvailableE, but terminates the test instead of returning an error.

func WaitUntilPodsAvailableE

func WaitUntilPodsAvailableE(
	t *testing.T,
	options *k8s.KubectlOptions,
	filters v1.ListOptions,
	minPods int,
	sleepDuration time.Duration,
	sleepBetweenRetries time.Duration,
) error

WaitUntilPodsAvailableE waits until pods satisfying the provided filters are all available. Availability is defined via terrastruct's k8s.IsPodAvailable function, which requires the Pod to be Running and all of its containers to be started and ready. Technically this condition is satisfied if no Pods exists, the minPods argument helps with this edge case.