Versions in this module Expand all Collapse all v1 v1.0.0 Jan 7, 2024 Changes in this version + var CleanPodPolicy_name = map[int32]string + var CleanPodPolicy_value = map[string]int32 + var RestartPolicy_name = map[int32]string + var RestartPolicy_value = map[string]int32 + type CleanPodPolicy int32 + const CleanPodPolicy_CLEANPOD_POLICY_ALL + const CleanPodPolicy_CLEANPOD_POLICY_NONE + const CleanPodPolicy_CLEANPOD_POLICY_RUNNING + func (CleanPodPolicy) EnumDescriptor() ([]byte, []int) + func (x CleanPodPolicy) String() string + type DistributedMPITrainingReplicaSpec struct + Command []string + Image string + Replicas int32 + Resources *core.Resources + RestartPolicy RestartPolicy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedMPITrainingReplicaSpec) Descriptor() ([]byte, []int) + func (*DistributedMPITrainingReplicaSpec) ProtoMessage() + func (m *DistributedMPITrainingReplicaSpec) GetCommand() []string + func (m *DistributedMPITrainingReplicaSpec) GetImage() string + func (m *DistributedMPITrainingReplicaSpec) GetReplicas() int32 + func (m *DistributedMPITrainingReplicaSpec) GetResources() *core.Resources + func (m *DistributedMPITrainingReplicaSpec) GetRestartPolicy() RestartPolicy + func (m *DistributedMPITrainingReplicaSpec) Reset() + func (m *DistributedMPITrainingReplicaSpec) String() string + func (m *DistributedMPITrainingReplicaSpec) Validate() error + func (m *DistributedMPITrainingReplicaSpec) XXX_DiscardUnknown() + func (m *DistributedMPITrainingReplicaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedMPITrainingReplicaSpec) XXX_Merge(src proto.Message) + func (m *DistributedMPITrainingReplicaSpec) XXX_Size() int + func (m *DistributedMPITrainingReplicaSpec) XXX_Unmarshal(b []byte) error + type DistributedMPITrainingReplicaSpecValidationError struct + func (e DistributedMPITrainingReplicaSpecValidationError) Cause() error + func (e DistributedMPITrainingReplicaSpecValidationError) Error() string + func (e DistributedMPITrainingReplicaSpecValidationError) ErrorName() string + func (e DistributedMPITrainingReplicaSpecValidationError) Field() string + func (e DistributedMPITrainingReplicaSpecValidationError) Key() bool + func (e DistributedMPITrainingReplicaSpecValidationError) Reason() string + type DistributedMPITrainingTask struct + LauncherReplicas *DistributedMPITrainingReplicaSpec + RunPolicy *RunPolicy + Slots int32 + WorkerReplicas *DistributedMPITrainingReplicaSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedMPITrainingTask) Descriptor() ([]byte, []int) + func (*DistributedMPITrainingTask) ProtoMessage() + func (m *DistributedMPITrainingTask) GetLauncherReplicas() *DistributedMPITrainingReplicaSpec + func (m *DistributedMPITrainingTask) GetRunPolicy() *RunPolicy + func (m *DistributedMPITrainingTask) GetSlots() int32 + func (m *DistributedMPITrainingTask) GetWorkerReplicas() *DistributedMPITrainingReplicaSpec + func (m *DistributedMPITrainingTask) Reset() + func (m *DistributedMPITrainingTask) String() string + func (m *DistributedMPITrainingTask) Validate() error + func (m *DistributedMPITrainingTask) XXX_DiscardUnknown() + func (m *DistributedMPITrainingTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedMPITrainingTask) XXX_Merge(src proto.Message) + func (m *DistributedMPITrainingTask) XXX_Size() int + func (m *DistributedMPITrainingTask) XXX_Unmarshal(b []byte) error + type DistributedMPITrainingTaskValidationError struct + func (e DistributedMPITrainingTaskValidationError) Cause() error + func (e DistributedMPITrainingTaskValidationError) Error() string + func (e DistributedMPITrainingTaskValidationError) ErrorName() string + func (e DistributedMPITrainingTaskValidationError) Field() string + func (e DistributedMPITrainingTaskValidationError) Key() bool + func (e DistributedMPITrainingTaskValidationError) Reason() string + type DistributedPyTorchTrainingReplicaSpec struct + Image string + Replicas int32 + Resources *core.Resources + RestartPolicy RestartPolicy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedPyTorchTrainingReplicaSpec) Descriptor() ([]byte, []int) + func (*DistributedPyTorchTrainingReplicaSpec) ProtoMessage() + func (m *DistributedPyTorchTrainingReplicaSpec) GetImage() string + func (m *DistributedPyTorchTrainingReplicaSpec) GetReplicas() int32 + func (m *DistributedPyTorchTrainingReplicaSpec) GetResources() *core.Resources + func (m *DistributedPyTorchTrainingReplicaSpec) GetRestartPolicy() RestartPolicy + func (m *DistributedPyTorchTrainingReplicaSpec) Reset() + func (m *DistributedPyTorchTrainingReplicaSpec) String() string + func (m *DistributedPyTorchTrainingReplicaSpec) Validate() error + func (m *DistributedPyTorchTrainingReplicaSpec) XXX_DiscardUnknown() + func (m *DistributedPyTorchTrainingReplicaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedPyTorchTrainingReplicaSpec) XXX_Merge(src proto.Message) + func (m *DistributedPyTorchTrainingReplicaSpec) XXX_Size() int + func (m *DistributedPyTorchTrainingReplicaSpec) XXX_Unmarshal(b []byte) error + type DistributedPyTorchTrainingReplicaSpecValidationError struct + func (e DistributedPyTorchTrainingReplicaSpecValidationError) Cause() error + func (e DistributedPyTorchTrainingReplicaSpecValidationError) Error() string + func (e DistributedPyTorchTrainingReplicaSpecValidationError) ErrorName() string + func (e DistributedPyTorchTrainingReplicaSpecValidationError) Field() string + func (e DistributedPyTorchTrainingReplicaSpecValidationError) Key() bool + func (e DistributedPyTorchTrainingReplicaSpecValidationError) Reason() string + type DistributedPyTorchTrainingTask struct + ElasticConfig *ElasticConfig + MasterReplicas *DistributedPyTorchTrainingReplicaSpec + RunPolicy *RunPolicy + WorkerReplicas *DistributedPyTorchTrainingReplicaSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedPyTorchTrainingTask) Descriptor() ([]byte, []int) + func (*DistributedPyTorchTrainingTask) ProtoMessage() + func (m *DistributedPyTorchTrainingTask) GetElasticConfig() *ElasticConfig + func (m *DistributedPyTorchTrainingTask) GetMasterReplicas() *DistributedPyTorchTrainingReplicaSpec + func (m *DistributedPyTorchTrainingTask) GetRunPolicy() *RunPolicy + func (m *DistributedPyTorchTrainingTask) GetWorkerReplicas() *DistributedPyTorchTrainingReplicaSpec + func (m *DistributedPyTorchTrainingTask) Reset() + func (m *DistributedPyTorchTrainingTask) String() string + func (m *DistributedPyTorchTrainingTask) Validate() error + func (m *DistributedPyTorchTrainingTask) XXX_DiscardUnknown() + func (m *DistributedPyTorchTrainingTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedPyTorchTrainingTask) XXX_Merge(src proto.Message) + func (m *DistributedPyTorchTrainingTask) XXX_Size() int + func (m *DistributedPyTorchTrainingTask) XXX_Unmarshal(b []byte) error + type DistributedPyTorchTrainingTaskValidationError struct + func (e DistributedPyTorchTrainingTaskValidationError) Cause() error + func (e DistributedPyTorchTrainingTaskValidationError) Error() string + func (e DistributedPyTorchTrainingTaskValidationError) ErrorName() string + func (e DistributedPyTorchTrainingTaskValidationError) Field() string + func (e DistributedPyTorchTrainingTaskValidationError) Key() bool + func (e DistributedPyTorchTrainingTaskValidationError) Reason() string + type DistributedTensorflowTrainingReplicaSpec struct + Image string + Replicas int32 + Resources *core.Resources + RestartPolicy RestartPolicy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedTensorflowTrainingReplicaSpec) Descriptor() ([]byte, []int) + func (*DistributedTensorflowTrainingReplicaSpec) ProtoMessage() + func (m *DistributedTensorflowTrainingReplicaSpec) GetImage() string + func (m *DistributedTensorflowTrainingReplicaSpec) GetReplicas() int32 + func (m *DistributedTensorflowTrainingReplicaSpec) GetResources() *core.Resources + func (m *DistributedTensorflowTrainingReplicaSpec) GetRestartPolicy() RestartPolicy + func (m *DistributedTensorflowTrainingReplicaSpec) Reset() + func (m *DistributedTensorflowTrainingReplicaSpec) String() string + func (m *DistributedTensorflowTrainingReplicaSpec) Validate() error + func (m *DistributedTensorflowTrainingReplicaSpec) XXX_DiscardUnknown() + func (m *DistributedTensorflowTrainingReplicaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedTensorflowTrainingReplicaSpec) XXX_Merge(src proto.Message) + func (m *DistributedTensorflowTrainingReplicaSpec) XXX_Size() int + func (m *DistributedTensorflowTrainingReplicaSpec) XXX_Unmarshal(b []byte) error + type DistributedTensorflowTrainingReplicaSpecValidationError struct + func (e DistributedTensorflowTrainingReplicaSpecValidationError) Cause() error + func (e DistributedTensorflowTrainingReplicaSpecValidationError) Error() string + func (e DistributedTensorflowTrainingReplicaSpecValidationError) ErrorName() string + func (e DistributedTensorflowTrainingReplicaSpecValidationError) Field() string + func (e DistributedTensorflowTrainingReplicaSpecValidationError) Key() bool + func (e DistributedTensorflowTrainingReplicaSpecValidationError) Reason() string + type DistributedTensorflowTrainingTask struct + ChiefReplicas *DistributedTensorflowTrainingReplicaSpec + PsReplicas *DistributedTensorflowTrainingReplicaSpec + RunPolicy *RunPolicy + WorkerReplicas *DistributedTensorflowTrainingReplicaSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedTensorflowTrainingTask) Descriptor() ([]byte, []int) + func (*DistributedTensorflowTrainingTask) ProtoMessage() + func (m *DistributedTensorflowTrainingTask) GetChiefReplicas() *DistributedTensorflowTrainingReplicaSpec + func (m *DistributedTensorflowTrainingTask) GetPsReplicas() *DistributedTensorflowTrainingReplicaSpec + func (m *DistributedTensorflowTrainingTask) GetRunPolicy() *RunPolicy + func (m *DistributedTensorflowTrainingTask) GetWorkerReplicas() *DistributedTensorflowTrainingReplicaSpec + func (m *DistributedTensorflowTrainingTask) Reset() + func (m *DistributedTensorflowTrainingTask) String() string + func (m *DistributedTensorflowTrainingTask) Validate() error + func (m *DistributedTensorflowTrainingTask) XXX_DiscardUnknown() + func (m *DistributedTensorflowTrainingTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DistributedTensorflowTrainingTask) XXX_Merge(src proto.Message) + func (m *DistributedTensorflowTrainingTask) XXX_Size() int + func (m *DistributedTensorflowTrainingTask) XXX_Unmarshal(b []byte) error + type DistributedTensorflowTrainingTaskValidationError struct + func (e DistributedTensorflowTrainingTaskValidationError) Cause() error + func (e DistributedTensorflowTrainingTaskValidationError) Error() string + func (e DistributedTensorflowTrainingTaskValidationError) ErrorName() string + func (e DistributedTensorflowTrainingTaskValidationError) Field() string + func (e DistributedTensorflowTrainingTaskValidationError) Key() bool + func (e DistributedTensorflowTrainingTaskValidationError) Reason() string + type ElasticConfig struct + MaxReplicas int32 + MaxRestarts int32 + MinReplicas int32 + NprocPerNode int32 + RdzvBackend string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ElasticConfig) Descriptor() ([]byte, []int) + func (*ElasticConfig) ProtoMessage() + func (m *ElasticConfig) GetMaxReplicas() int32 + func (m *ElasticConfig) GetMaxRestarts() int32 + func (m *ElasticConfig) GetMinReplicas() int32 + func (m *ElasticConfig) GetNprocPerNode() int32 + func (m *ElasticConfig) GetRdzvBackend() string + func (m *ElasticConfig) Reset() + func (m *ElasticConfig) String() string + func (m *ElasticConfig) Validate() error + func (m *ElasticConfig) XXX_DiscardUnknown() + func (m *ElasticConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ElasticConfig) XXX_Merge(src proto.Message) + func (m *ElasticConfig) XXX_Size() int + func (m *ElasticConfig) XXX_Unmarshal(b []byte) error + type ElasticConfigValidationError struct + func (e ElasticConfigValidationError) Cause() error + func (e ElasticConfigValidationError) Error() string + func (e ElasticConfigValidationError) ErrorName() string + func (e ElasticConfigValidationError) Field() string + func (e ElasticConfigValidationError) Key() bool + func (e ElasticConfigValidationError) Reason() string + type RestartPolicy int32 + const RestartPolicy_RESTART_POLICY_ALWAYS + const RestartPolicy_RESTART_POLICY_NEVER + const RestartPolicy_RESTART_POLICY_ON_FAILURE + func (RestartPolicy) EnumDescriptor() ([]byte, []int) + func (x RestartPolicy) String() string + type RunPolicy struct + ActiveDeadlineSeconds int32 + BackoffLimit int32 + CleanPodPolicy CleanPodPolicy + TtlSecondsAfterFinished int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunPolicy) Descriptor() ([]byte, []int) + func (*RunPolicy) ProtoMessage() + func (m *RunPolicy) GetActiveDeadlineSeconds() int32 + func (m *RunPolicy) GetBackoffLimit() int32 + func (m *RunPolicy) GetCleanPodPolicy() CleanPodPolicy + func (m *RunPolicy) GetTtlSecondsAfterFinished() int32 + func (m *RunPolicy) Reset() + func (m *RunPolicy) String() string + func (m *RunPolicy) Validate() error + func (m *RunPolicy) XXX_DiscardUnknown() + func (m *RunPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunPolicy) XXX_Merge(src proto.Message) + func (m *RunPolicy) XXX_Size() int + func (m *RunPolicy) XXX_Unmarshal(b []byte) error + type RunPolicyValidationError struct + func (e RunPolicyValidationError) Cause() error + func (e RunPolicyValidationError) Error() string + func (e RunPolicyValidationError) ErrorName() string + func (e RunPolicyValidationError) Field() string + func (e RunPolicyValidationError) Key() bool + func (e RunPolicyValidationError) Reason() string