package exec

import "k8s.io/kubectl/pkg/cmd/exec"

Index ¶

• func NewCmdExec(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
• type DefaultRemoteExecutor
• func (*DefaultRemoteExecutor) Execute(url *url.URL, config *restclient.Config, stdin io.Reader, stdout, stderr io.Writer, tty bool, terminalSizeQueue remotecommand.TerminalSizeQueue) error
• type ExecOptions
• func (p *ExecOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, argsIn []string, argsLenAtDash int) error
• func (p *ExecOptions) Run() error
• func (p *ExecOptions) Validate() error
• type RemoteExecutor
• type StreamOptions
• func (o *StreamOptions) SetupTTY() term.TTY

Functions ¶

func NewCmdExec ¶

func NewCmdExec(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command

Types ¶

type DefaultRemoteExecutor ¶

type DefaultRemoteExecutor struct{}

DefaultRemoteExecutor is the standard implementation of remote command execution

func (*DefaultRemoteExecutor) Execute ¶

func (*DefaultRemoteExecutor) Execute(url *url.URL, config *restclient.Config, stdin io.Reader, stdout, stderr io.Writer, tty bool, terminalSizeQueue remotecommand.TerminalSizeQueue) error

type ExecOptions ¶

type ExecOptions struct {
	StreamOptions
	resource.FilenameOptions

	ResourceName     string
	Command          []string
	EnforceNamespace bool

	Builder         func() *resource.Builder
	ExecutablePodFn polymorphichelpers.AttachablePodForObjectFunc

	Pod           *corev1.Pod
	Executor      RemoteExecutor
	PodClient     coreclient.PodsGetter
	GetPodTimeout time.Duration
	Config        *restclient.Config
	// contains filtered or unexported fields
}

ExecOptions declare the arguments accepted by the Exec command

func (*ExecOptions) Complete ¶

func (p *ExecOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, argsIn []string, argsLenAtDash int) error

Complete verifies command line arguments and loads data from the command environment

func (*ExecOptions) Run ¶

func (p *ExecOptions) Run() error

Run executes a validated remote execution against a pod.

func (*ExecOptions) Validate ¶

func (p *ExecOptions) Validate() error

Validate checks that the provided exec options are specified.

type RemoteExecutor ¶

type RemoteExecutor interface {
	Execute(url *url.URL, config *restclient.Config, stdin io.Reader, stdout, stderr io.Writer, tty bool, terminalSizeQueue remotecommand.TerminalSizeQueue) error
}

RemoteExecutor defines the interface accepted by the Exec command - provided for test stubbing

type StreamOptions ¶

type StreamOptions struct {
	Namespace     string
	PodName       string
	ContainerName string
	Stdin         bool
	TTY           bool
	// minimize unnecessary output
	Quiet bool
	// InterruptParent, if set, is used to handle interrupts while attached
	InterruptParent *interrupt.Handler

	genericiooptions.IOStreams
	// contains filtered or unexported fields
}

func (*StreamOptions) SetupTTY ¶

func (o *StreamOptions) SetupTTY() term.TTY

Source Files ¶

exec.go