Documentation
¶
Index ¶
- Constants
- Variables
- func KubeRegistryName(name string) string
- func RegistryName(name string) string
- type DeleteCommand
- type GetCommand
- type KillCommand
- type LogsCommand
- type RegistryCmd
- func (r *RegistryCmd) Delete() error
- func (r *RegistryCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
- func (r *RegistryCmd) Name() string
- func (r *RegistryCmd) SetFlags(f *flag.FlagSet)
- func (r *RegistryCmd) Synopsis() string
- func (r *RegistryCmd) Usage() string
- type SimpleFileCmd
- type SubmitCmd
- type Submitter
Constants ¶
const ( // RegistryCmdName is subcommand name RegistryCmdName = "registry" // RegistryPrefix is the prefix for Kubernetes secret name RegistryPrefix = "pcloud-registry" )
Variables ¶
var Config = config.ParseDefaultConfig()
Config is global config object for paddlecloud commandline
Functions ¶
func KubeRegistryName ¶
KubeRegistryName add a prefix for the name
func RegistryName ¶
RegistryName is registry secret name for PaddleCloud
Types ¶
type DeleteCommand ¶
type DeleteCommand struct {
}
DeleteCommand do job killings
func (*DeleteCommand) Execute ¶
func (p *DeleteCommand) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute kill command
func (*DeleteCommand) SetFlags ¶
func (p *DeleteCommand) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags
func (*DeleteCommand) Synopsis ¶
func (*DeleteCommand) Synopsis() string
Synopsis is subcommands synopsis
type GetCommand ¶
type GetCommand struct {
// contains filtered or unexported fields
}
GetCommand exports get subcommand for fetching status
func (*GetCommand) Execute ¶
func (p *GetCommand) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute get command
func (*GetCommand) SetFlags ¶
func (p *GetCommand) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags
type KillCommand ¶
type KillCommand struct {
// contains filtered or unexported fields
}
KillCommand do job killings
func (*KillCommand) Execute ¶
func (p *KillCommand) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute kill command
func (*KillCommand) SetFlags ¶
func (p *KillCommand) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags
func (*KillCommand) Synopsis ¶
func (*KillCommand) Synopsis() string
Synopsis is subcommands synopsis
type LogsCommand ¶
type LogsCommand struct {
// contains filtered or unexported fields
}
LogsCommand print aggregated job logs
func (*LogsCommand) Execute ¶
func (p *LogsCommand) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute logs command
func (*LogsCommand) SetFlags ¶
func (p *LogsCommand) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags
func (*LogsCommand) Synopsis ¶
func (*LogsCommand) Synopsis() string
Synopsis is subcommands synopsis
type RegistryCmd ¶
type RegistryCmd struct {
SecretName string `json:"name"`
Username string `json:"username"`
Password string `json:"password"`
Server string `json:"server"`
}
RegistryCmd is Docker registry secret information
func (*RegistryCmd) Execute ¶
func (r *RegistryCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute runs RegistryCmd command.
func (*RegistryCmd) SetFlags ¶
func (r *RegistryCmd) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags.
func (*RegistryCmd) Synopsis ¶
func (r *RegistryCmd) Synopsis() string
Synopsis is the subcommand's synopsis
type SimpleFileCmd ¶
type SimpleFileCmd struct {
}
SimpleFileCmd define the subcommand of simple file operations.
func (*SimpleFileCmd) Execute ¶
func (p *SimpleFileCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute file ops.
func (*SimpleFileCmd) SetFlags ¶
func (p *SimpleFileCmd) SetFlags(f *flag.FlagSet)
SetFlags registers subcommands flags.
func (*SimpleFileCmd) Synopsis ¶
func (*SimpleFileCmd) Synopsis() string
Synopsis is subcommands synopsis.
type SubmitCmd ¶
type SubmitCmd struct {
Jobname string `json:"name"`
Jobpackage string `json:"jobPackage"`
Parallelism int `json:"parallelism"`
CPU int `json:"cpu"`
GPU int `json:"gpu"`
Memory string `json:"memory"`
Pservers int `json:"pservers"`
PSCPU int `json:"pscpu"`
PSMemory string `json:"psmemory"`
Entry string `json:"entry"`
Topology string `json:"topology"`
Datacenter string `json:"datacenter"`
Passes int `json:"passes"`
// docker image to run jobs
Image string `json:"image"`
Registry string `json:"registry"`
// Alpha features:
// TODO: separate API versions
FaultTolerant bool `json:"faulttolerant"`
}
SubmitCmd define the subcommand of submitting paddle training jobs.
func (*SubmitCmd) Execute ¶
func (p *SubmitCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) subcommands.ExitStatus
Execute submit command.
type Submitter ¶
type Submitter struct {
// contains filtered or unexported fields
}
Submitter submit job to cloud.
func NewSubmitter ¶
NewSubmitter returns a submitter object.