exec

Oct 28, 2024

Changes in this version

+ func NewCommandExecutor(cli client.Client, clientSet kubernetes.Interface, ...) *defaultCommandExecutor

+ func NewExecPod(client client.Client, executor CommandExecutor, doguResource *k8sv2.Dogu, ...) (*execPod, error)

+ func NewExecPodFactory(client client.Client, config *rest.Config, executor CommandExecutor) *defaultExecPodFactory

+ func NewPodFileExtractor(k8sClient client.Client, restConfig *rest.Config, ...) *podFileExtractor

+ func NewShellCommand(command string, args ...string) *shellCommand

+ func NewShellCommandWithStdin(stdin io.Reader, command string, args ...string) *shellCommand

+ type CommandExecutor interface

+ ExecCommandForDogu func(ctx context.Context, resource *k8sv2.Dogu, command ShellCommand, ...) (*bytes.Buffer, error)

+ ExecCommandForPod func(ctx context.Context, pod *corev1.Pod, command ShellCommand, ...) (*bytes.Buffer, error)

+ type ExecPod interface

+ Create func(ctx context.Context) error

+ Delete func(ctx context.Context) error

+ Exec func(ctx context.Context, cmd ShellCommand) (out *bytes.Buffer, err error)

+ ObjectKey func() *client.ObjectKey

+ PodName func() string

+ type ExecPodFactory interface

+ NewExecPod func(doguResource *k8sv2.Dogu, dogu *core.Dogu) (ExecPod, error)

+ type FileExtractor interface

+ ExtractK8sResourcesFromContainer func(ctx context.Context, k8sExecPod ExecPod) (map[string]string, error)

+ type PodStatusForExec string

+ const ContainersStarted

+ const PodReady

+ type ShellCommand interface

+ CommandWithArgs func() []string

+ Stdin func() io.Reader