k8sutil

type ExecOptions struct {
	Command []string

	Namespace     string
	PodName       string
	ContainerName string

	Stdin         io.Reader
	CaptureStdout bool
	CaptureStderr bool
	// If false, whitespace in std{err,out} will be removed.
	PreserveWhitespace bool
}

type IExec interface {

	// ExecCommandInContainer executes a command in the specified container.
	ExecCommandInContainer(pod *corev1.Pod, containerName string, cmd ...string) (string, string, error)
}

type IPodControl interface {
	// CreatePod creates a Pod in a DistributedRedisCluster.
	CreatePod(*corev1.Pod) error
	// UpdatePod updates a Pod in a DistributedRedisCluster.
	UpdatePod(*corev1.Pod) error
	// DeletePod deletes a Pod in a DistributedRedisCluster.
	DeletePod(*corev1.Pod) error
	DeletePodByName(namespace, name string) error
	// GetPod get Pod in a DistributedRedisCluster.
	GetPod(namespace, name string) (*corev1.Pod, error)
}

type IUnitControl interface {

	// UpdateUnit updates a Unit.
	UpdateUnit(*unitv1alpha2.Unit) error

	// GetUnit get Unit.
	GetUnit(namespace, name string) (*unitv1alpha2.Unit, error)
}

type PodController struct {
	// contains filtered or unexported fields
}

type UnitController struct {
	// contains filtered or unexported fields
}