devenvutil

Documentation

Index

• func Backoff(ctx context.Context, d time.Duration, max uint64, fn func() error, ...) error
• func DeleteObjects(ctx context.Context, log logrus.FieldLogger, k kubernetes.Interface, ...) error
• func EnsureDevenvRunning(ctx context.Context, conf *config.Config, b *box.Config) (kubernetesruntime.Runtime, error)
• func FindUnreadyPods(ctx context.Context, k kubernetes.Interface) ([]string, error)
• func GetIngressControllerIP(ctx context.Context, k kubernetes.Interface, log logrus.FieldLogger) string
• func WaitForAllPodsToBeReady(ctx context.Context, k kubernetes.Interface, log logrus.FieldLogger) error
• func WaitForDevenv(ctx context.Context, sopt *status.Options, log logrus.FieldLogger) error
• type DeleteObjectsObjects
• type ListableType

Functions

func Backoff

func Backoff(ctx context.Context, d time.Duration, max uint64, fn func() error, log logrus.FieldLogger) error

Backoff is a light wrapper around the backoff library

func DeleteObjects

func DeleteObjects(ctx context.Context, log logrus.FieldLogger, k kubernetes.Interface, conf *rest.Config, opts DeleteObjectsObjects) error

func EnsureDevenvRunning

func EnsureDevenvRunning(ctx context.Context, conf *config.Config, b *box.Config) (kubernetesruntime.Runtime, error)

EnsureDevenvRunning returns an error if the developer environment is not running.

func FindUnreadyPods

func FindUnreadyPods(ctx context.Context, k kubernetes.Interface) ([]string, error)

FindUnreadyPods checks all namespaces to find pods that are unready, they are then returned. If an error occurs, err is returned.

func GetIngressControllerIP

func GetIngressControllerIP(ctx context.Context, k kubernetes.Interface, log logrus.FieldLogger) string

GetIngressControllerIP finds the IP address of the ingress controller being used in the devenv

func WaitForAllPodsToBeReady

func WaitForAllPodsToBeReady(ctx context.Context, k kubernetes.Interface, log logrus.FieldLogger) error

WaitForAllPodsToBeReady waits for all pods to be unready.

func WaitForDevenv

func WaitForDevenv(ctx context.Context, sopt *status.Options, log logrus.FieldLogger) error

WaitForDevenv waits for the developer environment to be up and handle context cancellation. This blocks until finished.

Types

type DeleteObjectsObjects

type DeleteObjectsObjects struct {
	// Type is the type of object that should be deleted.
	Type runtime.Object

	// Namespaces is a list of namespaces that objects should be deleted in
	Namespaces []string

	// Validator is a function that returns if an item should be filtered
	// or not.
	Validator func(obj *unstructured.Unstructured) (filter bool)
}

type ListableType

type ListableType interface {
	List(context.Context, metav1.ListOptions) (interface{}, error)
}