kube

type Factory interface {
	// KubernetesClientSet returns a new kubernetes clientset or error
	KubernetesClientSet() (kubernetes.Interface, error)

	// KubernetesClientSetOrDie calls KubernetesClientSet() and panics if it returns an error
	KubernetesClientSetOrDie() kubernetes.Interface

	// Apply applies the provided manifests on the specified namespace
	Apply(ctx context.Context, namespace string, manifests []byte) error

	// Wait waits for all of the provided `Resources` to be ready by calling
	// the `WaitFunc` of each resource until all of them returns `true`
	Wait(context.Context, *WaitOptions) error
}

type Resource struct {
	Name      string
	Namespace string

	// WaitFunc will be called to check if the resources is ready. Should return (true, nil)
	// if the resources is ready, (false, nil) if the resource is not ready yet, or (false, err)
	// if some error occured (in that case the `Wait` will fail with that error).
	WaitFunc func(ctx context.Context, f Factory, ns, name string) (bool, error)
}

type WaitOptions struct {
	// Inverval the duration between each iteration of calling all of the resources' `WaitFunc`s.
	Interval time.Duration

	// Timeout the max time to wait for all of the resources to be ready. If not all of the
	// resourecs are ready at time this will cause `Wait` to return an error.
	Timeout time.Duration

	// Resources the list of resources to wait for.
	Resources []Resource
}