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
	PodRunningTimeout    time.Duration
	RemoveInteractivePod bool

	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
	MemPerTask    *apiresource.Quantity
	MemPerCPU     *apiresource.Quantity
	MemPerGPU     *apiresource.Quantity
	Nodes         *int32
	NTasks        *int32
	Output        string
	Error         string
	Input         string
	JobName       string
	Partition     string
	IgnoreUnknown bool

	UserSpecifiedCommand     string
	UserSpecifiedParallelism int32
	UserSpecifiedCompletions int32
	UserSpecifiedRequest     map[string]string
	UserSpecifiedCpusPerTask string
	UserSpecifiedGpusPerTask 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