k8s

type EventsClient interface {
	GetByPod(ctx context.Context, pod corev1.Pod) ([]corev1.Event, error)
}

type JobClient interface {
	Create(ctx context.Context, namespace string, job *batch.Job) (*batch.Job, error)
	List(ctx context.Context, includeCompleted bool) ([]batch.Job, error)
	GetByGUID(ctx context.Context, guid string, includeCompleted bool) ([]batch.Job, error)
	Delete(ctx context.Context, namespace string, name string) error
}

type LRPClient struct {
	stset.Desirer
	stset.Lister
	stset.Stopper
	stset.Updater
	stset.Getter
}

type PodClient interface {
	GetAll(ctx context.Context) ([]corev1.Pod, error)
	GetByLRPIdentifier(ctx context.Context, id api.LRPIdentifier) ([]corev1.Pod, error)
	Delete(ctx context.Context, namespace, name string) error
}

type PodDisruptionBudgetClient interface {
	Update(ctx context.Context, stset *appsv1.StatefulSet, lrp *api.LRP) error
}

type SecretsClient interface {
	Create(ctx context.Context, namespace string, secret *corev1.Secret) (*corev1.Secret, error)
	Delete(ctx context.Context, namespace string, name string) error
	SetOwner(ctx context.Context, secret *corev1.Secret, owner metav1.Object) (*corev1.Secret, error)
}

type StatefulSetClient interface {
	Create(ctx context.Context, namespace string, statefulSet *appsv1.StatefulSet) (*appsv1.StatefulSet, error)
	Update(ctx context.Context, namespace string, statefulSet *appsv1.StatefulSet) (*appsv1.StatefulSet, error)
	Delete(ctx context.Context, namespace string, name string) error
	GetBySourceType(ctx context.Context, sourceType string) ([]appsv1.StatefulSet, error)
	GetByLRPIdentifier(ctx context.Context, id api.LRPIdentifier) ([]appsv1.StatefulSet, error)
}

type TaskClient struct {
	jobs.Desirer
	jobs.Getter
	jobs.Deleter
	jobs.Lister
}