k8s

type Client interface {
	// DeploymentList returns a list of all the services within the namespace
	DeploymentList(ctx context.Context, namespace string) (*appsv1.DeploymentList, error)
	// DeploymentRestart will force a restart of the deployment name in the provided namespace.
	// This is a blocking call, it should only return once the deployment has completed.
	DeploymentRestart(ctx context.Context, namespace, name string) error

	EventsWatch(ctx context.Context, namespace string) (watch.Interface, error)

	IngressCreate(ctx context.Context, namespace string, ingress *networkingv1.Ingress) error
	IngressExists(ctx context.Context, namespace string, ingress string) bool
	IngressUpdate(ctx context.Context, namespace string, ingress *networkingv1.Ingress) error

	LogsGet(ctx context.Context, namespace string, name string) (string, error)

	NamespaceCreate(ctx context.Context, namespace string) error
	NamespaceExists(ctx context.Context, namespace string) bool
	NamespaceDelete(ctx context.Context, namespace string) error

	PersistentVolumeCreate(ctx context.Context, namespace, name string) error
	PersistentVolumeExists(ctx context.Context, namespace, name string) bool
	PersistentVolumeDelete(ctx context.Context, namespace, name string) error

	PersistentVolumeClaimCreate(ctx context.Context, namespace, name, volumeName string) error
	PersistentVolumeClaimExists(ctx context.Context, namespace, name, volumeName string) bool
	PersistentVolumeClaimDelete(ctx context.Context, namespace, name, volumeName string) error

	PodList(ctx context.Context, namespace string) (*corev1.PodList, error)

	SecretCreateOrUpdate(ctx context.Context, secret corev1.Secret) error
	// SecretDeleteCollection deletes multiple secrets.
	// Note this takes a `type` and not a `name`.  All secrets matching this type will be removed.
	SecretDeleteCollection(ctx context.Context, namespace, _type string) error
	SecretGet(ctx context.Context, namespace, name string) (*corev1.Secret, error)

	ServiceGet(ctx context.Context, namespace, name string) (*corev1.Service, error)

	StreamPodLogs(ctx context.Context, namespace string, podName string, since time.Time) (io.ReadCloser, error)

	// ServerVersionGet returns the kubernetes version.
	ServerVersionGet() (string, error)
}

type Cluster interface {
	// Create a cluster with the provided name.
	Create(ctx context.Context, portHTTP int, extraMounts []ExtraVolumeMount) error
	// Delete a cluster with the provided name.
	Delete(ctx context.Context) error
	// Exists returns true if the cluster exists, false otherwise.
	Exists(ctx context.Context) bool
	LoadImages(ctx context.Context, dockerClient docker.Client, images []string)
}

type DefaultK8sClient struct {
	ClientSet kubernetes.Interface
}

type ExtraVolumeMount struct {
	HostPath      string
	ContainerPath string
}

type Logger struct {
}

type Provider struct {
	// Name of this provider
	Name string
	// ClusterName is the name of the cluster this provider will interact with
	ClusterName string
	// Context this provider should use
	Context string
	// Kubeconfig location
	Kubeconfig string
}