kube

type DeleteOptions struct {
	LabelSelector   string
	ResourceTypes   []string
	Timeout         time.Duration
	WaitForDeletion bool
}

type DeleteResourceOptions struct {
	Namespace string
	Name      string
	Resource  schema.GroupVersionResource
}

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

	// ToRESTConfig returns a rest Config object or error
	ToRESTConfig() (*restclient.Config, error)

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

	// Delete delets the resources by their type(s) and labelSelector
	Delete(context.Context, *DeleteOptions) error

	// Delete deletes a specific resource by namespace/name
	DeleteResource(context.Context, *DeleteResourceOptions) 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 WaitFunc
}

type 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
}