Versions in this module Expand all Collapse all v1 v1.0.15 Apr 20, 2023 Changes in this version + var SparkApplication_Type_name = map[int32]string + var SparkApplication_Type_value = map[string]int32 + type ArrayJob struct + Parallelism int64 + Size int64 + SuccessCriteria isArrayJob_SuccessCriteria + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ArrayJob) Descriptor() ([]byte, []int) + func (*ArrayJob) ProtoMessage() + func (*ArrayJob) XXX_OneofWrappers() []interface{} + func (m *ArrayJob) GetMinSuccessRatio() float32 + func (m *ArrayJob) GetMinSuccesses() int64 + func (m *ArrayJob) GetParallelism() int64 + func (m *ArrayJob) GetSize() int64 + func (m *ArrayJob) GetSuccessCriteria() isArrayJob_SuccessCriteria + func (m *ArrayJob) Reset() + func (m *ArrayJob) String() string + func (m *ArrayJob) Validate() error + func (m *ArrayJob) XXX_DiscardUnknown() + func (m *ArrayJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArrayJob) XXX_Merge(src proto.Message) + func (m *ArrayJob) XXX_Size() int + func (m *ArrayJob) XXX_Unmarshal(b []byte) error + type ArrayJobValidationError struct + func (e ArrayJobValidationError) Cause() error + func (e ArrayJobValidationError) Error() string + func (e ArrayJobValidationError) ErrorName() string + func (e ArrayJobValidationError) Field() string + func (e ArrayJobValidationError) Key() bool + func (e ArrayJobValidationError) Reason() string + type ArrayJob_MinSuccessRatio struct + MinSuccessRatio float32 + type ArrayJob_MinSuccesses struct + MinSuccesses int64 + type DaskJob struct + Scheduler *DaskScheduler + Workers *DaskWorkerGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DaskJob) Descriptor() ([]byte, []int) + func (*DaskJob) ProtoMessage() + func (m *DaskJob) GetScheduler() *DaskScheduler + func (m *DaskJob) GetWorkers() *DaskWorkerGroup + func (m *DaskJob) Reset() + func (m *DaskJob) String() string + func (m *DaskJob) Validate() error + func (m *DaskJob) XXX_DiscardUnknown() + func (m *DaskJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DaskJob) XXX_Merge(src proto.Message) + func (m *DaskJob) XXX_Size() int + func (m *DaskJob) XXX_Unmarshal(b []byte) error + type DaskJobValidationError struct + func (e DaskJobValidationError) Cause() error + func (e DaskJobValidationError) Error() string + func (e DaskJobValidationError) ErrorName() string + func (e DaskJobValidationError) Field() string + func (e DaskJobValidationError) Key() bool + func (e DaskJobValidationError) Reason() string + type DaskScheduler struct + Image string + Resources *core.Resources + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DaskScheduler) Descriptor() ([]byte, []int) + func (*DaskScheduler) ProtoMessage() + func (m *DaskScheduler) GetImage() string + func (m *DaskScheduler) GetResources() *core.Resources + func (m *DaskScheduler) Reset() + func (m *DaskScheduler) String() string + func (m *DaskScheduler) Validate() error + func (m *DaskScheduler) XXX_DiscardUnknown() + func (m *DaskScheduler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DaskScheduler) XXX_Merge(src proto.Message) + func (m *DaskScheduler) XXX_Size() int + func (m *DaskScheduler) XXX_Unmarshal(b []byte) error + type DaskSchedulerValidationError struct + func (e DaskSchedulerValidationError) Cause() error + func (e DaskSchedulerValidationError) Error() string + func (e DaskSchedulerValidationError) ErrorName() string + func (e DaskSchedulerValidationError) Field() string + func (e DaskSchedulerValidationError) Key() bool + func (e DaskSchedulerValidationError) Reason() string + type DaskWorkerGroup struct + Image string + NumberOfWorkers uint32 + Resources *core.Resources + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DaskWorkerGroup) Descriptor() ([]byte, []int) + func (*DaskWorkerGroup) ProtoMessage() + func (m *DaskWorkerGroup) GetImage() string + func (m *DaskWorkerGroup) GetNumberOfWorkers() uint32 + func (m *DaskWorkerGroup) GetResources() *core.Resources + func (m *DaskWorkerGroup) Reset() + func (m *DaskWorkerGroup) String() string + func (m *DaskWorkerGroup) Validate() error + func (m *DaskWorkerGroup) XXX_DiscardUnknown() + func (m *DaskWorkerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DaskWorkerGroup) XXX_Merge(src proto.Message) + func (m *DaskWorkerGroup) XXX_Size() int + func (m *DaskWorkerGroup) XXX_Unmarshal(b []byte) error + type DaskWorkerGroupValidationError struct + func (e DaskWorkerGroupValidationError) Cause() error + func (e DaskWorkerGroupValidationError) Error() string + func (e DaskWorkerGroupValidationError) ErrorName() string + func (e DaskWorkerGroupValidationError) Field() string + func (e DaskWorkerGroupValidationError) Key() bool + func (e DaskWorkerGroupValidationError) Reason() string + type DistributedMPITrainingTask struct + NumLauncherReplicas int32 + NumWorkers int32 + Slots int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedMPITrainingTask) Descriptor() ([]byte, []int) + func (*DistributedMPITrainingTask) ProtoMessage() + func (m *DistributedMPITrainingTask) GetNumLauncherReplicas() int32 + func (m *DistributedMPITrainingTask) GetNumWorkers() int32 + func (m *DistributedMPITrainingTask) GetSlots() int32 + 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 DistributedPyTorchTrainingTask struct + Workers int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedPyTorchTrainingTask) Descriptor() ([]byte, []int) + func (*DistributedPyTorchTrainingTask) ProtoMessage() + func (m *DistributedPyTorchTrainingTask) GetWorkers() int32 + 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 DistributedTensorflowTrainingTask struct + ChiefReplicas int32 + PsReplicas int32 + Workers int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DistributedTensorflowTrainingTask) Descriptor() ([]byte, []int) + func (*DistributedTensorflowTrainingTask) ProtoMessage() + func (m *DistributedTensorflowTrainingTask) GetChiefReplicas() int32 + func (m *DistributedTensorflowTrainingTask) GetPsReplicas() int32 + func (m *DistributedTensorflowTrainingTask) GetWorkers() int32 + 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 HeadGroupSpec struct + RayStartParams map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HeadGroupSpec) Descriptor() ([]byte, []int) + func (*HeadGroupSpec) ProtoMessage() + func (m *HeadGroupSpec) GetRayStartParams() map[string]string + func (m *HeadGroupSpec) Reset() + func (m *HeadGroupSpec) String() string + func (m *HeadGroupSpec) Validate() error + func (m *HeadGroupSpec) XXX_DiscardUnknown() + func (m *HeadGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HeadGroupSpec) XXX_Merge(src proto.Message) + func (m *HeadGroupSpec) XXX_Size() int + func (m *HeadGroupSpec) XXX_Unmarshal(b []byte) error + type HeadGroupSpecValidationError struct + func (e HeadGroupSpecValidationError) Cause() error + func (e HeadGroupSpecValidationError) Error() string + func (e HeadGroupSpecValidationError) ErrorName() string + func (e HeadGroupSpecValidationError) Field() string + func (e HeadGroupSpecValidationError) Key() bool + func (e HeadGroupSpecValidationError) Reason() string + type HiveQuery struct + Query string + RetryCount uint32 + TimeoutSec uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HiveQuery) Descriptor() ([]byte, []int) + func (*HiveQuery) ProtoMessage() + func (m *HiveQuery) GetQuery() string + func (m *HiveQuery) GetRetryCount() uint32 + func (m *HiveQuery) GetTimeoutSec() uint32 + func (m *HiveQuery) Reset() + func (m *HiveQuery) String() string + func (m *HiveQuery) Validate() error + func (m *HiveQuery) XXX_DiscardUnknown() + func (m *HiveQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HiveQuery) XXX_Merge(src proto.Message) + func (m *HiveQuery) XXX_Size() int + func (m *HiveQuery) XXX_Unmarshal(b []byte) error + type HiveQueryCollection struct + Queries []*HiveQuery + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HiveQueryCollection) Descriptor() ([]byte, []int) + func (*HiveQueryCollection) ProtoMessage() + func (m *HiveQueryCollection) GetQueries() []*HiveQuery + func (m *HiveQueryCollection) Reset() + func (m *HiveQueryCollection) String() string + func (m *HiveQueryCollection) Validate() error + func (m *HiveQueryCollection) XXX_DiscardUnknown() + func (m *HiveQueryCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HiveQueryCollection) XXX_Merge(src proto.Message) + func (m *HiveQueryCollection) XXX_Size() int + func (m *HiveQueryCollection) XXX_Unmarshal(b []byte) error + type HiveQueryCollectionValidationError struct + func (e HiveQueryCollectionValidationError) Cause() error + func (e HiveQueryCollectionValidationError) Error() string + func (e HiveQueryCollectionValidationError) ErrorName() string + func (e HiveQueryCollectionValidationError) Field() string + func (e HiveQueryCollectionValidationError) Key() bool + func (e HiveQueryCollectionValidationError) Reason() string + type HiveQueryValidationError struct + func (e HiveQueryValidationError) Cause() error + func (e HiveQueryValidationError) Error() string + func (e HiveQueryValidationError) ErrorName() string + func (e HiveQueryValidationError) Field() string + func (e HiveQueryValidationError) Key() bool + func (e HiveQueryValidationError) Reason() string + type PrestoQuery struct + Catalog string + RoutingGroup string + Schema string + Statement string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrestoQuery) Descriptor() ([]byte, []int) + func (*PrestoQuery) ProtoMessage() + func (m *PrestoQuery) GetCatalog() string + func (m *PrestoQuery) GetRoutingGroup() string + func (m *PrestoQuery) GetSchema() string + func (m *PrestoQuery) GetStatement() string + func (m *PrestoQuery) Reset() + func (m *PrestoQuery) String() string + func (m *PrestoQuery) Validate() error + func (m *PrestoQuery) XXX_DiscardUnknown() + func (m *PrestoQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrestoQuery) XXX_Merge(src proto.Message) + func (m *PrestoQuery) XXX_Size() int + func (m *PrestoQuery) XXX_Unmarshal(b []byte) error + type PrestoQueryValidationError struct + func (e PrestoQueryValidationError) Cause() error + func (e PrestoQueryValidationError) Error() string + func (e PrestoQueryValidationError) ErrorName() string + func (e PrestoQueryValidationError) Field() string + func (e PrestoQueryValidationError) Key() bool + func (e PrestoQueryValidationError) Reason() string + type QuboleHiveJob struct + ClusterLabel string + Query *HiveQuery + QueryCollection *HiveQueryCollection + Tags []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QuboleHiveJob) Descriptor() ([]byte, []int) + func (*QuboleHiveJob) ProtoMessage() + func (m *QuboleHiveJob) GetClusterLabel() string + func (m *QuboleHiveJob) GetQuery() *HiveQuery + func (m *QuboleHiveJob) GetQueryCollection() *HiveQueryCollection + func (m *QuboleHiveJob) GetTags() []string + func (m *QuboleHiveJob) Reset() + func (m *QuboleHiveJob) String() string + func (m *QuboleHiveJob) Validate() error + func (m *QuboleHiveJob) XXX_DiscardUnknown() + func (m *QuboleHiveJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuboleHiveJob) XXX_Merge(src proto.Message) + func (m *QuboleHiveJob) XXX_Size() int + func (m *QuboleHiveJob) XXX_Unmarshal(b []byte) error + type QuboleHiveJobValidationError struct + func (e QuboleHiveJobValidationError) Cause() error + func (e QuboleHiveJobValidationError) Error() string + func (e QuboleHiveJobValidationError) ErrorName() string + func (e QuboleHiveJobValidationError) Field() string + func (e QuboleHiveJobValidationError) Key() bool + func (e QuboleHiveJobValidationError) Reason() string + type RayCluster struct + HeadGroupSpec *HeadGroupSpec + WorkerGroupSpec []*WorkerGroupSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RayCluster) Descriptor() ([]byte, []int) + func (*RayCluster) ProtoMessage() + func (m *RayCluster) GetHeadGroupSpec() *HeadGroupSpec + func (m *RayCluster) GetWorkerGroupSpec() []*WorkerGroupSpec + func (m *RayCluster) Reset() + func (m *RayCluster) String() string + func (m *RayCluster) Validate() error + func (m *RayCluster) XXX_DiscardUnknown() + func (m *RayCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RayCluster) XXX_Merge(src proto.Message) + func (m *RayCluster) XXX_Size() int + func (m *RayCluster) XXX_Unmarshal(b []byte) error + type RayClusterValidationError struct + func (e RayClusterValidationError) Cause() error + func (e RayClusterValidationError) Error() string + func (e RayClusterValidationError) ErrorName() string + func (e RayClusterValidationError) Field() string + func (e RayClusterValidationError) Key() bool + func (e RayClusterValidationError) Reason() string + type RayJob struct + RayCluster *RayCluster + RuntimeEnv string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RayJob) Descriptor() ([]byte, []int) + func (*RayJob) ProtoMessage() + func (m *RayJob) GetRayCluster() *RayCluster + func (m *RayJob) GetRuntimeEnv() string + func (m *RayJob) Reset() + func (m *RayJob) String() string + func (m *RayJob) Validate() error + func (m *RayJob) XXX_DiscardUnknown() + func (m *RayJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RayJob) XXX_Merge(src proto.Message) + func (m *RayJob) XXX_Size() int + func (m *RayJob) XXX_Unmarshal(b []byte) error + type RayJobValidationError struct + func (e RayJobValidationError) Cause() error + func (e RayJobValidationError) Error() string + func (e RayJobValidationError) ErrorName() string + func (e RayJobValidationError) Field() string + func (e RayJobValidationError) Key() bool + func (e RayJobValidationError) Reason() string + type SparkApplication struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SparkApplication) Descriptor() ([]byte, []int) + func (*SparkApplication) ProtoMessage() + func (m *SparkApplication) Reset() + func (m *SparkApplication) String() string + func (m *SparkApplication) Validate() error + func (m *SparkApplication) XXX_DiscardUnknown() + func (m *SparkApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SparkApplication) XXX_Merge(src proto.Message) + func (m *SparkApplication) XXX_Size() int + func (m *SparkApplication) XXX_Unmarshal(b []byte) error + type SparkApplicationValidationError struct + func (e SparkApplicationValidationError) Cause() error + func (e SparkApplicationValidationError) Error() string + func (e SparkApplicationValidationError) ErrorName() string + func (e SparkApplicationValidationError) Field() string + func (e SparkApplicationValidationError) Key() bool + func (e SparkApplicationValidationError) Reason() string + type SparkApplication_Type int32 + const SparkApplication_JAVA + const SparkApplication_PYTHON + const SparkApplication_R + const SparkApplication_SCALA + func (SparkApplication_Type) EnumDescriptor() ([]byte, []int) + func (x SparkApplication_Type) String() string + type SparkJob struct + ApplicationType SparkApplication_Type + DatabricksConf *_struct.Struct + DatabricksInstance string + DatabricksToken string + ExecutorPath string + HadoopConf map[string]string + MainApplicationFile string + MainClass string + SparkConf map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SparkJob) Descriptor() ([]byte, []int) + func (*SparkJob) ProtoMessage() + func (m *SparkJob) GetApplicationType() SparkApplication_Type + func (m *SparkJob) GetDatabricksConf() *_struct.Struct + func (m *SparkJob) GetDatabricksInstance() string + func (m *SparkJob) GetDatabricksToken() string + func (m *SparkJob) GetExecutorPath() string + func (m *SparkJob) GetHadoopConf() map[string]string + func (m *SparkJob) GetMainApplicationFile() string + func (m *SparkJob) GetMainClass() string + func (m *SparkJob) GetSparkConf() map[string]string + func (m *SparkJob) Reset() + func (m *SparkJob) String() string + func (m *SparkJob) Validate() error + func (m *SparkJob) XXX_DiscardUnknown() + func (m *SparkJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SparkJob) XXX_Merge(src proto.Message) + func (m *SparkJob) XXX_Size() int + func (m *SparkJob) XXX_Unmarshal(b []byte) error + type SparkJobValidationError struct + func (e SparkJobValidationError) Cause() error + func (e SparkJobValidationError) Error() string + func (e SparkJobValidationError) ErrorName() string + func (e SparkJobValidationError) Field() string + func (e SparkJobValidationError) Key() bool + func (e SparkJobValidationError) Reason() string + type Waitable struct + Phase core.WorkflowExecution_Phase + WfExecId *core.WorkflowExecutionIdentifier + WorkflowId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Waitable) Descriptor() ([]byte, []int) + func (*Waitable) ProtoMessage() + func (m *Waitable) GetPhase() core.WorkflowExecution_Phase + func (m *Waitable) GetWfExecId() *core.WorkflowExecutionIdentifier + func (m *Waitable) GetWorkflowId() string + func (m *Waitable) Reset() + func (m *Waitable) String() string + func (m *Waitable) Validate() error + func (m *Waitable) XXX_DiscardUnknown() + func (m *Waitable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Waitable) XXX_Merge(src proto.Message) + func (m *Waitable) XXX_Size() int + func (m *Waitable) XXX_Unmarshal(b []byte) error + type WaitableValidationError struct + func (e WaitableValidationError) Cause() error + func (e WaitableValidationError) Error() string + func (e WaitableValidationError) ErrorName() string + func (e WaitableValidationError) Field() string + func (e WaitableValidationError) Key() bool + func (e WaitableValidationError) Reason() string + type WorkerGroupSpec struct + GroupName string + MaxReplicas int32 + MinReplicas int32 + RayStartParams map[string]string + Replicas int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkerGroupSpec) Descriptor() ([]byte, []int) + func (*WorkerGroupSpec) ProtoMessage() + func (m *WorkerGroupSpec) GetGroupName() string + func (m *WorkerGroupSpec) GetMaxReplicas() int32 + func (m *WorkerGroupSpec) GetMinReplicas() int32 + func (m *WorkerGroupSpec) GetRayStartParams() map[string]string + func (m *WorkerGroupSpec) GetReplicas() int32 + func (m *WorkerGroupSpec) Reset() + func (m *WorkerGroupSpec) String() string + func (m *WorkerGroupSpec) Validate() error + func (m *WorkerGroupSpec) XXX_DiscardUnknown() + func (m *WorkerGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkerGroupSpec) XXX_Merge(src proto.Message) + func (m *WorkerGroupSpec) XXX_Size() int + func (m *WorkerGroupSpec) XXX_Unmarshal(b []byte) error + type WorkerGroupSpecValidationError struct + func (e WorkerGroupSpecValidationError) Cause() error + func (e WorkerGroupSpecValidationError) Error() string + func (e WorkerGroupSpecValidationError) ErrorName() string + func (e WorkerGroupSpecValidationError) Field() string + func (e WorkerGroupSpecValidationError) Key() bool + func (e WorkerGroupSpecValidationError) Reason() string