usecase

Documentation

Index

• type K8sInClusterUsecase
  • func NewK8sInClusterUsecase() (K8sInClusterUsecase, error)
• type PodUsecase
  • func NewPodUsecase(ctx context.Context, k8sUsecase K8sInClusterUsecase) (PodUsecase, error)
• type SshUsecase
  • func NewSshUsecase(port string, ctx context.Context, publicKey gossh.PublicKey, ...) (SshUsecase, error)

Types

type K8sInClusterUsecase

type K8sInClusterUsecase interface {
	GetConfig() *rest.Config
	GetClientSet() *kubernetes.Clientset
}

func NewK8sInClusterUsecase

func NewK8sInClusterUsecase() (K8sInClusterUsecase, error)

type PodUsecase

type PodUsecase interface {
	GetCurrentPod() (*corev1.Pod, error)
	GetContainerInCurrentPod(targetContainerName string) (*corev1.Container, error)
}

func NewPodUsecase

func NewPodUsecase(
	ctx context.Context,
	k8sUsecase K8sInClusterUsecase,
) (PodUsecase, error)

type SshUsecase

type SshUsecase interface {
	StartSshServer4ContainerShell(cri pod.CRI, cmd string) error
	Shutdown() error
}

func NewSshUsecase

func NewSshUsecase(
	port string,
	ctx context.Context,
	publicKey gossh.PublicKey,
	k8sUsecase K8sInClusterUsecase,
) (SshUsecase, error)