kubernetes/staging/src/k8s.io/kubectl/pkg/cmd/run/run.go

var runLong …

var runExample …

const defaultPodAttachTimeout …

var metadataAccessor …

type RunObject …

type RunOptions …

func NewRunOptions(streams genericiooptions.IOStreams) *RunOptions { … }

func NewCmdRun(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command { … }

func addRunFlags(cmd *cobra.Command, opt *RunOptions) { … }

func (o *RunOptions) Complete(f cmdutil.Factory, cmd *cobra.Command) error { … }

func (o *RunOptions) Run(f cmdutil.Factory, cmd *cobra.Command, args []string) error { … }

func (o *RunOptions) removeCreatedObjects(f cmdutil.Factory, createdObjects []*RunObject) error { … }

// waitForPod watches the given pod until the exitCondition is true
func waitForPod(podClient corev1client.PodsGetter, ns, name string, timeout time.Duration, exitCondition watchtools.ConditionFunc) (*corev1.Pod, error) { … }

func handleAttachPod(f cmdutil.Factory, podClient corev1client.PodsGetter, ns, name string, opts *attach.AttachOptions) error { … }

// logOpts logs output from opts to the pods log.
func logOpts(restClientGetter genericclioptions.RESTClientGetter, pod *corev1.Pod, opts *attach.AttachOptions) error { … }

func getRestartPolicy(cmd *cobra.Command, interactive bool) (corev1.RestartPolicy, error) { … }

func verifyImagePullPolicy(cmd *cobra.Command) error { … }

func (o *RunOptions) generateService(f cmdutil.Factory, cmd *cobra.Command, paramsIn map[string]interface{ … }

func (o *RunOptions) createGeneratedObject(f cmdutil.Factory, cmd *cobra.Command, generator generate.Generator, names []generate.GeneratorParam, params map[string]interface{ … }

var ErrPodCompleted …

// podCompleted returns true if the pod has run to completion, false if the pod has not yet
// reached running state, or an error in any other case.
func podCompleted(event watch.Event) (bool, error) { … }

// podSucceeded returns true if the pod has run to completion, false if the pod has not yet
// reached running state, or an error in any other case.
func podSucceeded(event watch.Event) (bool, error) { … }

// podRunningAndReady returns true if the pod is running and ready, false if the pod has not
// yet reached those states, returns ErrPodCompleted if the pod has run to completion, or
// an error in any other case.
func podRunningAndReady(event watch.Event) (bool, error) { … }