create

Documentation

Index

• func NewCreateCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• type CreateOptions
  • func NewCreateOptions(streams genericiooptions.IOStreams) *CreateOptions
  • func (o *CreateOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command, args []string) error
  • func (o *CreateOptions) Run(ctx context.Context, clientGetter util.ClientGetter, runTime time.Time) error
  • func (o *CreateOptions) RunInteractivePod(ctx context.Context, clientGetter util.ClientGetter, podName string) error

Functions

func NewCreateCmd

func NewCreateCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

Types

type CreateOptions

type CreateOptions struct {
	exec.StreamOptions

	PrintFlags *genericclioptions.PrintFlags
	Config     *restclient.Config
	Attach     attach.RemoteAttach
	AttachFunc func(*CreateOptions, *corev1.Container, remotecommand.TerminalSizeQueue, *corev1.Pod) func() error

	DryRunStrategy util.DryRunStrategy

	Namespace            string
	ProfileName          string
	ModeName             v1alpha1.ApplicationProfileMode
	Script               string
	InitImage            string
	PodRunningTimeout    time.Duration
	FirstNodeIPTimeout   time.Duration
	FirstNodeIP          bool
	RemoveInteractivePod bool
	ChangeDir            string

	SlurmFlagSet *pflag.FlagSet

	Command                  []string
	Parallelism              *int32
	Completions              *int32
	Replicas                 map[string]int
	MinReplicas              map[string]int
	MaxReplicas              map[string]int
	Requests                 corev1.ResourceList
	LocalQueue               string
	RayCluster               string
	Array                    string
	CpusPerTask              *apiresource.Quantity
	GpusPerTask              map[string]*apiresource.Quantity
	MemPerNode               *apiresource.Quantity
	MemPerTask               *apiresource.Quantity
	MemPerCPU                *apiresource.Quantity
	MemPerGPU                *apiresource.Quantity
	Nodes                    *int32
	NTasks                   *int32
	Output                   string
	Error                    string
	Input                    string
	JobName                  string
	Partition                string
	Priority                 string
	TimeLimit                string
	IgnoreUnknown            bool
	SkipLocalQueueValidation bool
	SkipPriorityValidation   bool

	UserSpecifiedCommand     string
	UserSpecifiedParallelism int32
	UserSpecifiedCompletions int32
	UserSpecifiedRequest     map[string]string
	UserSpecifiedCpusPerTask string
	UserSpecifiedGpusPerTask string
	UserSpecifiedMemPerNode  string
	UserSpecifiedMemPerTask  string
	UserSpecifiedMemPerCPU   string
	UserSpecifiedMemPerGPU   string
	UserSpecifiedNodes       int32
	UserSpecifiedNTasks      int32

	PrintObj printers.ResourcePrinterFunc

	genericiooptions.IOStreams
}

func NewCreateOptions

func NewCreateOptions(streams genericiooptions.IOStreams) *CreateOptions

func (*CreateOptions) Complete

func (o *CreateOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command, args []string) error

func (*CreateOptions) Run

func (o *CreateOptions) Run(ctx context.Context, clientGetter util.ClientGetter, runTime time.Time) error

func (*CreateOptions) RunInteractivePod

func (o *CreateOptions) RunInteractivePod(ctx context.Context, clientGetter util.ClientGetter, podName string) error