Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
- func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
- func RegisterResourcePresetServiceServer(s grpc.ServiceRegistrar, srv ResourcePresetServiceServer)
- func RegisterSubclusterServiceServer(s grpc.ServiceRegistrar, srv SubclusterServiceServer)
- type ApplicationAttempt
- func (*ApplicationAttempt) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationAttempt) GetAmContainerId() string
- func (x *ApplicationAttempt) GetId() string
- func (*ApplicationAttempt) ProtoMessage()
- func (x *ApplicationAttempt) ProtoReflect() protoreflect.Message
- func (x *ApplicationAttempt) Reset()
- func (m *ApplicationAttempt) SetAmContainerId(v string)
- func (m *ApplicationAttempt) SetId(v string)
- func (x *ApplicationAttempt) String() string
- type ApplicationInfo
- func (*ApplicationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationInfo) GetApplicationAttempts() []*ApplicationAttempt
- func (x *ApplicationInfo) GetId() string
- func (*ApplicationInfo) ProtoMessage()
- func (x *ApplicationInfo) ProtoReflect() protoreflect.Message
- func (x *ApplicationInfo) Reset()
- func (m *ApplicationInfo) SetApplicationAttempts(v []*ApplicationAttempt)
- func (m *ApplicationInfo) SetId(v string)
- func (x *ApplicationInfo) String() string
- type AutoscalingConfig
- func (*AutoscalingConfig) Descriptor() ([]byte, []int)deprecated
- func (x *AutoscalingConfig) GetCpuUtilizationTarget() float64
- func (x *AutoscalingConfig) GetDecommissionTimeout() int64
- func (x *AutoscalingConfig) GetMaxHostsCount() int64
- func (x *AutoscalingConfig) GetMeasurementDuration() *durationpb.Duration
- func (x *AutoscalingConfig) GetPreemptible() bool
- func (x *AutoscalingConfig) GetStabilizationDuration() *durationpb.Duration
- func (x *AutoscalingConfig) GetWarmupDuration() *durationpb.Duration
- func (*AutoscalingConfig) ProtoMessage()
- func (x *AutoscalingConfig) ProtoReflect() protoreflect.Message
- func (x *AutoscalingConfig) Reset()
- func (m *AutoscalingConfig) SetCpuUtilizationTarget(v float64)
- func (m *AutoscalingConfig) SetDecommissionTimeout(v int64)
- func (m *AutoscalingConfig) SetMaxHostsCount(v int64)
- func (m *AutoscalingConfig) SetMeasurementDuration(v *durationpb.Duration)
- func (m *AutoscalingConfig) SetPreemptible(v bool)
- func (m *AutoscalingConfig) SetStabilizationDuration(v *durationpb.Duration)
- func (m *AutoscalingConfig) SetWarmupDuration(v *durationpb.Duration)
- func (x *AutoscalingConfig) String() string
- type CancelJobRequest
- func (*CancelJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelJobRequest) GetClusterId() string
- func (x *CancelJobRequest) GetJobId() string
- func (*CancelJobRequest) ProtoMessage()
- func (x *CancelJobRequest) ProtoReflect() protoreflect.Message
- func (x *CancelJobRequest) Reset()
- func (m *CancelJobRequest) SetClusterId(v string)
- func (m *CancelJobRequest) SetJobId(v string)
- func (x *CancelJobRequest) String() string
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetBucket() string
- func (x *Cluster) GetConfig() *ClusterConfig
- func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp
- func (x *Cluster) GetDeletionProtection() bool
- func (x *Cluster) GetDescription() string
- func (x *Cluster) GetFolderId() string
- func (x *Cluster) GetHealth() Health
- func (x *Cluster) GetHostGroupIds() []string
- func (x *Cluster) GetId() string
- func (x *Cluster) GetLabels() map[string]string
- func (x *Cluster) GetLogGroupId() string
- func (x *Cluster) GetMonitoring() []*Monitoring
- func (x *Cluster) GetName() string
- func (x *Cluster) GetSecurityGroupIds() []string
- func (x *Cluster) GetServiceAccountId() string
- func (x *Cluster) GetStatus() Cluster_Status
- func (x *Cluster) GetUiProxy() bool
- func (x *Cluster) GetZoneId() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (m *Cluster) SetBucket(v string)
- func (m *Cluster) SetConfig(v *ClusterConfig)
- func (m *Cluster) SetCreatedAt(v *timestamppb.Timestamp)
- func (m *Cluster) SetDeletionProtection(v bool)
- func (m *Cluster) SetDescription(v string)
- func (m *Cluster) SetFolderId(v string)
- func (m *Cluster) SetHealth(v Health)
- func (m *Cluster) SetHostGroupIds(v []string)
- func (m *Cluster) SetId(v string)
- func (m *Cluster) SetLabels(v map[string]string)
- func (m *Cluster) SetLogGroupId(v string)
- func (m *Cluster) SetMonitoring(v []*Monitoring)
- func (m *Cluster) SetName(v string)
- func (m *Cluster) SetSecurityGroupIds(v []string)
- func (m *Cluster) SetServiceAccountId(v string)
- func (m *Cluster) SetStatus(v Cluster_Status)
- func (m *Cluster) SetUiProxy(v bool)
- func (m *Cluster) SetZoneId(v string)
- func (x *Cluster) String() string
- type ClusterConfig
- func (*ClusterConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterConfig) GetHadoop() *HadoopConfig
- func (x *ClusterConfig) GetVersionId() string
- func (*ClusterConfig) ProtoMessage()
- func (x *ClusterConfig) ProtoReflect() protoreflect.Message
- func (x *ClusterConfig) Reset()
- func (m *ClusterConfig) SetHadoop(v *HadoopConfig)
- func (m *ClusterConfig) SetVersionId(v string)
- func (x *ClusterConfig) String() string
- type ClusterServiceClient
- type ClusterServiceServer
- type Cluster_Status
- func (Cluster_Status) Descriptor() protoreflect.EnumDescriptor
- func (x Cluster_Status) Enum() *Cluster_Status
- func (Cluster_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x Cluster_Status) Number() protoreflect.EnumNumber
- func (x Cluster_Status) String() string
- func (Cluster_Status) Type() protoreflect.EnumType
- type CreateClusterConfigSpec
- func (*CreateClusterConfigSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterConfigSpec) GetHadoop() *HadoopConfig
- func (x *CreateClusterConfigSpec) GetSubclustersSpec() []*CreateSubclusterConfigSpec
- func (x *CreateClusterConfigSpec) GetVersionId() string
- func (*CreateClusterConfigSpec) ProtoMessage()
- func (x *CreateClusterConfigSpec) ProtoReflect() protoreflect.Message
- func (x *CreateClusterConfigSpec) Reset()
- func (m *CreateClusterConfigSpec) SetHadoop(v *HadoopConfig)
- func (m *CreateClusterConfigSpec) SetSubclustersSpec(v []*CreateSubclusterConfigSpec)
- func (m *CreateClusterConfigSpec) SetVersionId(v string)
- func (x *CreateClusterConfigSpec) String() string
- type CreateClusterMetadata
- func (*CreateClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterMetadata) GetClusterId() string
- func (*CreateClusterMetadata) ProtoMessage()
- func (x *CreateClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *CreateClusterMetadata) Reset()
- func (m *CreateClusterMetadata) SetClusterId(v string)
- func (x *CreateClusterMetadata) String() string
- type CreateClusterRequest
- func (*CreateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterRequest) GetBucket() string
- func (x *CreateClusterRequest) GetConfigSpec() *CreateClusterConfigSpec
- func (x *CreateClusterRequest) GetDeletionProtection() bool
- func (x *CreateClusterRequest) GetDescription() string
- func (x *CreateClusterRequest) GetFolderId() string
- func (x *CreateClusterRequest) GetHostGroupIds() []string
- func (x *CreateClusterRequest) GetLabels() map[string]string
- func (x *CreateClusterRequest) GetLogGroupId() string
- func (x *CreateClusterRequest) GetName() string
- func (x *CreateClusterRequest) GetSecurityGroupIds() []string
- func (x *CreateClusterRequest) GetServiceAccountId() string
- func (x *CreateClusterRequest) GetUiProxy() bool
- func (x *CreateClusterRequest) GetZoneId() string
- func (*CreateClusterRequest) ProtoMessage()
- func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *CreateClusterRequest) Reset()
- func (m *CreateClusterRequest) SetBucket(v string)
- func (m *CreateClusterRequest) SetConfigSpec(v *CreateClusterConfigSpec)
- func (m *CreateClusterRequest) SetDeletionProtection(v bool)
- func (m *CreateClusterRequest) SetDescription(v string)
- func (m *CreateClusterRequest) SetFolderId(v string)
- func (m *CreateClusterRequest) SetHostGroupIds(v []string)
- func (m *CreateClusterRequest) SetLabels(v map[string]string)
- func (m *CreateClusterRequest) SetLogGroupId(v string)
- func (m *CreateClusterRequest) SetName(v string)
- func (m *CreateClusterRequest) SetSecurityGroupIds(v []string)
- func (m *CreateClusterRequest) SetServiceAccountId(v string)
- func (m *CreateClusterRequest) SetUiProxy(v bool)
- func (m *CreateClusterRequest) SetZoneId(v string)
- func (x *CreateClusterRequest) String() string
- type CreateJobMetadata
- func (*CreateJobMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CreateJobMetadata) GetClusterId() string
- func (x *CreateJobMetadata) GetJobId() string
- func (*CreateJobMetadata) ProtoMessage()
- func (x *CreateJobMetadata) ProtoReflect() protoreflect.Message
- func (x *CreateJobMetadata) Reset()
- func (m *CreateJobMetadata) SetClusterId(v string)
- func (m *CreateJobMetadata) SetJobId(v string)
- func (x *CreateJobMetadata) String() string
- type CreateJobRequest
- func (*CreateJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateJobRequest) GetClusterId() string
- func (x *CreateJobRequest) GetHiveJob() *HiveJob
- func (m *CreateJobRequest) GetJobSpec() isCreateJobRequest_JobSpec
- func (x *CreateJobRequest) GetMapreduceJob() *MapreduceJob
- func (x *CreateJobRequest) GetName() string
- func (x *CreateJobRequest) GetPysparkJob() *PysparkJob
- func (x *CreateJobRequest) GetSparkJob() *SparkJob
- func (*CreateJobRequest) ProtoMessage()
- func (x *CreateJobRequest) ProtoReflect() protoreflect.Message
- func (x *CreateJobRequest) Reset()
- func (m *CreateJobRequest) SetClusterId(v string)
- func (m *CreateJobRequest) SetHiveJob(v *HiveJob)
- func (m *CreateJobRequest) SetJobSpec(v CreateJobRequest_JobSpec)
- func (m *CreateJobRequest) SetMapreduceJob(v *MapreduceJob)
- func (m *CreateJobRequest) SetName(v string)
- func (m *CreateJobRequest) SetPysparkJob(v *PysparkJob)
- func (m *CreateJobRequest) SetSparkJob(v *SparkJob)
- func (x *CreateJobRequest) String() string
- type CreateJobRequest_HiveJob
- type CreateJobRequest_JobSpec
- type CreateJobRequest_MapreduceJob
- type CreateJobRequest_PysparkJob
- type CreateJobRequest_SparkJob
- type CreateSubclusterConfigSpec
- func (*CreateSubclusterConfigSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubclusterConfigSpec) GetAssignPublicIp() bool
- func (x *CreateSubclusterConfigSpec) GetAutoscalingConfig() *AutoscalingConfig
- func (x *CreateSubclusterConfigSpec) GetHostsCount() int64
- func (x *CreateSubclusterConfigSpec) GetName() string
- func (x *CreateSubclusterConfigSpec) GetResources() *Resources
- func (x *CreateSubclusterConfigSpec) GetRole() Role
- func (x *CreateSubclusterConfigSpec) GetSubnetId() string
- func (*CreateSubclusterConfigSpec) ProtoMessage()
- func (x *CreateSubclusterConfigSpec) ProtoReflect() protoreflect.Message
- func (x *CreateSubclusterConfigSpec) Reset()
- func (m *CreateSubclusterConfigSpec) SetAssignPublicIp(v bool)
- func (m *CreateSubclusterConfigSpec) SetAutoscalingConfig(v *AutoscalingConfig)
- func (m *CreateSubclusterConfigSpec) SetHostsCount(v int64)
- func (m *CreateSubclusterConfigSpec) SetName(v string)
- func (m *CreateSubclusterConfigSpec) SetResources(v *Resources)
- func (m *CreateSubclusterConfigSpec) SetRole(v Role)
- func (m *CreateSubclusterConfigSpec) SetSubnetId(v string)
- func (x *CreateSubclusterConfigSpec) String() string
- type CreateSubclusterMetadata
- func (*CreateSubclusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubclusterMetadata) GetClusterId() string
- func (x *CreateSubclusterMetadata) GetSubclusterId() string
- func (*CreateSubclusterMetadata) ProtoMessage()
- func (x *CreateSubclusterMetadata) ProtoReflect() protoreflect.Message
- func (x *CreateSubclusterMetadata) Reset()
- func (m *CreateSubclusterMetadata) SetClusterId(v string)
- func (m *CreateSubclusterMetadata) SetSubclusterId(v string)
- func (x *CreateSubclusterMetadata) String() string
- type CreateSubclusterRequest
- func (*CreateSubclusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubclusterRequest) GetAutoscalingConfig() *AutoscalingConfig
- func (x *CreateSubclusterRequest) GetClusterId() string
- func (x *CreateSubclusterRequest) GetHostsCount() int64
- func (x *CreateSubclusterRequest) GetName() string
- func (x *CreateSubclusterRequest) GetResources() *Resources
- func (x *CreateSubclusterRequest) GetRole() Role
- func (x *CreateSubclusterRequest) GetSubnetId() string
- func (*CreateSubclusterRequest) ProtoMessage()
- func (x *CreateSubclusterRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSubclusterRequest) Reset()
- func (m *CreateSubclusterRequest) SetAutoscalingConfig(v *AutoscalingConfig)
- func (m *CreateSubclusterRequest) SetClusterId(v string)
- func (m *CreateSubclusterRequest) SetHostsCount(v int64)
- func (m *CreateSubclusterRequest) SetName(v string)
- func (m *CreateSubclusterRequest) SetResources(v *Resources)
- func (m *CreateSubclusterRequest) SetRole(v Role)
- func (m *CreateSubclusterRequest) SetSubnetId(v string)
- func (x *CreateSubclusterRequest) String() string
- type DeleteClusterMetadata
- func (*DeleteClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteClusterMetadata) GetClusterId() string
- func (*DeleteClusterMetadata) ProtoMessage()
- func (x *DeleteClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterMetadata) Reset()
- func (m *DeleteClusterMetadata) SetClusterId(v string)
- func (x *DeleteClusterMetadata) String() string
- type DeleteClusterRequest
- func (*DeleteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteClusterRequest) GetClusterId() string
- func (x *DeleteClusterRequest) GetDecommissionTimeout() int64
- func (*DeleteClusterRequest) ProtoMessage()
- func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterRequest) Reset()
- func (m *DeleteClusterRequest) SetClusterId(v string)
- func (m *DeleteClusterRequest) SetDecommissionTimeout(v int64)
- func (x *DeleteClusterRequest) String() string
- type DeleteSubclusterMetadata
- func (*DeleteSubclusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSubclusterMetadata) GetClusterId() string
- func (x *DeleteSubclusterMetadata) GetSubclusterId() string
- func (*DeleteSubclusterMetadata) ProtoMessage()
- func (x *DeleteSubclusterMetadata) ProtoReflect() protoreflect.Message
- func (x *DeleteSubclusterMetadata) Reset()
- func (m *DeleteSubclusterMetadata) SetClusterId(v string)
- func (m *DeleteSubclusterMetadata) SetSubclusterId(v string)
- func (x *DeleteSubclusterMetadata) String() string
- type DeleteSubclusterRequest
- func (*DeleteSubclusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSubclusterRequest) GetClusterId() string
- func (x *DeleteSubclusterRequest) GetDecommissionTimeout() int64
- func (x *DeleteSubclusterRequest) GetSubclusterId() string
- func (*DeleteSubclusterRequest) ProtoMessage()
- func (x *DeleteSubclusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSubclusterRequest) Reset()
- func (m *DeleteSubclusterRequest) SetClusterId(v string)
- func (m *DeleteSubclusterRequest) SetDecommissionTimeout(v int64)
- func (m *DeleteSubclusterRequest) SetSubclusterId(v string)
- func (x *DeleteSubclusterRequest) String() string
- type GetClusterRequest
- func (*GetClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetClusterRequest) GetClusterId() string
- func (*GetClusterRequest) ProtoMessage()
- func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
- func (x *GetClusterRequest) Reset()
- func (m *GetClusterRequest) SetClusterId(v string)
- func (x *GetClusterRequest) String() string
- type GetJobRequest
- func (*GetJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobRequest) GetClusterId() string
- func (x *GetJobRequest) GetJobId() string
- func (*GetJobRequest) ProtoMessage()
- func (x *GetJobRequest) ProtoReflect() protoreflect.Message
- func (x *GetJobRequest) Reset()
- func (m *GetJobRequest) SetClusterId(v string)
- func (m *GetJobRequest) SetJobId(v string)
- func (x *GetJobRequest) String() string
- type GetResourcePresetRequest
- func (*GetResourcePresetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourcePresetRequest) GetResourcePresetId() string
- func (*GetResourcePresetRequest) ProtoMessage()
- func (x *GetResourcePresetRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourcePresetRequest) Reset()
- func (m *GetResourcePresetRequest) SetResourcePresetId(v string)
- func (x *GetResourcePresetRequest) String() string
- type GetSubclusterRequest
- func (*GetSubclusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSubclusterRequest) GetClusterId() string
- func (x *GetSubclusterRequest) GetSubclusterId() string
- func (*GetSubclusterRequest) ProtoMessage()
- func (x *GetSubclusterRequest) ProtoReflect() protoreflect.Message
- func (x *GetSubclusterRequest) Reset()
- func (m *GetSubclusterRequest) SetClusterId(v string)
- func (m *GetSubclusterRequest) SetSubclusterId(v string)
- func (x *GetSubclusterRequest) String() string
- type HadoopConfig
- func (*HadoopConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HadoopConfig) GetInitializationActions() []*InitializationAction
- func (x *HadoopConfig) GetProperties() map[string]string
- func (x *HadoopConfig) GetServices() []HadoopConfig_Service
- func (x *HadoopConfig) GetSshPublicKeys() []string
- func (*HadoopConfig) ProtoMessage()
- func (x *HadoopConfig) ProtoReflect() protoreflect.Message
- func (x *HadoopConfig) Reset()
- func (m *HadoopConfig) SetInitializationActions(v []*InitializationAction)
- func (m *HadoopConfig) SetProperties(v map[string]string)
- func (m *HadoopConfig) SetServices(v []HadoopConfig_Service)
- func (m *HadoopConfig) SetSshPublicKeys(v []string)
- func (x *HadoopConfig) String() string
- type HadoopConfig_Service
- func (HadoopConfig_Service) Descriptor() protoreflect.EnumDescriptor
- func (x HadoopConfig_Service) Enum() *HadoopConfig_Service
- func (HadoopConfig_Service) EnumDescriptor() ([]byte, []int)deprecated
- func (x HadoopConfig_Service) Number() protoreflect.EnumNumber
- func (x HadoopConfig_Service) String() string
- func (HadoopConfig_Service) Type() protoreflect.EnumType
- type Health
- type HiveJob
- func (*HiveJob) Descriptor() ([]byte, []int)deprecated
- func (x *HiveJob) GetContinueOnFailure() bool
- func (x *HiveJob) GetJarFileUris() []string
- func (x *HiveJob) GetProperties() map[string]string
- func (x *HiveJob) GetQueryFileUri() string
- func (x *HiveJob) GetQueryList() *QueryList
- func (m *HiveJob) GetQueryType() isHiveJob_QueryType
- func (x *HiveJob) GetScriptVariables() map[string]string
- func (*HiveJob) ProtoMessage()
- func (x *HiveJob) ProtoReflect() protoreflect.Message
- func (x *HiveJob) Reset()
- func (m *HiveJob) SetContinueOnFailure(v bool)
- func (m *HiveJob) SetJarFileUris(v []string)
- func (m *HiveJob) SetProperties(v map[string]string)
- func (m *HiveJob) SetQueryFileUri(v string)
- func (m *HiveJob) SetQueryList(v *QueryList)
- func (m *HiveJob) SetQueryType(v HiveJob_QueryType)
- func (m *HiveJob) SetScriptVariables(v map[string]string)
- func (x *HiveJob) String() string
- type HiveJob_QueryFileUri
- type HiveJob_QueryList
- type HiveJob_QueryType
- type Host
- func (*Host) Descriptor() ([]byte, []int)deprecated
- func (x *Host) GetComputeInstanceId() string
- func (x *Host) GetHealth() Health
- func (x *Host) GetName() string
- func (x *Host) GetRole() Role
- func (x *Host) GetSubclusterId() string
- func (*Host) ProtoMessage()
- func (x *Host) ProtoReflect() protoreflect.Message
- func (x *Host) Reset()
- func (m *Host) SetComputeInstanceId(v string)
- func (m *Host) SetHealth(v Health)
- func (m *Host) SetName(v string)
- func (m *Host) SetRole(v Role)
- func (m *Host) SetSubclusterId(v string)
- func (x *Host) String() string
- type InitializationAction
- func (*InitializationAction) Descriptor() ([]byte, []int)deprecated
- func (x *InitializationAction) GetArgs() []string
- func (x *InitializationAction) GetTimeout() int64
- func (x *InitializationAction) GetUri() string
- func (*InitializationAction) ProtoMessage()
- func (x *InitializationAction) ProtoReflect() protoreflect.Message
- func (x *InitializationAction) Reset()
- func (m *InitializationAction) SetArgs(v []string)
- func (m *InitializationAction) SetTimeout(v int64)
- func (m *InitializationAction) SetUri(v string)
- func (x *InitializationAction) String() string
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetApplicationInfo() *ApplicationInfo
- func (x *Job) GetClusterId() string
- func (x *Job) GetCreatedAt() *timestamppb.Timestamp
- func (x *Job) GetCreatedBy() string
- func (x *Job) GetFinishedAt() *timestamppb.Timestamp
- func (x *Job) GetHiveJob() *HiveJob
- func (x *Job) GetId() string
- func (m *Job) GetJobSpec() isJob_JobSpec
- func (x *Job) GetMapreduceJob() *MapreduceJob
- func (x *Job) GetName() string
- func (x *Job) GetPysparkJob() *PysparkJob
- func (x *Job) GetSparkJob() *SparkJob
- func (x *Job) GetStartedAt() *timestamppb.Timestamp
- func (x *Job) GetStatus() Job_Status
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (m *Job) SetApplicationInfo(v *ApplicationInfo)
- func (m *Job) SetClusterId(v string)
- func (m *Job) SetCreatedAt(v *timestamppb.Timestamp)
- func (m *Job) SetCreatedBy(v string)
- func (m *Job) SetFinishedAt(v *timestamppb.Timestamp)
- func (m *Job) SetHiveJob(v *HiveJob)
- func (m *Job) SetId(v string)
- func (m *Job) SetJobSpec(v Job_JobSpec)
- func (m *Job) SetMapreduceJob(v *MapreduceJob)
- func (m *Job) SetName(v string)
- func (m *Job) SetPysparkJob(v *PysparkJob)
- func (m *Job) SetSparkJob(v *SparkJob)
- func (m *Job) SetStartedAt(v *timestamppb.Timestamp)
- func (m *Job) SetStatus(v Job_Status)
- func (x *Job) String() string
- type JobServiceClient
- type JobServiceServer
- type Job_HiveJob
- type Job_JobSpec
- type Job_MapreduceJob
- type Job_PysparkJob
- type Job_SparkJob
- type Job_Status
- type ListClusterHostsRequest
- func (*ListClusterHostsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterHostsRequest) GetClusterId() string
- func (x *ListClusterHostsRequest) GetFilter() string
- func (x *ListClusterHostsRequest) GetPageSize() int64
- func (x *ListClusterHostsRequest) GetPageToken() string
- func (*ListClusterHostsRequest) ProtoMessage()
- func (x *ListClusterHostsRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterHostsRequest) Reset()
- func (m *ListClusterHostsRequest) SetClusterId(v string)
- func (m *ListClusterHostsRequest) SetFilter(v string)
- func (m *ListClusterHostsRequest) SetPageSize(v int64)
- func (m *ListClusterHostsRequest) SetPageToken(v string)
- func (x *ListClusterHostsRequest) String() string
- type ListClusterHostsResponse
- func (*ListClusterHostsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterHostsResponse) GetHosts() []*Host
- func (x *ListClusterHostsResponse) GetNextPageToken() string
- func (*ListClusterHostsResponse) ProtoMessage()
- func (x *ListClusterHostsResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterHostsResponse) Reset()
- func (m *ListClusterHostsResponse) SetHosts(v []*Host)
- func (m *ListClusterHostsResponse) SetNextPageToken(v string)
- func (x *ListClusterHostsResponse) String() string
- type ListClusterOperationsRequest
- func (*ListClusterOperationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterOperationsRequest) GetClusterId() string
- func (x *ListClusterOperationsRequest) GetPageSize() int64
- func (x *ListClusterOperationsRequest) GetPageToken() string
- func (*ListClusterOperationsRequest) ProtoMessage()
- func (x *ListClusterOperationsRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterOperationsRequest) Reset()
- func (m *ListClusterOperationsRequest) SetClusterId(v string)
- func (m *ListClusterOperationsRequest) SetPageSize(v int64)
- func (m *ListClusterOperationsRequest) SetPageToken(v string)
- func (x *ListClusterOperationsRequest) String() string
- type ListClusterOperationsResponse
- func (*ListClusterOperationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterOperationsResponse) GetNextPageToken() string
- func (x *ListClusterOperationsResponse) GetOperations() []*operation.Operation
- func (*ListClusterOperationsResponse) ProtoMessage()
- func (x *ListClusterOperationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterOperationsResponse) Reset()
- func (m *ListClusterOperationsResponse) SetNextPageToken(v string)
- func (m *ListClusterOperationsResponse) SetOperations(v []*operation.Operation)
- func (x *ListClusterOperationsResponse) String() string
- type ListClustersRequest
- func (*ListClustersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersRequest) GetFilter() string
- func (x *ListClustersRequest) GetFolderId() string
- func (x *ListClustersRequest) GetPageSize() int64
- func (x *ListClustersRequest) GetPageToken() string
- func (*ListClustersRequest) ProtoMessage()
- func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest) Reset()
- func (m *ListClustersRequest) SetFilter(v string)
- func (m *ListClustersRequest) SetFolderId(v string)
- func (m *ListClustersRequest) SetPageSize(v int64)
- func (m *ListClustersRequest) SetPageToken(v string)
- func (x *ListClustersRequest) String() string
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersResponse) GetClusters() []*Cluster
- func (x *ListClustersResponse) GetNextPageToken() string
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (m *ListClustersResponse) SetClusters(v []*Cluster)
- func (m *ListClustersResponse) SetNextPageToken(v string)
- func (x *ListClustersResponse) String() string
- type ListJobLogRequest
- func (*ListJobLogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobLogRequest) GetClusterId() string
- func (x *ListJobLogRequest) GetJobId() string
- func (x *ListJobLogRequest) GetPageSize() int64
- func (x *ListJobLogRequest) GetPageToken() string
- func (*ListJobLogRequest) ProtoMessage()
- func (x *ListJobLogRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobLogRequest) Reset()
- func (m *ListJobLogRequest) SetClusterId(v string)
- func (m *ListJobLogRequest) SetJobId(v string)
- func (m *ListJobLogRequest) SetPageSize(v int64)
- func (m *ListJobLogRequest) SetPageToken(v string)
- func (x *ListJobLogRequest) String() string
- type ListJobLogResponse
- func (*ListJobLogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobLogResponse) GetContent() string
- func (x *ListJobLogResponse) GetNextPageToken() string
- func (*ListJobLogResponse) ProtoMessage()
- func (x *ListJobLogResponse) ProtoReflect() protoreflect.Message
- func (x *ListJobLogResponse) Reset()
- func (m *ListJobLogResponse) SetContent(v string)
- func (m *ListJobLogResponse) SetNextPageToken(v string)
- func (x *ListJobLogResponse) String() string
- type ListJobsRequest
- func (*ListJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsRequest) GetClusterId() string
- func (x *ListJobsRequest) GetFilter() string
- func (x *ListJobsRequest) GetPageSize() int64
- func (x *ListJobsRequest) GetPageToken() string
- func (*ListJobsRequest) ProtoMessage()
- func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobsRequest) Reset()
- func (m *ListJobsRequest) SetClusterId(v string)
- func (m *ListJobsRequest) SetFilter(v string)
- func (m *ListJobsRequest) SetPageSize(v int64)
- func (m *ListJobsRequest) SetPageToken(v string)
- func (x *ListJobsRequest) String() string
- type ListJobsResponse
- func (*ListJobsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsResponse) GetJobs() []*Job
- func (x *ListJobsResponse) GetNextPageToken() string
- func (*ListJobsResponse) ProtoMessage()
- func (x *ListJobsResponse) ProtoReflect() protoreflect.Message
- func (x *ListJobsResponse) Reset()
- func (m *ListJobsResponse) SetJobs(v []*Job)
- func (m *ListJobsResponse) SetNextPageToken(v string)
- func (x *ListJobsResponse) String() string
- type ListResourcePresetsRequest
- func (*ListResourcePresetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourcePresetsRequest) GetPageSize() int64
- func (x *ListResourcePresetsRequest) GetPageToken() string
- func (*ListResourcePresetsRequest) ProtoMessage()
- func (x *ListResourcePresetsRequest) ProtoReflect() protoreflect.Message
- func (x *ListResourcePresetsRequest) Reset()
- func (m *ListResourcePresetsRequest) SetPageSize(v int64)
- func (m *ListResourcePresetsRequest) SetPageToken(v string)
- func (x *ListResourcePresetsRequest) String() string
- type ListResourcePresetsResponse
- func (*ListResourcePresetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourcePresetsResponse) GetNextPageToken() string
- func (x *ListResourcePresetsResponse) GetResourcePresets() []*ResourcePreset
- func (*ListResourcePresetsResponse) ProtoMessage()
- func (x *ListResourcePresetsResponse) ProtoReflect() protoreflect.Message
- func (x *ListResourcePresetsResponse) Reset()
- func (m *ListResourcePresetsResponse) SetNextPageToken(v string)
- func (m *ListResourcePresetsResponse) SetResourcePresets(v []*ResourcePreset)
- func (x *ListResourcePresetsResponse) String() string
- type ListSubclustersRequest
- func (*ListSubclustersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubclustersRequest) GetClusterId() string
- func (x *ListSubclustersRequest) GetFilter() string
- func (x *ListSubclustersRequest) GetPageSize() int64
- func (x *ListSubclustersRequest) GetPageToken() string
- func (*ListSubclustersRequest) ProtoMessage()
- func (x *ListSubclustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubclustersRequest) Reset()
- func (m *ListSubclustersRequest) SetClusterId(v string)
- func (m *ListSubclustersRequest) SetFilter(v string)
- func (m *ListSubclustersRequest) SetPageSize(v int64)
- func (m *ListSubclustersRequest) SetPageToken(v string)
- func (x *ListSubclustersRequest) String() string
- type ListSubclustersResponse
- func (*ListSubclustersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubclustersResponse) GetNextPageToken() string
- func (x *ListSubclustersResponse) GetSubclusters() []*Subcluster
- func (*ListSubclustersResponse) ProtoMessage()
- func (x *ListSubclustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListSubclustersResponse) Reset()
- func (m *ListSubclustersResponse) SetNextPageToken(v string)
- func (m *ListSubclustersResponse) SetSubclusters(v []*Subcluster)
- func (x *ListSubclustersResponse) String() string
- type ListUILinksRequest
- func (*ListUILinksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListUILinksRequest) GetClusterId() string
- func (*ListUILinksRequest) ProtoMessage()
- func (x *ListUILinksRequest) ProtoReflect() protoreflect.Message
- func (x *ListUILinksRequest) Reset()
- func (m *ListUILinksRequest) SetClusterId(v string)
- func (x *ListUILinksRequest) String() string
- type ListUILinksResponse
- func (*ListUILinksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListUILinksResponse) GetLinks() []*UILink
- func (*ListUILinksResponse) ProtoMessage()
- func (x *ListUILinksResponse) ProtoReflect() protoreflect.Message
- func (x *ListUILinksResponse) Reset()
- func (m *ListUILinksResponse) SetLinks(v []*UILink)
- func (x *ListUILinksResponse) String() string
- type MapreduceJob
- func (*MapreduceJob) Descriptor() ([]byte, []int)deprecated
- func (x *MapreduceJob) GetArchiveUris() []string
- func (x *MapreduceJob) GetArgs() []string
- func (m *MapreduceJob) GetDriver() isMapreduceJob_Driver
- func (x *MapreduceJob) GetFileUris() []string
- func (x *MapreduceJob) GetJarFileUris() []string
- func (x *MapreduceJob) GetMainClass() string
- func (x *MapreduceJob) GetMainJarFileUri() string
- func (x *MapreduceJob) GetProperties() map[string]string
- func (*MapreduceJob) ProtoMessage()
- func (x *MapreduceJob) ProtoReflect() protoreflect.Message
- func (x *MapreduceJob) Reset()
- func (m *MapreduceJob) SetArchiveUris(v []string)
- func (m *MapreduceJob) SetArgs(v []string)
- func (m *MapreduceJob) SetDriver(v MapreduceJob_Driver)
- func (m *MapreduceJob) SetFileUris(v []string)
- func (m *MapreduceJob) SetJarFileUris(v []string)
- func (m *MapreduceJob) SetMainClass(v string)
- func (m *MapreduceJob) SetMainJarFileUri(v string)
- func (m *MapreduceJob) SetProperties(v map[string]string)
- func (x *MapreduceJob) String() string
- type MapreduceJob_Driver
- type MapreduceJob_MainClass
- type MapreduceJob_MainJarFileUri
- type Monitoring
- func (*Monitoring) Descriptor() ([]byte, []int)deprecated
- func (x *Monitoring) GetDescription() string
- func (x *Monitoring) GetLink() string
- func (x *Monitoring) GetName() string
- func (*Monitoring) ProtoMessage()
- func (x *Monitoring) ProtoReflect() protoreflect.Message
- func (x *Monitoring) Reset()
- func (m *Monitoring) SetDescription(v string)
- func (m *Monitoring) SetLink(v string)
- func (m *Monitoring) SetName(v string)
- func (x *Monitoring) String() string
- type PysparkJob
- func (*PysparkJob) Descriptor() ([]byte, []int)deprecated
- func (x *PysparkJob) GetArchiveUris() []string
- func (x *PysparkJob) GetArgs() []string
- func (x *PysparkJob) GetExcludePackages() []string
- func (x *PysparkJob) GetFileUris() []string
- func (x *PysparkJob) GetJarFileUris() []string
- func (x *PysparkJob) GetMainPythonFileUri() string
- func (x *PysparkJob) GetPackages() []string
- func (x *PysparkJob) GetProperties() map[string]string
- func (x *PysparkJob) GetPythonFileUris() []string
- func (x *PysparkJob) GetRepositories() []string
- func (*PysparkJob) ProtoMessage()
- func (x *PysparkJob) ProtoReflect() protoreflect.Message
- func (x *PysparkJob) Reset()
- func (m *PysparkJob) SetArchiveUris(v []string)
- func (m *PysparkJob) SetArgs(v []string)
- func (m *PysparkJob) SetExcludePackages(v []string)
- func (m *PysparkJob) SetFileUris(v []string)
- func (m *PysparkJob) SetJarFileUris(v []string)
- func (m *PysparkJob) SetMainPythonFileUri(v string)
- func (m *PysparkJob) SetPackages(v []string)
- func (m *PysparkJob) SetProperties(v map[string]string)
- func (m *PysparkJob) SetPythonFileUris(v []string)
- func (m *PysparkJob) SetRepositories(v []string)
- func (x *PysparkJob) String() string
- type QueryList
- type ResourcePreset
- func (*ResourcePreset) Descriptor() ([]byte, []int)deprecated
- func (x *ResourcePreset) GetCores() int64
- func (x *ResourcePreset) GetId() string
- func (x *ResourcePreset) GetMemory() int64
- func (x *ResourcePreset) GetZoneIds() []string
- func (*ResourcePreset) ProtoMessage()
- func (x *ResourcePreset) ProtoReflect() protoreflect.Message
- func (x *ResourcePreset) Reset()
- func (m *ResourcePreset) SetCores(v int64)
- func (m *ResourcePreset) SetId(v string)
- func (m *ResourcePreset) SetMemory(v int64)
- func (m *ResourcePreset) SetZoneIds(v []string)
- func (x *ResourcePreset) String() string
- type ResourcePresetServiceClient
- type ResourcePresetServiceServer
- type Resources
- func (*Resources) Descriptor() ([]byte, []int)deprecated
- func (x *Resources) GetDiskSize() int64
- func (x *Resources) GetDiskTypeId() string
- func (x *Resources) GetResourcePresetId() string
- func (*Resources) ProtoMessage()
- func (x *Resources) ProtoReflect() protoreflect.Message
- func (x *Resources) Reset()
- func (m *Resources) SetDiskSize(v int64)
- func (m *Resources) SetDiskTypeId(v string)
- func (m *Resources) SetResourcePresetId(v string)
- func (x *Resources) String() string
- type Role
- type SparkJob
- func (*SparkJob) Descriptor() ([]byte, []int)deprecated
- func (x *SparkJob) GetArchiveUris() []string
- func (x *SparkJob) GetArgs() []string
- func (x *SparkJob) GetExcludePackages() []string
- func (x *SparkJob) GetFileUris() []string
- func (x *SparkJob) GetJarFileUris() []string
- func (x *SparkJob) GetMainClass() string
- func (x *SparkJob) GetMainJarFileUri() string
- func (x *SparkJob) GetPackages() []string
- func (x *SparkJob) GetProperties() map[string]string
- func (x *SparkJob) GetRepositories() []string
- func (*SparkJob) ProtoMessage()
- func (x *SparkJob) ProtoReflect() protoreflect.Message
- func (x *SparkJob) Reset()
- func (m *SparkJob) SetArchiveUris(v []string)
- func (m *SparkJob) SetArgs(v []string)
- func (m *SparkJob) SetExcludePackages(v []string)
- func (m *SparkJob) SetFileUris(v []string)
- func (m *SparkJob) SetJarFileUris(v []string)
- func (m *SparkJob) SetMainClass(v string)
- func (m *SparkJob) SetMainJarFileUri(v string)
- func (m *SparkJob) SetPackages(v []string)
- func (m *SparkJob) SetProperties(v map[string]string)
- func (m *SparkJob) SetRepositories(v []string)
- func (x *SparkJob) String() string
- type StartClusterMetadata
- func (*StartClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *StartClusterMetadata) GetClusterId() string
- func (*StartClusterMetadata) ProtoMessage()
- func (x *StartClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *StartClusterMetadata) Reset()
- func (m *StartClusterMetadata) SetClusterId(v string)
- func (x *StartClusterMetadata) String() string
- type StartClusterRequest
- func (*StartClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartClusterRequest) GetClusterId() string
- func (*StartClusterRequest) ProtoMessage()
- func (x *StartClusterRequest) ProtoReflect() protoreflect.Message
- func (x *StartClusterRequest) Reset()
- func (m *StartClusterRequest) SetClusterId(v string)
- func (x *StartClusterRequest) String() string
- type StopClusterMetadata
- func (*StopClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *StopClusterMetadata) GetClusterId() string
- func (*StopClusterMetadata) ProtoMessage()
- func (x *StopClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *StopClusterMetadata) Reset()
- func (m *StopClusterMetadata) SetClusterId(v string)
- func (x *StopClusterMetadata) String() string
- type StopClusterRequest
- func (*StopClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopClusterRequest) GetClusterId() string
- func (x *StopClusterRequest) GetDecommissionTimeout() int64
- func (*StopClusterRequest) ProtoMessage()
- func (x *StopClusterRequest) ProtoReflect() protoreflect.Message
- func (x *StopClusterRequest) Reset()
- func (m *StopClusterRequest) SetClusterId(v string)
- func (m *StopClusterRequest) SetDecommissionTimeout(v int64)
- func (x *StopClusterRequest) String() string
- type Subcluster
- func (*Subcluster) Descriptor() ([]byte, []int)deprecated
- func (x *Subcluster) GetAssignPublicIp() bool
- func (x *Subcluster) GetAutoscalingConfig() *AutoscalingConfig
- func (x *Subcluster) GetClusterId() string
- func (x *Subcluster) GetCreatedAt() *timestamppb.Timestamp
- func (x *Subcluster) GetHostsCount() int64
- func (x *Subcluster) GetId() string
- func (x *Subcluster) GetInstanceGroupId() string
- func (x *Subcluster) GetName() string
- func (x *Subcluster) GetResources() *Resources
- func (x *Subcluster) GetRole() Role
- func (x *Subcluster) GetSubnetId() string
- func (*Subcluster) ProtoMessage()
- func (x *Subcluster) ProtoReflect() protoreflect.Message
- func (x *Subcluster) Reset()
- func (m *Subcluster) SetAssignPublicIp(v bool)
- func (m *Subcluster) SetAutoscalingConfig(v *AutoscalingConfig)
- func (m *Subcluster) SetClusterId(v string)
- func (m *Subcluster) SetCreatedAt(v *timestamppb.Timestamp)
- func (m *Subcluster) SetHostsCount(v int64)
- func (m *Subcluster) SetId(v string)
- func (m *Subcluster) SetInstanceGroupId(v string)
- func (m *Subcluster) SetName(v string)
- func (m *Subcluster) SetResources(v *Resources)
- func (m *Subcluster) SetRole(v Role)
- func (m *Subcluster) SetSubnetId(v string)
- func (x *Subcluster) String() string
- type SubclusterServiceClient
- type SubclusterServiceServer
- type UILink
- func (*UILink) Descriptor() ([]byte, []int)deprecated
- func (x *UILink) GetName() string
- func (x *UILink) GetUrl() string
- func (*UILink) ProtoMessage()
- func (x *UILink) ProtoReflect() protoreflect.Message
- func (x *UILink) Reset()
- func (m *UILink) SetName(v string)
- func (m *UILink) SetUrl(v string)
- func (x *UILink) String() string
- type UnimplementedClusterServiceServer
- func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)
- func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)
- func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)
- func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
- func (UnimplementedClusterServiceServer) ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
- func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
- func (UnimplementedClusterServiceServer) ListUILinks(context.Context, *ListUILinksRequest) (*ListUILinksResponse, error)
- func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*operation.Operation, error)
- func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)
- func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)
- type UnimplementedJobServiceServer
- func (UnimplementedJobServiceServer) Cancel(context.Context, *CancelJobRequest) (*operation.Operation, error)
- func (UnimplementedJobServiceServer) Create(context.Context, *CreateJobRequest) (*operation.Operation, error)
- func (UnimplementedJobServiceServer) Get(context.Context, *GetJobRequest) (*Job, error)
- func (UnimplementedJobServiceServer) List(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
- func (UnimplementedJobServiceServer) ListLog(context.Context, *ListJobLogRequest) (*ListJobLogResponse, error)
- type UnimplementedResourcePresetServiceServer
- type UnimplementedSubclusterServiceServer
- func (UnimplementedSubclusterServiceServer) Create(context.Context, *CreateSubclusterRequest) (*operation.Operation, error)
- func (UnimplementedSubclusterServiceServer) Delete(context.Context, *DeleteSubclusterRequest) (*operation.Operation, error)
- func (UnimplementedSubclusterServiceServer) Get(context.Context, *GetSubclusterRequest) (*Subcluster, error)
- func (UnimplementedSubclusterServiceServer) List(context.Context, *ListSubclustersRequest) (*ListSubclustersResponse, error)
- func (UnimplementedSubclusterServiceServer) Update(context.Context, *UpdateSubclusterRequest) (*operation.Operation, error)
- type UnsafeClusterServiceServer
- type UnsafeJobServiceServer
- type UnsafeResourcePresetServiceServer
- type UnsafeSubclusterServiceServer
- type UpdateClusterConfigSpec
- func (*UpdateClusterConfigSpec) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterConfigSpec) GetHadoop() *HadoopConfig
- func (x *UpdateClusterConfigSpec) GetSubclustersSpec() []*UpdateSubclusterConfigSpec
- func (*UpdateClusterConfigSpec) ProtoMessage()
- func (x *UpdateClusterConfigSpec) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterConfigSpec) Reset()
- func (m *UpdateClusterConfigSpec) SetHadoop(v *HadoopConfig)
- func (m *UpdateClusterConfigSpec) SetSubclustersSpec(v []*UpdateSubclusterConfigSpec)
- func (x *UpdateClusterConfigSpec) String() string
- type UpdateClusterMetadata
- func (*UpdateClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterMetadata) GetClusterId() string
- func (*UpdateClusterMetadata) ProtoMessage()
- func (x *UpdateClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterMetadata) Reset()
- func (m *UpdateClusterMetadata) SetClusterId(v string)
- func (x *UpdateClusterMetadata) String() string
- type UpdateClusterRequest
- func (*UpdateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterRequest) GetBucket() string
- func (x *UpdateClusterRequest) GetClusterId() string
- func (x *UpdateClusterRequest) GetConfigSpec() *UpdateClusterConfigSpec
- func (x *UpdateClusterRequest) GetDecommissionTimeout() int64
- func (x *UpdateClusterRequest) GetDeletionProtection() bool
- func (x *UpdateClusterRequest) GetDescription() string
- func (x *UpdateClusterRequest) GetLabels() map[string]string
- func (x *UpdateClusterRequest) GetLogGroupId() string
- func (x *UpdateClusterRequest) GetName() string
- func (x *UpdateClusterRequest) GetSecurityGroupIds() []string
- func (x *UpdateClusterRequest) GetServiceAccountId() string
- func (x *UpdateClusterRequest) GetUiProxy() bool
- func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateClusterRequest) ProtoMessage()
- func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterRequest) Reset()
- func (m *UpdateClusterRequest) SetBucket(v string)
- func (m *UpdateClusterRequest) SetClusterId(v string)
- func (m *UpdateClusterRequest) SetConfigSpec(v *UpdateClusterConfigSpec)
- func (m *UpdateClusterRequest) SetDecommissionTimeout(v int64)
- func (m *UpdateClusterRequest) SetDeletionProtection(v bool)
- func (m *UpdateClusterRequest) SetDescription(v string)
- func (m *UpdateClusterRequest) SetLabels(v map[string]string)
- func (m *UpdateClusterRequest) SetLogGroupId(v string)
- func (m *UpdateClusterRequest) SetName(v string)
- func (m *UpdateClusterRequest) SetSecurityGroupIds(v []string)
- func (m *UpdateClusterRequest) SetServiceAccountId(v string)
- func (m *UpdateClusterRequest) SetUiProxy(v bool)
- func (m *UpdateClusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)
- func (x *UpdateClusterRequest) String() string
- type UpdateSubclusterConfigSpec
- func (*UpdateSubclusterConfigSpec) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSubclusterConfigSpec) GetAutoscalingConfig() *AutoscalingConfig
- func (x *UpdateSubclusterConfigSpec) GetHostsCount() int64
- func (x *UpdateSubclusterConfigSpec) GetId() string
- func (x *UpdateSubclusterConfigSpec) GetName() string
- func (x *UpdateSubclusterConfigSpec) GetResources() *Resources
- func (*UpdateSubclusterConfigSpec) ProtoMessage()
- func (x *UpdateSubclusterConfigSpec) ProtoReflect() protoreflect.Message
- func (x *UpdateSubclusterConfigSpec) Reset()
- func (m *UpdateSubclusterConfigSpec) SetAutoscalingConfig(v *AutoscalingConfig)
- func (m *UpdateSubclusterConfigSpec) SetHostsCount(v int64)
- func (m *UpdateSubclusterConfigSpec) SetId(v string)
- func (m *UpdateSubclusterConfigSpec) SetName(v string)
- func (m *UpdateSubclusterConfigSpec) SetResources(v *Resources)
- func (x *UpdateSubclusterConfigSpec) String() string
- type UpdateSubclusterMetadata
- func (*UpdateSubclusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSubclusterMetadata) GetClusterId() string
- func (x *UpdateSubclusterMetadata) GetSubclusterId() string
- func (*UpdateSubclusterMetadata) ProtoMessage()
- func (x *UpdateSubclusterMetadata) ProtoReflect() protoreflect.Message
- func (x *UpdateSubclusterMetadata) Reset()
- func (m *UpdateSubclusterMetadata) SetClusterId(v string)
- func (m *UpdateSubclusterMetadata) SetSubclusterId(v string)
- func (x *UpdateSubclusterMetadata) String() string
- type UpdateSubclusterRequest
- func (*UpdateSubclusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSubclusterRequest) GetAutoscalingConfig() *AutoscalingConfig
- func (x *UpdateSubclusterRequest) GetClusterId() string
- func (x *UpdateSubclusterRequest) GetDecommissionTimeout() int64
- func (x *UpdateSubclusterRequest) GetHostsCount() int64
- func (x *UpdateSubclusterRequest) GetName() string
- func (x *UpdateSubclusterRequest) GetResources() *Resources
- func (x *UpdateSubclusterRequest) GetSubclusterId() string
- func (x *UpdateSubclusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateSubclusterRequest) ProtoMessage()
- func (x *UpdateSubclusterRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSubclusterRequest) Reset()
- func (m *UpdateSubclusterRequest) SetAutoscalingConfig(v *AutoscalingConfig)
- func (m *UpdateSubclusterRequest) SetClusterId(v string)
- func (m *UpdateSubclusterRequest) SetDecommissionTimeout(v int64)
- func (m *UpdateSubclusterRequest) SetHostsCount(v int64)
- func (m *UpdateSubclusterRequest) SetName(v string)
- func (m *UpdateSubclusterRequest) SetResources(v *Resources)
- func (m *UpdateSubclusterRequest) SetSubclusterId(v string)
- func (m *UpdateSubclusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)
- func (x *UpdateSubclusterRequest) String() string
Constants ¶
const ( ClusterService_Get_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Get" ClusterService_List_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/List" ClusterService_Create_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Create" ClusterService_Update_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Update" ClusterService_Delete_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Delete" ClusterService_Start_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Start" ClusterService_Stop_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/Stop" ClusterService_ListOperations_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/ListOperations" ClusterService_ListHosts_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/ListHosts" ClusterService_ListUILinks_FullMethodName = "/yandex.cloud.dataproc.v1.ClusterService/ListUILinks" )
const ( JobService_List_FullMethodName = "/yandex.cloud.dataproc.v1.JobService/List" JobService_Create_FullMethodName = "/yandex.cloud.dataproc.v1.JobService/Create" JobService_Get_FullMethodName = "/yandex.cloud.dataproc.v1.JobService/Get" JobService_ListLog_FullMethodName = "/yandex.cloud.dataproc.v1.JobService/ListLog" JobService_Cancel_FullMethodName = "/yandex.cloud.dataproc.v1.JobService/Cancel" )
const ( ResourcePresetService_Get_FullMethodName = "/yandex.cloud.dataproc.v1.ResourcePresetService/Get" ResourcePresetService_List_FullMethodName = "/yandex.cloud.dataproc.v1.ResourcePresetService/List" )
const ( SubclusterService_Get_FullMethodName = "/yandex.cloud.dataproc.v1.SubclusterService/Get" SubclusterService_List_FullMethodName = "/yandex.cloud.dataproc.v1.SubclusterService/List" SubclusterService_Create_FullMethodName = "/yandex.cloud.dataproc.v1.SubclusterService/Create" SubclusterService_Update_FullMethodName = "/yandex.cloud.dataproc.v1.SubclusterService/Update" SubclusterService_Delete_FullMethodName = "/yandex.cloud.dataproc.v1.SubclusterService/Delete" )
Variables ¶
var ( Cluster_Status_name = map[int32]string{ 0: "STATUS_UNKNOWN", 1: "CREATING", 2: "RUNNING", 3: "ERROR", 4: "STOPPING", 5: "STOPPED", 6: "STARTING", } Cluster_Status_value = map[string]int32{ "STATUS_UNKNOWN": 0, "CREATING": 1, "RUNNING": 2, "ERROR": 3, "STOPPING": 4, "STOPPED": 5, "STARTING": 6, } )
Enum value maps for Cluster_Status.
var ( HadoopConfig_Service_name = map[int32]string{ 0: "SERVICE_UNSPECIFIED", 1: "HDFS", 2: "YARN", 3: "MAPREDUCE", 4: "HIVE", 5: "TEZ", 6: "ZOOKEEPER", 7: "HBASE", 8: "SQOOP", 9: "FLUME", 10: "SPARK", 11: "ZEPPELIN", 12: "OOZIE", 13: "LIVY", } HadoopConfig_Service_value = map[string]int32{ "SERVICE_UNSPECIFIED": 0, "HDFS": 1, "YARN": 2, "MAPREDUCE": 3, "HIVE": 4, "TEZ": 5, "ZOOKEEPER": 6, "HBASE": 7, "SQOOP": 8, "FLUME": 9, "SPARK": 10, "ZEPPELIN": 11, "OOZIE": 12, "LIVY": 13, } )
Enum value maps for HadoopConfig_Service.
var ( Health_name = map[int32]string{ 0: "HEALTH_UNKNOWN", 1: "ALIVE", 2: "DEAD", 3: "DEGRADED", } Health_value = map[string]int32{ "HEALTH_UNKNOWN": 0, "ALIVE": 1, "DEAD": 2, "DEGRADED": 3, } )
Enum value maps for Health.
var ( Job_Status_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "PROVISIONING", 2: "PENDING", 3: "RUNNING", 4: "ERROR", 5: "DONE", 6: "CANCELLED", 7: "CANCELLING", } Job_Status_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "PROVISIONING": 1, "PENDING": 2, "RUNNING": 3, "ERROR": 4, "DONE": 5, "CANCELLED": 6, "CANCELLING": 7, } )
Enum value maps for Job_Status.
var ( Role_name = map[int32]string{ 0: "ROLE_UNSPECIFIED", 1: "MASTERNODE", 2: "DATANODE", 3: "COMPUTENODE", } Role_value = map[string]int32{ "ROLE_UNSPECIFIED": 0, "MASTERNODE": 1, "DATANODE": 2, "COMPUTENODE": 3, } )
Enum value maps for Role.
var ClusterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "yandex.cloud.dataproc.v1.ClusterService", HandlerType: (*ClusterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _ClusterService_Get_Handler, }, { MethodName: "List", Handler: _ClusterService_List_Handler, }, { MethodName: "Create", Handler: _ClusterService_Create_Handler, }, { MethodName: "Update", Handler: _ClusterService_Update_Handler, }, { MethodName: "Delete", Handler: _ClusterService_Delete_Handler, }, { MethodName: "Start", Handler: _ClusterService_Start_Handler, }, { MethodName: "Stop", Handler: _ClusterService_Stop_Handler, }, { MethodName: "ListOperations", Handler: _ClusterService_ListOperations_Handler, }, { MethodName: "ListHosts", Handler: _ClusterService_ListHosts_Handler, }, { MethodName: "ListUILinks", Handler: _ClusterService_ListUILinks_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "yandex/cloud/dataproc/v1/cluster_service.proto", }
ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_yandex_cloud_dataproc_v1_cluster_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_cluster_service_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_common_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_job_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_job_service_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_resource_preset_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_resource_preset_service_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_subcluster_proto protoreflect.FileDescriptor
var File_yandex_cloud_dataproc_v1_subcluster_service_proto protoreflect.FileDescriptor
var JobService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "yandex.cloud.dataproc.v1.JobService", HandlerType: (*JobServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "List", Handler: _JobService_List_Handler, }, { MethodName: "Create", Handler: _JobService_Create_Handler, }, { MethodName: "Get", Handler: _JobService_Get_Handler, }, { MethodName: "ListLog", Handler: _JobService_ListLog_Handler, }, { MethodName: "Cancel", Handler: _JobService_Cancel_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "yandex/cloud/dataproc/v1/job_service.proto", }
JobService_ServiceDesc is the grpc.ServiceDesc for JobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ResourcePresetService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "yandex.cloud.dataproc.v1.ResourcePresetService", HandlerType: (*ResourcePresetServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _ResourcePresetService_Get_Handler, }, { MethodName: "List", Handler: _ResourcePresetService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "yandex/cloud/dataproc/v1/resource_preset_service.proto", }
ResourcePresetService_ServiceDesc is the grpc.ServiceDesc for ResourcePresetService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SubclusterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "yandex.cloud.dataproc.v1.SubclusterService", HandlerType: (*SubclusterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _SubclusterService_Get_Handler, }, { MethodName: "List", Handler: _SubclusterService_List_Handler, }, { MethodName: "Create", Handler: _SubclusterService_Create_Handler, }, { MethodName: "Update", Handler: _SubclusterService_Update_Handler, }, { MethodName: "Delete", Handler: _SubclusterService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "yandex/cloud/dataproc/v1/subcluster_service.proto", }
SubclusterService_ServiceDesc is the grpc.ServiceDesc for SubclusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterClusterServiceServer ¶
func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
func RegisterJobServiceServer ¶
func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
func RegisterResourcePresetServiceServer ¶
func RegisterResourcePresetServiceServer(s grpc.ServiceRegistrar, srv ResourcePresetServiceServer)
func RegisterSubclusterServiceServer ¶
func RegisterSubclusterServiceServer(s grpc.ServiceRegistrar, srv SubclusterServiceServer)
Types ¶
type ApplicationAttempt ¶
type ApplicationAttempt struct { // ID of YARN application attempt Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of YARN Application Master container AmContainerId string `protobuf:"bytes,2,opt,name=am_container_id,json=amContainerId,proto3" json:"am_container_id,omitempty"` // contains filtered or unexported fields }
func (*ApplicationAttempt) Descriptor
deprecated
func (*ApplicationAttempt) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationAttempt.ProtoReflect.Descriptor instead.
func (*ApplicationAttempt) GetAmContainerId ¶
func (x *ApplicationAttempt) GetAmContainerId() string
func (*ApplicationAttempt) GetId ¶
func (x *ApplicationAttempt) GetId() string
func (*ApplicationAttempt) ProtoMessage ¶
func (*ApplicationAttempt) ProtoMessage()
func (*ApplicationAttempt) ProtoReflect ¶
func (x *ApplicationAttempt) ProtoReflect() protoreflect.Message
func (*ApplicationAttempt) Reset ¶
func (x *ApplicationAttempt) Reset()
func (*ApplicationAttempt) SetAmContainerId ¶
func (m *ApplicationAttempt) SetAmContainerId(v string)
func (*ApplicationAttempt) SetId ¶
func (m *ApplicationAttempt) SetId(v string)
func (*ApplicationAttempt) String ¶
func (x *ApplicationAttempt) String() string
type ApplicationInfo ¶
type ApplicationInfo struct { // ID of YARN application Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // YARN application attempts ApplicationAttempts []*ApplicationAttempt `protobuf:"bytes,2,rep,name=application_attempts,json=applicationAttempts,proto3" json:"application_attempts,omitempty"` // contains filtered or unexported fields }
func (*ApplicationInfo) Descriptor
deprecated
func (*ApplicationInfo) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationInfo.ProtoReflect.Descriptor instead.
func (*ApplicationInfo) GetApplicationAttempts ¶
func (x *ApplicationInfo) GetApplicationAttempts() []*ApplicationAttempt
func (*ApplicationInfo) GetId ¶
func (x *ApplicationInfo) GetId() string
func (*ApplicationInfo) ProtoMessage ¶
func (*ApplicationInfo) ProtoMessage()
func (*ApplicationInfo) ProtoReflect ¶
func (x *ApplicationInfo) ProtoReflect() protoreflect.Message
func (*ApplicationInfo) Reset ¶
func (x *ApplicationInfo) Reset()
func (*ApplicationInfo) SetApplicationAttempts ¶
func (m *ApplicationInfo) SetApplicationAttempts(v []*ApplicationAttempt)
func (*ApplicationInfo) SetId ¶
func (m *ApplicationInfo) SetId(v string)
func (*ApplicationInfo) String ¶
func (x *ApplicationInfo) String() string
type AutoscalingConfig ¶
type AutoscalingConfig struct { // Upper limit for total instance subcluster count. MaxHostsCount int64 `protobuf:"varint,1,opt,name=max_hosts_count,json=maxHostsCount,proto3" json:"max_hosts_count,omitempty"` // Preemptible instances are stopped at least once every 24 hours, and can be stopped at any time // if their resources are needed by Compute. // For more information, see [Preemptible Virtual Machines](/docs/compute/concepts/preemptible-vm). Preemptible bool `protobuf:"varint,2,opt,name=preemptible,proto3" json:"preemptible,omitempty"` // Time in seconds allotted for averaging metrics. MeasurementDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=measurement_duration,json=measurementDuration,proto3" json:"measurement_duration,omitempty"` // The warmup time of the instance in seconds. During this time, // traffic is sent to the instance, but instance metrics are not collected. WarmupDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=warmup_duration,json=warmupDuration,proto3" json:"warmup_duration,omitempty"` // Minimum amount of time in seconds allotted for monitoring before // Instance Groups can reduce the number of instances in the group. // During this time, the group size doesn't decrease, even if the new metric values // indicate that it should. StabilizationDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=stabilization_duration,json=stabilizationDuration,proto3" json:"stabilization_duration,omitempty"` // Defines an autoscaling rule based on the average CPU utilization of the instance group. CpuUtilizationTarget float64 `protobuf:"fixed64,6,opt,name=cpu_utilization_target,json=cpuUtilizationTarget,proto3" json:"cpu_utilization_target,omitempty"` // Timeout to gracefully decommission nodes during downscaling. In seconds. Default value: 120 DecommissionTimeout int64 `protobuf:"varint,7,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // contains filtered or unexported fields }
func (*AutoscalingConfig) Descriptor
deprecated
func (*AutoscalingConfig) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalingConfig.ProtoReflect.Descriptor instead.
func (*AutoscalingConfig) GetCpuUtilizationTarget ¶
func (x *AutoscalingConfig) GetCpuUtilizationTarget() float64
func (*AutoscalingConfig) GetDecommissionTimeout ¶
func (x *AutoscalingConfig) GetDecommissionTimeout() int64
func (*AutoscalingConfig) GetMaxHostsCount ¶
func (x *AutoscalingConfig) GetMaxHostsCount() int64
func (*AutoscalingConfig) GetMeasurementDuration ¶
func (x *AutoscalingConfig) GetMeasurementDuration() *durationpb.Duration
func (*AutoscalingConfig) GetPreemptible ¶
func (x *AutoscalingConfig) GetPreemptible() bool
func (*AutoscalingConfig) GetStabilizationDuration ¶
func (x *AutoscalingConfig) GetStabilizationDuration() *durationpb.Duration
func (*AutoscalingConfig) GetWarmupDuration ¶
func (x *AutoscalingConfig) GetWarmupDuration() *durationpb.Duration
func (*AutoscalingConfig) ProtoMessage ¶
func (*AutoscalingConfig) ProtoMessage()
func (*AutoscalingConfig) ProtoReflect ¶
func (x *AutoscalingConfig) ProtoReflect() protoreflect.Message
func (*AutoscalingConfig) Reset ¶
func (x *AutoscalingConfig) Reset()
func (*AutoscalingConfig) SetCpuUtilizationTarget ¶
func (m *AutoscalingConfig) SetCpuUtilizationTarget(v float64)
func (*AutoscalingConfig) SetDecommissionTimeout ¶
func (m *AutoscalingConfig) SetDecommissionTimeout(v int64)
func (*AutoscalingConfig) SetMaxHostsCount ¶
func (m *AutoscalingConfig) SetMaxHostsCount(v int64)
func (*AutoscalingConfig) SetMeasurementDuration ¶
func (m *AutoscalingConfig) SetMeasurementDuration(v *durationpb.Duration)
func (*AutoscalingConfig) SetPreemptible ¶
func (m *AutoscalingConfig) SetPreemptible(v bool)
func (*AutoscalingConfig) SetStabilizationDuration ¶
func (m *AutoscalingConfig) SetStabilizationDuration(v *durationpb.Duration)
func (*AutoscalingConfig) SetWarmupDuration ¶
func (m *AutoscalingConfig) SetWarmupDuration(v *durationpb.Duration)
func (*AutoscalingConfig) String ¶
func (x *AutoscalingConfig) String() string
type CancelJobRequest ¶
type CancelJobRequest struct { // Required. ID of the Dataproc cluster. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Required. ID of the Dataproc job to cancel. JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // contains filtered or unexported fields }
func (*CancelJobRequest) Descriptor
deprecated
func (*CancelJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.
func (*CancelJobRequest) GetClusterId ¶
func (x *CancelJobRequest) GetClusterId() string
func (*CancelJobRequest) GetJobId ¶
func (x *CancelJobRequest) GetJobId() string
func (*CancelJobRequest) ProtoMessage ¶
func (*CancelJobRequest) ProtoMessage()
func (*CancelJobRequest) ProtoReflect ¶
func (x *CancelJobRequest) ProtoReflect() protoreflect.Message
func (*CancelJobRequest) Reset ¶
func (x *CancelJobRequest) Reset()
func (*CancelJobRequest) SetClusterId ¶
func (m *CancelJobRequest) SetClusterId(v string)
func (*CancelJobRequest) SetJobId ¶
func (m *CancelJobRequest) SetJobId(v string)
func (*CancelJobRequest) String ¶
func (x *CancelJobRequest) String() string
type Cluster ¶
type Cluster struct { // ID of the cluster. Generated at creation time. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of the folder that the cluster belongs to. FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"` // Creation timestamp. CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // Name of the cluster. The name is unique within the folder. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Description of the cluster. Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Cluster labels as `key:value` pairs. Labels map[string]string `` /* 153-byte string literal not displayed */ // Monitoring systems relevant to the cluster. Monitoring []*Monitoring `protobuf:"bytes,7,rep,name=monitoring,proto3" json:"monitoring,omitempty"` // Configuration of the cluster. Config *ClusterConfig `protobuf:"bytes,8,opt,name=config,proto3" json:"config,omitempty"` // Aggregated cluster health. Health Health `protobuf:"varint,9,opt,name=health,proto3,enum=yandex.cloud.dataproc.v1.Health" json:"health,omitempty"` // Cluster status. Status Cluster_Status `protobuf:"varint,10,opt,name=status,proto3,enum=yandex.cloud.dataproc.v1.Cluster_Status" json:"status,omitempty"` // ID of the availability zone where the cluster resides. ZoneId string `protobuf:"bytes,11,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"` // ID of service account for the Data Proc manager agent. ServiceAccountId string `protobuf:"bytes,12,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"` // Object Storage bucket to be used for Data Proc jobs that are run in the cluster. Bucket string `protobuf:"bytes,13,opt,name=bucket,proto3" json:"bucket,omitempty"` // Whether UI Proxy feature is enabled. UiProxy bool `protobuf:"varint,14,opt,name=ui_proxy,json=uiProxy,proto3" json:"ui_proxy,omitempty"` // User security groups. SecurityGroupIds []string `protobuf:"bytes,15,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"` // Host groups hosting VMs of the cluster. HostGroupIds []string `protobuf:"bytes,16,rep,name=host_group_ids,json=hostGroupIds,proto3" json:"host_group_ids,omitempty"` // Deletion Protection inhibits deletion of the cluster DeletionProtection bool `protobuf:"varint,17,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"` // ID of the cloud logging log group to write logs. If not set, default log group for the folder will be used. // To prevent logs from being sent to the cloud set cluster property dataproc:disable_cloud_logging = true LogGroupId string `protobuf:"bytes,18,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"` // contains filtered or unexported fields }
A Data Proc cluster. For details about the concept, see [documentation](/docs/data-proc/concepts/).
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetConfig ¶
func (x *Cluster) GetConfig() *ClusterConfig
func (*Cluster) GetCreatedAt ¶
func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp
func (*Cluster) GetDeletionProtection ¶
func (*Cluster) GetDescription ¶
func (*Cluster) GetFolderId ¶
func (*Cluster) GetHostGroupIds ¶
func (*Cluster) GetLogGroupId ¶
func (*Cluster) GetMonitoring ¶
func (x *Cluster) GetMonitoring() []*Monitoring
func (*Cluster) GetSecurityGroupIds ¶
func (*Cluster) GetServiceAccountId ¶
func (*Cluster) GetStatus ¶
func (x *Cluster) GetStatus() Cluster_Status
func (*Cluster) GetUiProxy ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
func (*Cluster) SetConfig ¶
func (m *Cluster) SetConfig(v *ClusterConfig)
func (*Cluster) SetCreatedAt ¶
func (m *Cluster) SetCreatedAt(v *timestamppb.Timestamp)
func (*Cluster) SetDeletionProtection ¶
func (*Cluster) SetDescription ¶
func (*Cluster) SetFolderId ¶
func (*Cluster) SetHostGroupIds ¶
func (*Cluster) SetLogGroupId ¶
func (*Cluster) SetMonitoring ¶
func (m *Cluster) SetMonitoring(v []*Monitoring)
func (*Cluster) SetSecurityGroupIds ¶
func (*Cluster) SetServiceAccountId ¶
func (*Cluster) SetStatus ¶
func (m *Cluster) SetStatus(v Cluster_Status)
func (*Cluster) SetUiProxy ¶
type ClusterConfig ¶
type ClusterConfig struct { // Image version for cluster provisioning. // All available versions are listed in the [documentation](/docs/data-proc/concepts/environment). VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"` // Data Proc specific configuration options. Hadoop *HadoopConfig `protobuf:"bytes,2,opt,name=hadoop,proto3" json:"hadoop,omitempty"` // contains filtered or unexported fields }
func (*ClusterConfig) Descriptor
deprecated
func (*ClusterConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClusterConfig.ProtoReflect.Descriptor instead.
func (*ClusterConfig) GetHadoop ¶
func (x *ClusterConfig) GetHadoop() *HadoopConfig
func (*ClusterConfig) GetVersionId ¶
func (x *ClusterConfig) GetVersionId() string
func (*ClusterConfig) ProtoMessage ¶
func (*ClusterConfig) ProtoMessage()
func (*ClusterConfig) ProtoReflect ¶
func (x *ClusterConfig) ProtoReflect() protoreflect.Message
func (*ClusterConfig) Reset ¶
func (x *ClusterConfig) Reset()
func (*ClusterConfig) SetHadoop ¶
func (m *ClusterConfig) SetHadoop(v *HadoopConfig)
func (*ClusterConfig) SetVersionId ¶
func (m *ClusterConfig) SetVersionId(v string)
func (*ClusterConfig) String ¶
func (x *ClusterConfig) String() string
type ClusterServiceClient ¶
type ClusterServiceClient interface { // Returns the specified cluster. // // To get the list of all available clusters, make a [ClusterService.List] request. Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) // Retrieves the list of clusters in the specified folder. List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) // Creates a cluster in the specified folder. Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Updates the configuration of the specified cluster. Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Deletes the specified cluster. Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Starts the specified cluster. Start(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Stops the specified cluster. Stop(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Lists operations for the specified cluster. ListOperations(ctx context.Context, in *ListClusterOperationsRequest, opts ...grpc.CallOption) (*ListClusterOperationsResponse, error) // Retrieves the list of hosts in the specified cluster. ListHosts(ctx context.Context, in *ListClusterHostsRequest, opts ...grpc.CallOption) (*ListClusterHostsResponse, error) // Retrieves a list of links to web interfaces being proxied by Data Proc UI Proxy. ListUILinks(ctx context.Context, in *ListUILinksRequest, opts ...grpc.CallOption) (*ListUILinksResponse, error) }
ClusterServiceClient is the client API for ClusterService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClusterServiceClient ¶
func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient
type ClusterServiceServer ¶
type ClusterServiceServer interface { // Returns the specified cluster. // // To get the list of all available clusters, make a [ClusterService.List] request. Get(context.Context, *GetClusterRequest) (*Cluster, error) // Retrieves the list of clusters in the specified folder. List(context.Context, *ListClustersRequest) (*ListClustersResponse, error) // Creates a cluster in the specified folder. Create(context.Context, *CreateClusterRequest) (*operation.Operation, error) // Updates the configuration of the specified cluster. Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error) // Deletes the specified cluster. Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error) // Starts the specified cluster. Start(context.Context, *StartClusterRequest) (*operation.Operation, error) // Stops the specified cluster. Stop(context.Context, *StopClusterRequest) (*operation.Operation, error) // Lists operations for the specified cluster. ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error) // Retrieves the list of hosts in the specified cluster. ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error) // Retrieves a list of links to web interfaces being proxied by Data Proc UI Proxy. ListUILinks(context.Context, *ListUILinksRequest) (*ListUILinksResponse, error) }
ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility
type Cluster_Status ¶
type Cluster_Status int32
const ( // Cluster state is unknown. Cluster_STATUS_UNKNOWN Cluster_Status = 0 // Cluster is being created. Cluster_CREATING Cluster_Status = 1 // Cluster is running normally. Cluster_RUNNING Cluster_Status = 2 // Cluster encountered a problem and cannot operate. Cluster_ERROR Cluster_Status = 3 // Cluster is stopping. Cluster_STOPPING Cluster_Status = 4 // Cluster stopped. Cluster_STOPPED Cluster_Status = 5 // Cluster is starting. Cluster_STARTING Cluster_Status = 6 )
func (Cluster_Status) Descriptor ¶
func (Cluster_Status) Descriptor() protoreflect.EnumDescriptor
func (Cluster_Status) Enum ¶
func (x Cluster_Status) Enum() *Cluster_Status
func (Cluster_Status) EnumDescriptor
deprecated
func (Cluster_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use Cluster_Status.Descriptor instead.
func (Cluster_Status) Number ¶
func (x Cluster_Status) Number() protoreflect.EnumNumber
func (Cluster_Status) String ¶
func (x Cluster_Status) String() string
func (Cluster_Status) Type ¶
func (Cluster_Status) Type() protoreflect.EnumType
type CreateClusterConfigSpec ¶
type CreateClusterConfigSpec struct { // Version of the image for cluster provisioning. // // All available versions are listed in the [documentation](/docs/data-proc/concepts/environment). VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"` // Data Proc specific options. Hadoop *HadoopConfig `protobuf:"bytes,2,opt,name=hadoop,proto3" json:"hadoop,omitempty"` // Specification for creating subclusters. SubclustersSpec []*CreateSubclusterConfigSpec `protobuf:"bytes,3,rep,name=subclusters_spec,json=subclustersSpec,proto3" json:"subclusters_spec,omitempty"` // contains filtered or unexported fields }
func (*CreateClusterConfigSpec) Descriptor
deprecated
func (*CreateClusterConfigSpec) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterConfigSpec.ProtoReflect.Descriptor instead.
func (*CreateClusterConfigSpec) GetHadoop ¶
func (x *CreateClusterConfigSpec) GetHadoop() *HadoopConfig
func (*CreateClusterConfigSpec) GetSubclustersSpec ¶
func (x *CreateClusterConfigSpec) GetSubclustersSpec() []*CreateSubclusterConfigSpec
func (*CreateClusterConfigSpec) GetVersionId ¶
func (x *CreateClusterConfigSpec) GetVersionId() string
func (*CreateClusterConfigSpec) ProtoMessage ¶
func (*CreateClusterConfigSpec) ProtoMessage()
func (*CreateClusterConfigSpec) ProtoReflect ¶
func (x *CreateClusterConfigSpec) ProtoReflect() protoreflect.Message
func (*CreateClusterConfigSpec) Reset ¶
func (x *CreateClusterConfigSpec) Reset()
func (*CreateClusterConfigSpec) SetHadoop ¶
func (m *CreateClusterConfigSpec) SetHadoop(v *HadoopConfig)
func (*CreateClusterConfigSpec) SetSubclustersSpec ¶
func (m *CreateClusterConfigSpec) SetSubclustersSpec(v []*CreateSubclusterConfigSpec)
func (*CreateClusterConfigSpec) SetVersionId ¶
func (m *CreateClusterConfigSpec) SetVersionId(v string)
func (*CreateClusterConfigSpec) String ¶
func (x *CreateClusterConfigSpec) String() string
type CreateClusterMetadata ¶
type CreateClusterMetadata struct { // ID of the cluster that is being created. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*CreateClusterMetadata) Descriptor
deprecated
func (*CreateClusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterMetadata.ProtoReflect.Descriptor instead.
func (*CreateClusterMetadata) GetClusterId ¶
func (x *CreateClusterMetadata) GetClusterId() string
func (*CreateClusterMetadata) ProtoMessage ¶
func (*CreateClusterMetadata) ProtoMessage()
func (*CreateClusterMetadata) ProtoReflect ¶
func (x *CreateClusterMetadata) ProtoReflect() protoreflect.Message
func (*CreateClusterMetadata) Reset ¶
func (x *CreateClusterMetadata) Reset()
func (*CreateClusterMetadata) SetClusterId ¶
func (m *CreateClusterMetadata) SetClusterId(v string)
func (*CreateClusterMetadata) String ¶
func (x *CreateClusterMetadata) String() string
type CreateClusterRequest ¶
type CreateClusterRequest struct { // ID of the folder to create a cluster in. // // To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request. FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"` // Name of the cluster. The name must be unique within the folder. // The name can't be changed after the Data Proc cluster is created. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Description of the cluster. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Cluster labels as `key:value` pairs. Labels map[string]string `` /* 153-byte string literal not displayed */ // Configuration and resources for hosts that should be created with the cluster. ConfigSpec *CreateClusterConfigSpec `protobuf:"bytes,6,opt,name=config_spec,json=configSpec,proto3" json:"config_spec,omitempty"` // ID of the availability zone where the cluster should be placed. // // To get the list of available zones make a [yandex.cloud.compute.v1.ZoneService.List] request. ZoneId string `protobuf:"bytes,7,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"` // ID of the service account to be used by the Data Proc manager agent. ServiceAccountId string `protobuf:"bytes,8,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"` // Name of the Object Storage bucket to use for Data Proc jobs. Bucket string `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"` // Enable UI Proxy feature. UiProxy bool `protobuf:"varint,10,opt,name=ui_proxy,json=uiProxy,proto3" json:"ui_proxy,omitempty"` // User security groups. SecurityGroupIds []string `protobuf:"bytes,11,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"` // Host groups to place VMs of cluster on. HostGroupIds []string `protobuf:"bytes,12,rep,name=host_group_ids,json=hostGroupIds,proto3" json:"host_group_ids,omitempty"` // Deletion Protection inhibits deletion of the cluster DeletionProtection bool `protobuf:"varint,13,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"` // ID of the cloud logging log group to write logs. If not set, logs will not be sent to logging service LogGroupId string `protobuf:"bytes,14,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"` // contains filtered or unexported fields }
func (*CreateClusterRequest) Descriptor
deprecated
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.
func (*CreateClusterRequest) GetBucket ¶
func (x *CreateClusterRequest) GetBucket() string
func (*CreateClusterRequest) GetConfigSpec ¶
func (x *CreateClusterRequest) GetConfigSpec() *CreateClusterConfigSpec
func (*CreateClusterRequest) GetDeletionProtection ¶
func (x *CreateClusterRequest) GetDeletionProtection() bool
func (*CreateClusterRequest) GetDescription ¶
func (x *CreateClusterRequest) GetDescription() string
func (*CreateClusterRequest) GetFolderId ¶
func (x *CreateClusterRequest) GetFolderId() string
func (*CreateClusterRequest) GetHostGroupIds ¶
func (x *CreateClusterRequest) GetHostGroupIds() []string
func (*CreateClusterRequest) GetLabels ¶
func (x *CreateClusterRequest) GetLabels() map[string]string
func (*CreateClusterRequest) GetLogGroupId ¶
func (x *CreateClusterRequest) GetLogGroupId() string
func (*CreateClusterRequest) GetName ¶
func (x *CreateClusterRequest) GetName() string
func (*CreateClusterRequest) GetSecurityGroupIds ¶
func (x *CreateClusterRequest) GetSecurityGroupIds() []string
func (*CreateClusterRequest) GetServiceAccountId ¶
func (x *CreateClusterRequest) GetServiceAccountId() string
func (*CreateClusterRequest) GetUiProxy ¶
func (x *CreateClusterRequest) GetUiProxy() bool
func (*CreateClusterRequest) GetZoneId ¶
func (x *CreateClusterRequest) GetZoneId() string
func (*CreateClusterRequest) ProtoMessage ¶
func (*CreateClusterRequest) ProtoMessage()
func (*CreateClusterRequest) ProtoReflect ¶
func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
func (*CreateClusterRequest) Reset ¶
func (x *CreateClusterRequest) Reset()
func (*CreateClusterRequest) SetBucket ¶
func (m *CreateClusterRequest) SetBucket(v string)
func (*CreateClusterRequest) SetConfigSpec ¶
func (m *CreateClusterRequest) SetConfigSpec(v *CreateClusterConfigSpec)
func (*CreateClusterRequest) SetDeletionProtection ¶
func (m *CreateClusterRequest) SetDeletionProtection(v bool)
func (*CreateClusterRequest) SetDescription ¶
func (m *CreateClusterRequest) SetDescription(v string)
func (*CreateClusterRequest) SetFolderId ¶
func (m *CreateClusterRequest) SetFolderId(v string)
func (*CreateClusterRequest) SetHostGroupIds ¶
func (m *CreateClusterRequest) SetHostGroupIds(v []string)
func (*CreateClusterRequest) SetLabels ¶
func (m *CreateClusterRequest) SetLabels(v map[string]string)
func (*CreateClusterRequest) SetLogGroupId ¶
func (m *CreateClusterRequest) SetLogGroupId(v string)
func (*CreateClusterRequest) SetName ¶
func (m *CreateClusterRequest) SetName(v string)
func (*CreateClusterRequest) SetSecurityGroupIds ¶
func (m *CreateClusterRequest) SetSecurityGroupIds(v []string)
func (*CreateClusterRequest) SetServiceAccountId ¶
func (m *CreateClusterRequest) SetServiceAccountId(v string)
func (*CreateClusterRequest) SetUiProxy ¶
func (m *CreateClusterRequest) SetUiProxy(v bool)
func (*CreateClusterRequest) SetZoneId ¶
func (m *CreateClusterRequest) SetZoneId(v string)
func (*CreateClusterRequest) String ¶
func (x *CreateClusterRequest) String() string
type CreateJobMetadata ¶
type CreateJobMetadata struct { // ID of the cluster that the job is being created for. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the job being created. JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // contains filtered or unexported fields }
func (*CreateJobMetadata) Descriptor
deprecated
func (*CreateJobMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CreateJobMetadata.ProtoReflect.Descriptor instead.
func (*CreateJobMetadata) GetClusterId ¶
func (x *CreateJobMetadata) GetClusterId() string
func (*CreateJobMetadata) GetJobId ¶
func (x *CreateJobMetadata) GetJobId() string
func (*CreateJobMetadata) ProtoMessage ¶
func (*CreateJobMetadata) ProtoMessage()
func (*CreateJobMetadata) ProtoReflect ¶
func (x *CreateJobMetadata) ProtoReflect() protoreflect.Message
func (*CreateJobMetadata) Reset ¶
func (x *CreateJobMetadata) Reset()
func (*CreateJobMetadata) SetClusterId ¶
func (m *CreateJobMetadata) SetClusterId(v string)
func (*CreateJobMetadata) SetJobId ¶
func (m *CreateJobMetadata) SetJobId(v string)
func (*CreateJobMetadata) String ¶
func (x *CreateJobMetadata) String() string
type CreateJobRequest ¶
type CreateJobRequest struct { // ID of the cluster to create a job for. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Name of the job. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Specification for the job. // // Types that are assignable to JobSpec: // // *CreateJobRequest_MapreduceJob // *CreateJobRequest_SparkJob // *CreateJobRequest_PysparkJob // *CreateJobRequest_HiveJob JobSpec isCreateJobRequest_JobSpec `protobuf_oneof:"job_spec"` // contains filtered or unexported fields }
func (*CreateJobRequest) Descriptor
deprecated
func (*CreateJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.
func (*CreateJobRequest) GetClusterId ¶
func (x *CreateJobRequest) GetClusterId() string
func (*CreateJobRequest) GetHiveJob ¶
func (x *CreateJobRequest) GetHiveJob() *HiveJob
func (*CreateJobRequest) GetJobSpec ¶
func (m *CreateJobRequest) GetJobSpec() isCreateJobRequest_JobSpec
func (*CreateJobRequest) GetMapreduceJob ¶
func (x *CreateJobRequest) GetMapreduceJob() *MapreduceJob
func (*CreateJobRequest) GetName ¶
func (x *CreateJobRequest) GetName() string
func (*CreateJobRequest) GetPysparkJob ¶
func (x *CreateJobRequest) GetPysparkJob() *PysparkJob
func (*CreateJobRequest) GetSparkJob ¶
func (x *CreateJobRequest) GetSparkJob() *SparkJob
func (*CreateJobRequest) ProtoMessage ¶
func (*CreateJobRequest) ProtoMessage()
func (*CreateJobRequest) ProtoReflect ¶
func (x *CreateJobRequest) ProtoReflect() protoreflect.Message
func (*CreateJobRequest) Reset ¶
func (x *CreateJobRequest) Reset()
func (*CreateJobRequest) SetClusterId ¶
func (m *CreateJobRequest) SetClusterId(v string)
func (*CreateJobRequest) SetHiveJob ¶
func (m *CreateJobRequest) SetHiveJob(v *HiveJob)
func (*CreateJobRequest) SetJobSpec ¶
func (m *CreateJobRequest) SetJobSpec(v CreateJobRequest_JobSpec)
func (*CreateJobRequest) SetMapreduceJob ¶
func (m *CreateJobRequest) SetMapreduceJob(v *MapreduceJob)
func (*CreateJobRequest) SetName ¶
func (m *CreateJobRequest) SetName(v string)
func (*CreateJobRequest) SetPysparkJob ¶
func (m *CreateJobRequest) SetPysparkJob(v *PysparkJob)
func (*CreateJobRequest) SetSparkJob ¶
func (m *CreateJobRequest) SetSparkJob(v *SparkJob)
func (*CreateJobRequest) String ¶
func (x *CreateJobRequest) String() string
type CreateJobRequest_HiveJob ¶
type CreateJobRequest_HiveJob struct { // Specification for a Hive job. HiveJob *HiveJob `protobuf:"bytes,6,opt,name=hive_job,json=hiveJob,proto3,oneof"` }
type CreateJobRequest_JobSpec ¶
type CreateJobRequest_JobSpec = isCreateJobRequest_JobSpec
type CreateJobRequest_MapreduceJob ¶
type CreateJobRequest_MapreduceJob struct { // Specification for a MapReduce job. MapreduceJob *MapreduceJob `protobuf:"bytes,3,opt,name=mapreduce_job,json=mapreduceJob,proto3,oneof"` }
type CreateJobRequest_PysparkJob ¶
type CreateJobRequest_PysparkJob struct { // Specification for a PySpark job. PysparkJob *PysparkJob `protobuf:"bytes,5,opt,name=pyspark_job,json=pysparkJob,proto3,oneof"` }
type CreateJobRequest_SparkJob ¶
type CreateJobRequest_SparkJob struct { // Specification for a Spark job. SparkJob *SparkJob `protobuf:"bytes,4,opt,name=spark_job,json=sparkJob,proto3,oneof"` }
type CreateSubclusterConfigSpec ¶
type CreateSubclusterConfigSpec struct { // Name of the subcluster. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Role of the subcluster in the Data Proc cluster. Role Role `protobuf:"varint,2,opt,name=role,proto3,enum=yandex.cloud.dataproc.v1.Role" json:"role,omitempty"` // Resource configuration for hosts in the subcluster. Resources *Resources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` // ID of the VPC subnet used for hosts in the subcluster. SubnetId string `protobuf:"bytes,4,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` // Number of hosts in the subcluster. HostsCount int64 `protobuf:"varint,5,opt,name=hosts_count,json=hostsCount,proto3" json:"hosts_count,omitempty"` // Assign public ip addresses for all hosts in subcluter. AssignPublicIp bool `protobuf:"varint,6,opt,name=assign_public_ip,json=assignPublicIp,proto3" json:"assign_public_ip,omitempty"` // Configuration for instance group based subclusters AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` // contains filtered or unexported fields }
func (*CreateSubclusterConfigSpec) Descriptor
deprecated
func (*CreateSubclusterConfigSpec) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubclusterConfigSpec.ProtoReflect.Descriptor instead.
func (*CreateSubclusterConfigSpec) GetAssignPublicIp ¶
func (x *CreateSubclusterConfigSpec) GetAssignPublicIp() bool
func (*CreateSubclusterConfigSpec) GetAutoscalingConfig ¶
func (x *CreateSubclusterConfigSpec) GetAutoscalingConfig() *AutoscalingConfig
func (*CreateSubclusterConfigSpec) GetHostsCount ¶
func (x *CreateSubclusterConfigSpec) GetHostsCount() int64
func (*CreateSubclusterConfigSpec) GetName ¶
func (x *CreateSubclusterConfigSpec) GetName() string
func (*CreateSubclusterConfigSpec) GetResources ¶
func (x *CreateSubclusterConfigSpec) GetResources() *Resources
func (*CreateSubclusterConfigSpec) GetRole ¶
func (x *CreateSubclusterConfigSpec) GetRole() Role
func (*CreateSubclusterConfigSpec) GetSubnetId ¶
func (x *CreateSubclusterConfigSpec) GetSubnetId() string
func (*CreateSubclusterConfigSpec) ProtoMessage ¶
func (*CreateSubclusterConfigSpec) ProtoMessage()
func (*CreateSubclusterConfigSpec) ProtoReflect ¶
func (x *CreateSubclusterConfigSpec) ProtoReflect() protoreflect.Message
func (*CreateSubclusterConfigSpec) Reset ¶
func (x *CreateSubclusterConfigSpec) Reset()
func (*CreateSubclusterConfigSpec) SetAssignPublicIp ¶
func (m *CreateSubclusterConfigSpec) SetAssignPublicIp(v bool)
func (*CreateSubclusterConfigSpec) SetAutoscalingConfig ¶
func (m *CreateSubclusterConfigSpec) SetAutoscalingConfig(v *AutoscalingConfig)
func (*CreateSubclusterConfigSpec) SetHostsCount ¶
func (m *CreateSubclusterConfigSpec) SetHostsCount(v int64)
func (*CreateSubclusterConfigSpec) SetName ¶
func (m *CreateSubclusterConfigSpec) SetName(v string)
func (*CreateSubclusterConfigSpec) SetResources ¶
func (m *CreateSubclusterConfigSpec) SetResources(v *Resources)
func (*CreateSubclusterConfigSpec) SetRole ¶
func (m *CreateSubclusterConfigSpec) SetRole(v Role)
func (*CreateSubclusterConfigSpec) SetSubnetId ¶
func (m *CreateSubclusterConfigSpec) SetSubnetId(v string)
func (*CreateSubclusterConfigSpec) String ¶
func (x *CreateSubclusterConfigSpec) String() string
type CreateSubclusterMetadata ¶
type CreateSubclusterMetadata struct { // ID of the cluster that the subcluster is being added to. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster that is being created. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // contains filtered or unexported fields }
func (*CreateSubclusterMetadata) Descriptor
deprecated
func (*CreateSubclusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubclusterMetadata.ProtoReflect.Descriptor instead.
func (*CreateSubclusterMetadata) GetClusterId ¶
func (x *CreateSubclusterMetadata) GetClusterId() string
func (*CreateSubclusterMetadata) GetSubclusterId ¶
func (x *CreateSubclusterMetadata) GetSubclusterId() string
func (*CreateSubclusterMetadata) ProtoMessage ¶
func (*CreateSubclusterMetadata) ProtoMessage()
func (*CreateSubclusterMetadata) ProtoReflect ¶
func (x *CreateSubclusterMetadata) ProtoReflect() protoreflect.Message
func (*CreateSubclusterMetadata) Reset ¶
func (x *CreateSubclusterMetadata) Reset()
func (*CreateSubclusterMetadata) SetClusterId ¶
func (m *CreateSubclusterMetadata) SetClusterId(v string)
func (*CreateSubclusterMetadata) SetSubclusterId ¶
func (m *CreateSubclusterMetadata) SetSubclusterId(v string)
func (*CreateSubclusterMetadata) String ¶
func (x *CreateSubclusterMetadata) String() string
type CreateSubclusterRequest ¶
type CreateSubclusterRequest struct { // ID of the Data Proc cluster to create a subcluster in. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Name of the subcluster. The name must be unique within the cluster. The name can't be // changed when the subcluster is created. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Role that is fulfilled by hosts of the subcluster. Role Role `protobuf:"varint,3,opt,name=role,proto3,enum=yandex.cloud.dataproc.v1.Role" json:"role,omitempty"` // Resources allocated for each host in the subcluster. Resources *Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"` // ID of the VPC subnet used for hosts in the subcluster. SubnetId string `protobuf:"bytes,5,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` // Number of hosts in the subcluster. HostsCount int64 `protobuf:"varint,6,opt,name=hosts_count,json=hostsCount,proto3" json:"hosts_count,omitempty"` // Configuration for instance group based subclusters AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,7,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` // contains filtered or unexported fields }
func (*CreateSubclusterRequest) Descriptor
deprecated
func (*CreateSubclusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubclusterRequest.ProtoReflect.Descriptor instead.
func (*CreateSubclusterRequest) GetAutoscalingConfig ¶
func (x *CreateSubclusterRequest) GetAutoscalingConfig() *AutoscalingConfig
func (*CreateSubclusterRequest) GetClusterId ¶
func (x *CreateSubclusterRequest) GetClusterId() string
func (*CreateSubclusterRequest) GetHostsCount ¶
func (x *CreateSubclusterRequest) GetHostsCount() int64
func (*CreateSubclusterRequest) GetName ¶
func (x *CreateSubclusterRequest) GetName() string
func (*CreateSubclusterRequest) GetResources ¶
func (x *CreateSubclusterRequest) GetResources() *Resources
func (*CreateSubclusterRequest) GetRole ¶
func (x *CreateSubclusterRequest) GetRole() Role
func (*CreateSubclusterRequest) GetSubnetId ¶
func (x *CreateSubclusterRequest) GetSubnetId() string
func (*CreateSubclusterRequest) ProtoMessage ¶
func (*CreateSubclusterRequest) ProtoMessage()
func (*CreateSubclusterRequest) ProtoReflect ¶
func (x *CreateSubclusterRequest) ProtoReflect() protoreflect.Message
func (*CreateSubclusterRequest) Reset ¶
func (x *CreateSubclusterRequest) Reset()
func (*CreateSubclusterRequest) SetAutoscalingConfig ¶
func (m *CreateSubclusterRequest) SetAutoscalingConfig(v *AutoscalingConfig)
func (*CreateSubclusterRequest) SetClusterId ¶
func (m *CreateSubclusterRequest) SetClusterId(v string)
func (*CreateSubclusterRequest) SetHostsCount ¶
func (m *CreateSubclusterRequest) SetHostsCount(v int64)
func (*CreateSubclusterRequest) SetName ¶
func (m *CreateSubclusterRequest) SetName(v string)
func (*CreateSubclusterRequest) SetResources ¶
func (m *CreateSubclusterRequest) SetResources(v *Resources)
func (*CreateSubclusterRequest) SetRole ¶
func (m *CreateSubclusterRequest) SetRole(v Role)
func (*CreateSubclusterRequest) SetSubnetId ¶
func (m *CreateSubclusterRequest) SetSubnetId(v string)
func (*CreateSubclusterRequest) String ¶
func (x *CreateSubclusterRequest) String() string
type DeleteClusterMetadata ¶
type DeleteClusterMetadata struct { // ID of the Data Proc cluster that is being deleted. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteClusterMetadata) Descriptor
deprecated
func (*DeleteClusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterMetadata.ProtoReflect.Descriptor instead.
func (*DeleteClusterMetadata) GetClusterId ¶
func (x *DeleteClusterMetadata) GetClusterId() string
func (*DeleteClusterMetadata) ProtoMessage ¶
func (*DeleteClusterMetadata) ProtoMessage()
func (*DeleteClusterMetadata) ProtoReflect ¶
func (x *DeleteClusterMetadata) ProtoReflect() protoreflect.Message
func (*DeleteClusterMetadata) Reset ¶
func (x *DeleteClusterMetadata) Reset()
func (*DeleteClusterMetadata) SetClusterId ¶
func (m *DeleteClusterMetadata) SetClusterId(v string)
func (*DeleteClusterMetadata) String ¶
func (x *DeleteClusterMetadata) String() string
type DeleteClusterRequest ¶
type DeleteClusterRequest struct { // ID of the cluster to delete. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Timeout to gracefully decommission nodes. In seconds. Default value: 0 DecommissionTimeout int64 `protobuf:"varint,2,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // contains filtered or unexported fields }
func (*DeleteClusterRequest) Descriptor
deprecated
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
func (*DeleteClusterRequest) GetClusterId ¶
func (x *DeleteClusterRequest) GetClusterId() string
func (*DeleteClusterRequest) GetDecommissionTimeout ¶
func (x *DeleteClusterRequest) GetDecommissionTimeout() int64
func (*DeleteClusterRequest) ProtoMessage ¶
func (*DeleteClusterRequest) ProtoMessage()
func (*DeleteClusterRequest) ProtoReflect ¶
func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
func (*DeleteClusterRequest) Reset ¶
func (x *DeleteClusterRequest) Reset()
func (*DeleteClusterRequest) SetClusterId ¶
func (m *DeleteClusterRequest) SetClusterId(v string)
func (*DeleteClusterRequest) SetDecommissionTimeout ¶
func (m *DeleteClusterRequest) SetDecommissionTimeout(v int64)
func (*DeleteClusterRequest) String ¶
func (x *DeleteClusterRequest) String() string
type DeleteSubclusterMetadata ¶
type DeleteSubclusterMetadata struct { // ID of the cluster whose subcluster is being deleted. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster that is being deleted. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteSubclusterMetadata) Descriptor
deprecated
func (*DeleteSubclusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSubclusterMetadata.ProtoReflect.Descriptor instead.
func (*DeleteSubclusterMetadata) GetClusterId ¶
func (x *DeleteSubclusterMetadata) GetClusterId() string
func (*DeleteSubclusterMetadata) GetSubclusterId ¶
func (x *DeleteSubclusterMetadata) GetSubclusterId() string
func (*DeleteSubclusterMetadata) ProtoMessage ¶
func (*DeleteSubclusterMetadata) ProtoMessage()
func (*DeleteSubclusterMetadata) ProtoReflect ¶
func (x *DeleteSubclusterMetadata) ProtoReflect() protoreflect.Message
func (*DeleteSubclusterMetadata) Reset ¶
func (x *DeleteSubclusterMetadata) Reset()
func (*DeleteSubclusterMetadata) SetClusterId ¶
func (m *DeleteSubclusterMetadata) SetClusterId(v string)
func (*DeleteSubclusterMetadata) SetSubclusterId ¶
func (m *DeleteSubclusterMetadata) SetSubclusterId(v string)
func (*DeleteSubclusterMetadata) String ¶
func (x *DeleteSubclusterMetadata) String() string
type DeleteSubclusterRequest ¶
type DeleteSubclusterRequest struct { // ID of the cluster to remove a subcluster from. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster to delete. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // Timeout to gracefully decommission nodes. In seconds. Default value: 0 DecommissionTimeout int64 `protobuf:"varint,3,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // contains filtered or unexported fields }
func (*DeleteSubclusterRequest) Descriptor
deprecated
func (*DeleteSubclusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSubclusterRequest.ProtoReflect.Descriptor instead.
func (*DeleteSubclusterRequest) GetClusterId ¶
func (x *DeleteSubclusterRequest) GetClusterId() string
func (*DeleteSubclusterRequest) GetDecommissionTimeout ¶
func (x *DeleteSubclusterRequest) GetDecommissionTimeout() int64
func (*DeleteSubclusterRequest) GetSubclusterId ¶
func (x *DeleteSubclusterRequest) GetSubclusterId() string
func (*DeleteSubclusterRequest) ProtoMessage ¶
func (*DeleteSubclusterRequest) ProtoMessage()
func (*DeleteSubclusterRequest) ProtoReflect ¶
func (x *DeleteSubclusterRequest) ProtoReflect() protoreflect.Message
func (*DeleteSubclusterRequest) Reset ¶
func (x *DeleteSubclusterRequest) Reset()
func (*DeleteSubclusterRequest) SetClusterId ¶
func (m *DeleteSubclusterRequest) SetClusterId(v string)
func (*DeleteSubclusterRequest) SetDecommissionTimeout ¶
func (m *DeleteSubclusterRequest) SetDecommissionTimeout(v int64)
func (*DeleteSubclusterRequest) SetSubclusterId ¶
func (m *DeleteSubclusterRequest) SetSubclusterId(v string)
func (*DeleteSubclusterRequest) String ¶
func (x *DeleteSubclusterRequest) String() string
type GetClusterRequest ¶
type GetClusterRequest struct { // ID of the Data Proc cluster. // // To get a cluster ID make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*GetClusterRequest) Descriptor
deprecated
func (*GetClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.
func (*GetClusterRequest) GetClusterId ¶
func (x *GetClusterRequest) GetClusterId() string
func (*GetClusterRequest) ProtoMessage ¶
func (*GetClusterRequest) ProtoMessage()
func (*GetClusterRequest) ProtoReflect ¶
func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
func (*GetClusterRequest) Reset ¶
func (x *GetClusterRequest) Reset()
func (*GetClusterRequest) SetClusterId ¶
func (m *GetClusterRequest) SetClusterId(v string)
func (*GetClusterRequest) String ¶
func (x *GetClusterRequest) String() string
type GetJobRequest ¶
type GetJobRequest struct { // ID of the cluster to request a job from. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the job to return. // // To get a job ID make a [JobService.List] request. JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // contains filtered or unexported fields }
func (*GetJobRequest) Descriptor
deprecated
func (*GetJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.
func (*GetJobRequest) GetClusterId ¶
func (x *GetJobRequest) GetClusterId() string
func (*GetJobRequest) GetJobId ¶
func (x *GetJobRequest) GetJobId() string
func (*GetJobRequest) ProtoMessage ¶
func (*GetJobRequest) ProtoMessage()
func (*GetJobRequest) ProtoReflect ¶
func (x *GetJobRequest) ProtoReflect() protoreflect.Message
func (*GetJobRequest) Reset ¶
func (x *GetJobRequest) Reset()
func (*GetJobRequest) SetClusterId ¶
func (m *GetJobRequest) SetClusterId(v string)
func (*GetJobRequest) SetJobId ¶
func (m *GetJobRequest) SetJobId(v string)
func (*GetJobRequest) String ¶
func (x *GetJobRequest) String() string
type GetResourcePresetRequest ¶
type GetResourcePresetRequest struct { // Required. ID of the resource preset to return. // To get the resource preset ID, use a [ResourcePresetService.List] request. ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"` // contains filtered or unexported fields }
func (*GetResourcePresetRequest) Descriptor
deprecated
func (*GetResourcePresetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourcePresetRequest.ProtoReflect.Descriptor instead.
func (*GetResourcePresetRequest) GetResourcePresetId ¶
func (x *GetResourcePresetRequest) GetResourcePresetId() string
func (*GetResourcePresetRequest) ProtoMessage ¶
func (*GetResourcePresetRequest) ProtoMessage()
func (*GetResourcePresetRequest) ProtoReflect ¶
func (x *GetResourcePresetRequest) ProtoReflect() protoreflect.Message
func (*GetResourcePresetRequest) Reset ¶
func (x *GetResourcePresetRequest) Reset()
func (*GetResourcePresetRequest) SetResourcePresetId ¶
func (m *GetResourcePresetRequest) SetResourcePresetId(v string)
func (*GetResourcePresetRequest) String ¶
func (x *GetResourcePresetRequest) String() string
type GetSubclusterRequest ¶
type GetSubclusterRequest struct { // ID of the Data Proc cluster that the subcluster belongs to. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster to return. // // To get a subcluster ID make a [SubclusterService.List] request. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // contains filtered or unexported fields }
func (*GetSubclusterRequest) Descriptor
deprecated
func (*GetSubclusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSubclusterRequest.ProtoReflect.Descriptor instead.
func (*GetSubclusterRequest) GetClusterId ¶
func (x *GetSubclusterRequest) GetClusterId() string
func (*GetSubclusterRequest) GetSubclusterId ¶
func (x *GetSubclusterRequest) GetSubclusterId() string
func (*GetSubclusterRequest) ProtoMessage ¶
func (*GetSubclusterRequest) ProtoMessage()
func (*GetSubclusterRequest) ProtoReflect ¶
func (x *GetSubclusterRequest) ProtoReflect() protoreflect.Message
func (*GetSubclusterRequest) Reset ¶
func (x *GetSubclusterRequest) Reset()
func (*GetSubclusterRequest) SetClusterId ¶
func (m *GetSubclusterRequest) SetClusterId(v string)
func (*GetSubclusterRequest) SetSubclusterId ¶
func (m *GetSubclusterRequest) SetSubclusterId(v string)
func (*GetSubclusterRequest) String ¶
func (x *GetSubclusterRequest) String() string
type HadoopConfig ¶
type HadoopConfig struct { // Set of services used in the cluster (if empty, the default set is used). Services []HadoopConfig_Service `` /* 128-byte string literal not displayed */ // Properties set for all hosts in `*-site.xml` configurations. The key should indicate // the service and the property. // // For example, use the key 'hdfs:dfs.replication' to set the `dfs.replication` property // in the file `/etc/hadoop/conf/hdfs-site.xml`. Properties map[string]string `` /* 161-byte string literal not displayed */ // List of public SSH keys to access to cluster hosts. SshPublicKeys []string `protobuf:"bytes,3,rep,name=ssh_public_keys,json=sshPublicKeys,proto3" json:"ssh_public_keys,omitempty"` // Set of init-actions InitializationActions []*InitializationAction `protobuf:"bytes,4,rep,name=initialization_actions,json=initializationActions,proto3" json:"initialization_actions,omitempty"` // contains filtered or unexported fields }
Hadoop configuration that describes services installed in a cluster, their properties and settings.
func (*HadoopConfig) Descriptor
deprecated
func (*HadoopConfig) Descriptor() ([]byte, []int)
Deprecated: Use HadoopConfig.ProtoReflect.Descriptor instead.
func (*HadoopConfig) GetInitializationActions ¶
func (x *HadoopConfig) GetInitializationActions() []*InitializationAction
func (*HadoopConfig) GetProperties ¶
func (x *HadoopConfig) GetProperties() map[string]string
func (*HadoopConfig) GetServices ¶
func (x *HadoopConfig) GetServices() []HadoopConfig_Service
func (*HadoopConfig) GetSshPublicKeys ¶
func (x *HadoopConfig) GetSshPublicKeys() []string
func (*HadoopConfig) ProtoMessage ¶
func (*HadoopConfig) ProtoMessage()
func (*HadoopConfig) ProtoReflect ¶
func (x *HadoopConfig) ProtoReflect() protoreflect.Message
func (*HadoopConfig) Reset ¶
func (x *HadoopConfig) Reset()
func (*HadoopConfig) SetInitializationActions ¶
func (m *HadoopConfig) SetInitializationActions(v []*InitializationAction)
func (*HadoopConfig) SetProperties ¶
func (m *HadoopConfig) SetProperties(v map[string]string)
func (*HadoopConfig) SetServices ¶
func (m *HadoopConfig) SetServices(v []HadoopConfig_Service)
func (*HadoopConfig) SetSshPublicKeys ¶
func (m *HadoopConfig) SetSshPublicKeys(v []string)
func (*HadoopConfig) String ¶
func (x *HadoopConfig) String() string
type HadoopConfig_Service ¶
type HadoopConfig_Service int32
const ( HadoopConfig_SERVICE_UNSPECIFIED HadoopConfig_Service = 0 HadoopConfig_HDFS HadoopConfig_Service = 1 HadoopConfig_YARN HadoopConfig_Service = 2 HadoopConfig_MAPREDUCE HadoopConfig_Service = 3 HadoopConfig_HIVE HadoopConfig_Service = 4 HadoopConfig_TEZ HadoopConfig_Service = 5 HadoopConfig_ZOOKEEPER HadoopConfig_Service = 6 HadoopConfig_HBASE HadoopConfig_Service = 7 HadoopConfig_SQOOP HadoopConfig_Service = 8 HadoopConfig_FLUME HadoopConfig_Service = 9 HadoopConfig_SPARK HadoopConfig_Service = 10 HadoopConfig_ZEPPELIN HadoopConfig_Service = 11 HadoopConfig_OOZIE HadoopConfig_Service = 12 HadoopConfig_LIVY HadoopConfig_Service = 13 )
func (HadoopConfig_Service) Descriptor ¶
func (HadoopConfig_Service) Descriptor() protoreflect.EnumDescriptor
func (HadoopConfig_Service) Enum ¶
func (x HadoopConfig_Service) Enum() *HadoopConfig_Service
func (HadoopConfig_Service) EnumDescriptor
deprecated
func (HadoopConfig_Service) EnumDescriptor() ([]byte, []int)
Deprecated: Use HadoopConfig_Service.Descriptor instead.
func (HadoopConfig_Service) Number ¶
func (x HadoopConfig_Service) Number() protoreflect.EnumNumber
func (HadoopConfig_Service) String ¶
func (x HadoopConfig_Service) String() string
func (HadoopConfig_Service) Type ¶
func (HadoopConfig_Service) Type() protoreflect.EnumType
type Health ¶
type Health int32
const ( // Object is in unknown state (we have no data). Health_HEALTH_UNKNOWN Health = 0 // Object is alive and well (for example, all hosts of the cluster are alive). Health_ALIVE Health = 1 // Object is inoperable (it cannot perform any of its essential functions). Health_DEAD Health = 2 // Object is partially alive (it can perform some of its essential functions). Health_DEGRADED Health = 3 )
func (Health) Descriptor ¶
func (Health) Descriptor() protoreflect.EnumDescriptor
func (Health) EnumDescriptor
deprecated
func (Health) Number ¶
func (x Health) Number() protoreflect.EnumNumber
func (Health) Type ¶
func (Health) Type() protoreflect.EnumType
type HiveJob ¶
type HiveJob struct { // Property names and values, used to configure Data Proc and Hive. Properties map[string]string `` /* 161-byte string literal not displayed */ // Flag indicating whether a job should continue to run if a query fails. ContinueOnFailure bool `protobuf:"varint,2,opt,name=continue_on_failure,json=continueOnFailure,proto3" json:"continue_on_failure,omitempty"` // Query variables and their values. ScriptVariables map[string]string `` /* 194-byte string literal not displayed */ // JAR file URIs to add to CLASSPATH of the Hive driver and each task. JarFileUris []string `protobuf:"bytes,4,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"` // Types that are assignable to QueryType: // // *HiveJob_QueryFileUri // *HiveJob_QueryList QueryType isHiveJob_QueryType `protobuf_oneof:"query_type"` // contains filtered or unexported fields }
func (*HiveJob) Descriptor
deprecated
func (*HiveJob) GetContinueOnFailure ¶
func (*HiveJob) GetJarFileUris ¶
func (*HiveJob) GetProperties ¶
func (*HiveJob) GetQueryFileUri ¶
func (*HiveJob) GetQueryList ¶
func (*HiveJob) GetQueryType ¶
func (m *HiveJob) GetQueryType() isHiveJob_QueryType
func (*HiveJob) GetScriptVariables ¶
func (*HiveJob) ProtoMessage ¶
func (*HiveJob) ProtoMessage()
func (*HiveJob) ProtoReflect ¶
func (x *HiveJob) ProtoReflect() protoreflect.Message
func (*HiveJob) SetContinueOnFailure ¶
func (*HiveJob) SetJarFileUris ¶
func (*HiveJob) SetProperties ¶
func (*HiveJob) SetQueryFileUri ¶
func (*HiveJob) SetQueryList ¶
func (*HiveJob) SetQueryType ¶
func (m *HiveJob) SetQueryType(v HiveJob_QueryType)
func (*HiveJob) SetScriptVariables ¶
type HiveJob_QueryFileUri ¶
type HiveJob_QueryFileUri struct { // URI of the script with all the necessary Hive queries. QueryFileUri string `protobuf:"bytes,5,opt,name=query_file_uri,json=queryFileUri,proto3,oneof"` }
type HiveJob_QueryList ¶
type HiveJob_QueryList struct { // List of Hive queries to be used in the job. QueryList *QueryList `protobuf:"bytes,6,opt,name=query_list,json=queryList,proto3,oneof"` }
type HiveJob_QueryType ¶
type HiveJob_QueryType = isHiveJob_QueryType
type Host ¶
type Host struct { // Name of the Data Proc host. The host name is assigned by Data Proc at creation time // and cannot be changed. The name is generated to be unique across all Data Proc // hosts that exist on the platform, as it defines the FQDN of the host. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // ID of the Data Proc subcluster that the host belongs to. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // Status code of the aggregated health of the host. Health Health `protobuf:"varint,3,opt,name=health,proto3,enum=yandex.cloud.dataproc.v1.Health" json:"health,omitempty"` // ID of the Compute virtual machine that is used as the Data Proc host. ComputeInstanceId string `protobuf:"bytes,4,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"` // Role of the host in the cluster. Role Role `protobuf:"varint,5,opt,name=role,proto3,enum=yandex.cloud.dataproc.v1.Role" json:"role,omitempty"` // contains filtered or unexported fields }
A Data Proc host. For details about the concept, see [documentation](/docs/data-proc/concepts/).
func (*Host) Descriptor
deprecated
func (*Host) GetComputeInstanceId ¶
func (*Host) GetSubclusterId ¶
func (*Host) ProtoMessage ¶
func (*Host) ProtoMessage()
func (*Host) ProtoReflect ¶
func (x *Host) ProtoReflect() protoreflect.Message
func (*Host) SetComputeInstanceId ¶
func (*Host) SetSubclusterId ¶
type InitializationAction ¶
type InitializationAction struct { // URI of the executable file Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` // Arguments to the initialization action Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` // Execution timeout Timeout int64 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*InitializationAction) Descriptor
deprecated
func (*InitializationAction) Descriptor() ([]byte, []int)
Deprecated: Use InitializationAction.ProtoReflect.Descriptor instead.
func (*InitializationAction) GetArgs ¶
func (x *InitializationAction) GetArgs() []string
func (*InitializationAction) GetTimeout ¶
func (x *InitializationAction) GetTimeout() int64
func (*InitializationAction) GetUri ¶
func (x *InitializationAction) GetUri() string
func (*InitializationAction) ProtoMessage ¶
func (*InitializationAction) ProtoMessage()
func (*InitializationAction) ProtoReflect ¶
func (x *InitializationAction) ProtoReflect() protoreflect.Message
func (*InitializationAction) Reset ¶
func (x *InitializationAction) Reset()
func (*InitializationAction) SetArgs ¶
func (m *InitializationAction) SetArgs(v []string)
func (*InitializationAction) SetTimeout ¶
func (m *InitializationAction) SetTimeout(v int64)
func (*InitializationAction) SetUri ¶
func (m *InitializationAction) SetUri(v string)
func (*InitializationAction) String ¶
func (x *InitializationAction) String() string
type Job ¶
type Job struct { // ID of the job. Generated at creation time. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of the Data Proc cluster that the job belongs to. ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Creation timestamp. CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // The time when the job was started. StartedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` // The time when the job was finished. FinishedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"` // Name of the job, specified in the [JobService.Create] request. Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // The id of the user who created the job CreatedBy string `protobuf:"bytes,12,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"` // Job status. Status Job_Status `protobuf:"varint,7,opt,name=status,proto3,enum=yandex.cloud.dataproc.v1.Job_Status" json:"status,omitempty"` // Specification for the job. // // Types that are assignable to JobSpec: // // *Job_MapreduceJob // *Job_SparkJob // *Job_PysparkJob // *Job_HiveJob JobSpec isJob_JobSpec `protobuf_oneof:"job_spec"` // Attributes of YARN application. ApplicationInfo *ApplicationInfo `protobuf:"bytes,13,opt,name=application_info,json=applicationInfo,proto3" json:"application_info,omitempty"` // contains filtered or unexported fields }
A Data Proc job. For details about the concept, see [documentation](/docs/data-proc/concepts/jobs).
func (*Job) Descriptor
deprecated
func (*Job) GetApplicationInfo ¶
func (x *Job) GetApplicationInfo() *ApplicationInfo
func (*Job) GetClusterId ¶
func (*Job) GetCreatedAt ¶
func (x *Job) GetCreatedAt() *timestamppb.Timestamp
func (*Job) GetCreatedBy ¶
func (*Job) GetFinishedAt ¶
func (x *Job) GetFinishedAt() *timestamppb.Timestamp
func (*Job) GetHiveJob ¶
func (*Job) GetJobSpec ¶
func (m *Job) GetJobSpec() isJob_JobSpec
func (*Job) GetMapreduceJob ¶
func (x *Job) GetMapreduceJob() *MapreduceJob
func (*Job) GetPysparkJob ¶
func (x *Job) GetPysparkJob() *PysparkJob
func (*Job) GetSparkJob ¶
func (*Job) GetStartedAt ¶
func (x *Job) GetStartedAt() *timestamppb.Timestamp
func (*Job) GetStatus ¶
func (x *Job) GetStatus() Job_Status
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
func (*Job) SetApplicationInfo ¶
func (m *Job) SetApplicationInfo(v *ApplicationInfo)
func (*Job) SetClusterId ¶
func (*Job) SetCreatedAt ¶
func (m *Job) SetCreatedAt(v *timestamppb.Timestamp)
func (*Job) SetCreatedBy ¶
func (*Job) SetFinishedAt ¶
func (m *Job) SetFinishedAt(v *timestamppb.Timestamp)
func (*Job) SetHiveJob ¶
func (*Job) SetJobSpec ¶
func (m *Job) SetJobSpec(v Job_JobSpec)
func (*Job) SetMapreduceJob ¶
func (m *Job) SetMapreduceJob(v *MapreduceJob)
func (*Job) SetPysparkJob ¶
func (m *Job) SetPysparkJob(v *PysparkJob)
func (*Job) SetSparkJob ¶
func (*Job) SetStartedAt ¶
func (m *Job) SetStartedAt(v *timestamppb.Timestamp)
func (*Job) SetStatus ¶
func (m *Job) SetStatus(v Job_Status)
type JobServiceClient ¶
type JobServiceClient interface { // Retrieves a list of jobs for a cluster. List(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) // Creates a job for a cluster. Create(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Returns the specified job. Get(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) // Returns a log for specified job. ListLog(ctx context.Context, in *ListJobLogRequest, opts ...grpc.CallOption) (*ListJobLogResponse, error) // Cancels the specified Dataproc job. Cancel(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*operation.Operation, error) }
JobServiceClient is the client API for JobService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewJobServiceClient ¶
func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient
type JobServiceServer ¶
type JobServiceServer interface { // Retrieves a list of jobs for a cluster. List(context.Context, *ListJobsRequest) (*ListJobsResponse, error) // Creates a job for a cluster. Create(context.Context, *CreateJobRequest) (*operation.Operation, error) // Returns the specified job. Get(context.Context, *GetJobRequest) (*Job, error) // Returns a log for specified job. ListLog(context.Context, *ListJobLogRequest) (*ListJobLogResponse, error) // Cancels the specified Dataproc job. Cancel(context.Context, *CancelJobRequest) (*operation.Operation, error) }
JobServiceServer is the server API for JobService service. All implementations should embed UnimplementedJobServiceServer for forward compatibility
type Job_HiveJob ¶
type Job_HiveJob struct { // Specification for a Hive job. HiveJob *HiveJob `protobuf:"bytes,11,opt,name=hive_job,json=hiveJob,proto3,oneof"` }
type Job_JobSpec ¶
type Job_JobSpec = isJob_JobSpec
type Job_MapreduceJob ¶
type Job_MapreduceJob struct { // Specification for a MapReduce job. MapreduceJob *MapreduceJob `protobuf:"bytes,8,opt,name=mapreduce_job,json=mapreduceJob,proto3,oneof"` }
type Job_PysparkJob ¶
type Job_PysparkJob struct { // Specification for a PySpark job. PysparkJob *PysparkJob `protobuf:"bytes,10,opt,name=pyspark_job,json=pysparkJob,proto3,oneof"` }
type Job_SparkJob ¶
type Job_SparkJob struct { // Specification for a Spark job. SparkJob *SparkJob `protobuf:"bytes,9,opt,name=spark_job,json=sparkJob,proto3,oneof"` }
type Job_Status ¶
type Job_Status int32
const ( Job_STATUS_UNSPECIFIED Job_Status = 0 // Job is logged in the database and is waiting for the agent to run it. Job_PROVISIONING Job_Status = 1 // Job is acquired by the agent and is in the queue for execution. Job_PENDING Job_Status = 2 // Job is being run in the cluster. Job_RUNNING Job_Status = 3 // Job failed to finish the run properly. Job_ERROR Job_Status = 4 // Job is finished. Job_DONE Job_Status = 5 // Job is cancelled. Job_CANCELLED Job_Status = 6 // Job is waiting for cancellation. Job_CANCELLING Job_Status = 7 )
func (Job_Status) Descriptor ¶
func (Job_Status) Descriptor() protoreflect.EnumDescriptor
func (Job_Status) Enum ¶
func (x Job_Status) Enum() *Job_Status
func (Job_Status) EnumDescriptor
deprecated
func (Job_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use Job_Status.Descriptor instead.
func (Job_Status) Number ¶
func (x Job_Status) Number() protoreflect.EnumNumber
func (Job_Status) String ¶
func (x Job_Status) String() string
func (Job_Status) Type ¶
func (Job_Status) Type() protoreflect.EnumType
type ListClusterHostsRequest ¶
type ListClusterHostsRequest struct { // ID of the cluster to list hosts for. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListClusterHostsResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. // Default value: 100. PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set [page_token] to the // [ListClusterHostsResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters hosts listed in the response. // // The expression must specify: // 1. The field name. Currently you can use filtering only on [Cluster.name] field. // 2. An `=` operator. // 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`. // Example of a filter: `name=my-host` Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListClusterHostsRequest) Descriptor
deprecated
func (*ListClusterHostsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterHostsRequest.ProtoReflect.Descriptor instead.
func (*ListClusterHostsRequest) GetClusterId ¶
func (x *ListClusterHostsRequest) GetClusterId() string
func (*ListClusterHostsRequest) GetFilter ¶
func (x *ListClusterHostsRequest) GetFilter() string
func (*ListClusterHostsRequest) GetPageSize ¶
func (x *ListClusterHostsRequest) GetPageSize() int64
func (*ListClusterHostsRequest) GetPageToken ¶
func (x *ListClusterHostsRequest) GetPageToken() string
func (*ListClusterHostsRequest) ProtoMessage ¶
func (*ListClusterHostsRequest) ProtoMessage()
func (*ListClusterHostsRequest) ProtoReflect ¶
func (x *ListClusterHostsRequest) ProtoReflect() protoreflect.Message
func (*ListClusterHostsRequest) Reset ¶
func (x *ListClusterHostsRequest) Reset()
func (*ListClusterHostsRequest) SetClusterId ¶
func (m *ListClusterHostsRequest) SetClusterId(v string)
func (*ListClusterHostsRequest) SetFilter ¶
func (m *ListClusterHostsRequest) SetFilter(v string)
func (*ListClusterHostsRequest) SetPageSize ¶
func (m *ListClusterHostsRequest) SetPageSize(v int64)
func (*ListClusterHostsRequest) SetPageToken ¶
func (m *ListClusterHostsRequest) SetPageToken(v string)
func (*ListClusterHostsRequest) String ¶
func (x *ListClusterHostsRequest) String() string
type ListClusterHostsResponse ¶
type ListClusterHostsResponse struct { // Requested list of hosts. Hosts []*Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"` // Token for getting the next page of the list. If the number of results is greater than // the specified [ListClusterHostsRequest.page_size], use `next_page_token` as the value // for the [ListClusterHostsRequest.page_token] parameter in the next list request. // // Each subsequent page will have its own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListClusterHostsResponse) Descriptor
deprecated
func (*ListClusterHostsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterHostsResponse.ProtoReflect.Descriptor instead.
func (*ListClusterHostsResponse) GetHosts ¶
func (x *ListClusterHostsResponse) GetHosts() []*Host
func (*ListClusterHostsResponse) GetNextPageToken ¶
func (x *ListClusterHostsResponse) GetNextPageToken() string
func (*ListClusterHostsResponse) ProtoMessage ¶
func (*ListClusterHostsResponse) ProtoMessage()
func (*ListClusterHostsResponse) ProtoReflect ¶
func (x *ListClusterHostsResponse) ProtoReflect() protoreflect.Message
func (*ListClusterHostsResponse) Reset ¶
func (x *ListClusterHostsResponse) Reset()
func (*ListClusterHostsResponse) SetHosts ¶
func (m *ListClusterHostsResponse) SetHosts(v []*Host)
func (*ListClusterHostsResponse) SetNextPageToken ¶
func (m *ListClusterHostsResponse) SetNextPageToken(v string)
func (*ListClusterHostsResponse) String ¶
func (x *ListClusterHostsResponse) String() string
type ListClusterOperationsRequest ¶
type ListClusterOperationsRequest struct { // ID of the cluster to list operations for. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListClusterOperationsResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. // Default value: 100. PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set [page_token] to the // [ListClusterOperationsResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*ListClusterOperationsRequest) Descriptor
deprecated
func (*ListClusterOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterOperationsRequest.ProtoReflect.Descriptor instead.
func (*ListClusterOperationsRequest) GetClusterId ¶
func (x *ListClusterOperationsRequest) GetClusterId() string
func (*ListClusterOperationsRequest) GetPageSize ¶
func (x *ListClusterOperationsRequest) GetPageSize() int64
func (*ListClusterOperationsRequest) GetPageToken ¶
func (x *ListClusterOperationsRequest) GetPageToken() string
func (*ListClusterOperationsRequest) ProtoMessage ¶
func (*ListClusterOperationsRequest) ProtoMessage()
func (*ListClusterOperationsRequest) ProtoReflect ¶
func (x *ListClusterOperationsRequest) ProtoReflect() protoreflect.Message
func (*ListClusterOperationsRequest) Reset ¶
func (x *ListClusterOperationsRequest) Reset()
func (*ListClusterOperationsRequest) SetClusterId ¶
func (m *ListClusterOperationsRequest) SetClusterId(v string)
func (*ListClusterOperationsRequest) SetPageSize ¶
func (m *ListClusterOperationsRequest) SetPageSize(v int64)
func (*ListClusterOperationsRequest) SetPageToken ¶
func (m *ListClusterOperationsRequest) SetPageToken(v string)
func (*ListClusterOperationsRequest) String ¶
func (x *ListClusterOperationsRequest) String() string
type ListClusterOperationsResponse ¶
type ListClusterOperationsResponse struct { // List of operations for the specified cluster. Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` // Token for getting the next page of the list. If the number of results is greater than // the specified [ListClusterOperationsRequest.page_size], use `next_page_token` as the value // for the [ListClusterOperationsRequest.page_token] parameter in the next list request. // // Each subsequent page will have its own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListClusterOperationsResponse) Descriptor
deprecated
func (*ListClusterOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterOperationsResponse.ProtoReflect.Descriptor instead.
func (*ListClusterOperationsResponse) GetNextPageToken ¶
func (x *ListClusterOperationsResponse) GetNextPageToken() string
func (*ListClusterOperationsResponse) GetOperations ¶
func (x *ListClusterOperationsResponse) GetOperations() []*operation.Operation
func (*ListClusterOperationsResponse) ProtoMessage ¶
func (*ListClusterOperationsResponse) ProtoMessage()
func (*ListClusterOperationsResponse) ProtoReflect ¶
func (x *ListClusterOperationsResponse) ProtoReflect() protoreflect.Message
func (*ListClusterOperationsResponse) Reset ¶
func (x *ListClusterOperationsResponse) Reset()
func (*ListClusterOperationsResponse) SetNextPageToken ¶
func (m *ListClusterOperationsResponse) SetNextPageToken(v string)
func (*ListClusterOperationsResponse) SetOperations ¶
func (m *ListClusterOperationsResponse) SetOperations(v []*operation.Operation)
func (*ListClusterOperationsResponse) String ¶
func (x *ListClusterOperationsResponse) String() string
type ListClustersRequest ¶
type ListClustersRequest struct { // ID of the folder to list clusters in. // // To get the folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request. FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"` // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListClustersResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. // Default value: 100. PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set `page_token` to the // [ListClustersResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters clusters listed in the response. // // The expression must specify: // 1. The field name. Currently you can use filtering only on [Cluster.name] field. // 2. An `=` operator. // 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`. // Example of a filter: `name=my-cluster`. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListClustersRequest) Descriptor
deprecated
func (*ListClustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
func (*ListClustersRequest) GetFilter ¶
func (x *ListClustersRequest) GetFilter() string
func (*ListClustersRequest) GetFolderId ¶
func (x *ListClustersRequest) GetFolderId() string
func (*ListClustersRequest) GetPageSize ¶
func (x *ListClustersRequest) GetPageSize() int64
func (*ListClustersRequest) GetPageToken ¶
func (x *ListClustersRequest) GetPageToken() string
func (*ListClustersRequest) ProtoMessage ¶
func (*ListClustersRequest) ProtoMessage()
func (*ListClustersRequest) ProtoReflect ¶
func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
func (*ListClustersRequest) Reset ¶
func (x *ListClustersRequest) Reset()
func (*ListClustersRequest) SetFilter ¶
func (m *ListClustersRequest) SetFilter(v string)
func (*ListClustersRequest) SetFolderId ¶
func (m *ListClustersRequest) SetFolderId(v string)
func (*ListClustersRequest) SetPageSize ¶
func (m *ListClustersRequest) SetPageSize(v int64)
func (*ListClustersRequest) SetPageToken ¶
func (m *ListClustersRequest) SetPageToken(v string)
func (*ListClustersRequest) String ¶
func (x *ListClustersRequest) String() string
type ListClustersResponse ¶
type ListClustersResponse struct { // List of clusters in the specified folder. Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` // Token for getting the next page of the list. If the number of results is greater than // the specified [ListClustersRequest.page_size], use `next_page_token` as the value // for the [ListClustersRequest.page_token] parameter in the next list request. // // Each subsequent page will have its own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListClustersResponse) Descriptor
deprecated
func (*ListClustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
func (*ListClustersResponse) GetClusters ¶
func (x *ListClustersResponse) GetClusters() []*Cluster
func (*ListClustersResponse) GetNextPageToken ¶
func (x *ListClustersResponse) GetNextPageToken() string
func (*ListClustersResponse) ProtoMessage ¶
func (*ListClustersResponse) ProtoMessage()
func (*ListClustersResponse) ProtoReflect ¶
func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
func (*ListClustersResponse) Reset ¶
func (x *ListClustersResponse) Reset()
func (*ListClustersResponse) SetClusters ¶
func (m *ListClustersResponse) SetClusters(v []*Cluster)
func (*ListClustersResponse) SetNextPageToken ¶
func (m *ListClustersResponse) SetNextPageToken(v string)
func (*ListClustersResponse) String ¶
func (x *ListClustersResponse) String() string
type ListJobLogRequest ¶
type ListJobLogRequest struct { // ID of the cluster that the job is being created for. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the job being created. JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // The maximum bytes of job log per response to return. If the number of available // bytes is larger than [page_size], the service returns a [ListJobLogResponse.next_page_token] // that can be used to get the next page of output in subsequent list requests. // Default value: 1048576. PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set `page_token` to the // [ListJobLogResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*ListJobLogRequest) Descriptor
deprecated
func (*ListJobLogRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListJobLogRequest.ProtoReflect.Descriptor instead.
func (*ListJobLogRequest) GetClusterId ¶
func (x *ListJobLogRequest) GetClusterId() string
func (*ListJobLogRequest) GetJobId ¶
func (x *ListJobLogRequest) GetJobId() string
func (*ListJobLogRequest) GetPageSize ¶
func (x *ListJobLogRequest) GetPageSize() int64
func (*ListJobLogRequest) GetPageToken ¶
func (x *ListJobLogRequest) GetPageToken() string
func (*ListJobLogRequest) ProtoMessage ¶
func (*ListJobLogRequest) ProtoMessage()
func (*ListJobLogRequest) ProtoReflect ¶
func (x *ListJobLogRequest) ProtoReflect() protoreflect.Message
func (*ListJobLogRequest) Reset ¶
func (x *ListJobLogRequest) Reset()
func (*ListJobLogRequest) SetClusterId ¶
func (m *ListJobLogRequest) SetClusterId(v string)
func (*ListJobLogRequest) SetJobId ¶
func (m *ListJobLogRequest) SetJobId(v string)
func (*ListJobLogRequest) SetPageSize ¶
func (m *ListJobLogRequest) SetPageSize(v int64)
func (*ListJobLogRequest) SetPageToken ¶
func (m *ListJobLogRequest) SetPageToken(v string)
func (*ListJobLogRequest) String ¶
func (x *ListJobLogRequest) String() string
type ListJobLogResponse ¶
type ListJobLogResponse struct { // Requested part of Data Proc Job log. Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // This token allows you to get the next page of results for ListLog requests, // if the number of results is larger than `page_size` specified in the request. // To get the next page, specify the value of `next_page_token` as a value for // the `page_token` parameter in the next ListLog request. Subsequent ListLog // requests will have their own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListJobLogResponse) Descriptor
deprecated
func (*ListJobLogResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListJobLogResponse.ProtoReflect.Descriptor instead.
func (*ListJobLogResponse) GetContent ¶
func (x *ListJobLogResponse) GetContent() string
func (*ListJobLogResponse) GetNextPageToken ¶
func (x *ListJobLogResponse) GetNextPageToken() string
func (*ListJobLogResponse) ProtoMessage ¶
func (*ListJobLogResponse) ProtoMessage()
func (*ListJobLogResponse) ProtoReflect ¶
func (x *ListJobLogResponse) ProtoReflect() protoreflect.Message
func (*ListJobLogResponse) Reset ¶
func (x *ListJobLogResponse) Reset()
func (*ListJobLogResponse) SetContent ¶
func (m *ListJobLogResponse) SetContent(v string)
func (*ListJobLogResponse) SetNextPageToken ¶
func (m *ListJobLogResponse) SetNextPageToken(v string)
func (*ListJobLogResponse) String ¶
func (x *ListJobLogResponse) String() string
type ListJobsRequest ¶
type ListJobsRequest struct { // ID of the cluster to list jobs for. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListJobsResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. // Default value: 100. PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set `page_token` to the // [ListJobsResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters jobs listed in the response. // // The expression must specify: // 1. The field name. Currently you can use filtering only on [Job.name] field. // 2. An `=` operator. // 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`. // Example of a filter: `name=my-job`. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListJobsRequest) Descriptor
deprecated
func (*ListJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.
func (*ListJobsRequest) GetClusterId ¶
func (x *ListJobsRequest) GetClusterId() string
func (*ListJobsRequest) GetFilter ¶
func (x *ListJobsRequest) GetFilter() string
func (*ListJobsRequest) GetPageSize ¶
func (x *ListJobsRequest) GetPageSize() int64
func (*ListJobsRequest) GetPageToken ¶
func (x *ListJobsRequest) GetPageToken() string
func (*ListJobsRequest) ProtoMessage ¶
func (*ListJobsRequest) ProtoMessage()
func (*ListJobsRequest) ProtoReflect ¶
func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
func (*ListJobsRequest) Reset ¶
func (x *ListJobsRequest) Reset()
func (*ListJobsRequest) SetClusterId ¶
func (m *ListJobsRequest) SetClusterId(v string)
func (*ListJobsRequest) SetFilter ¶
func (m *ListJobsRequest) SetFilter(v string)
func (*ListJobsRequest) SetPageSize ¶
func (m *ListJobsRequest) SetPageSize(v int64)
func (*ListJobsRequest) SetPageToken ¶
func (m *ListJobsRequest) SetPageToken(v string)
func (*ListJobsRequest) String ¶
func (x *ListJobsRequest) String() string
type ListJobsResponse ¶
type ListJobsResponse struct { // List of jobs for the specified cluster. Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` // Token for getting the next page of the list. If the number of results is greater than // the specified [ListJobsRequest.page_size], use `next_page_token` as the value // for the [ListJobsRequest.page_token] parameter in the next list request. // // Each subsequent page will have its own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListJobsResponse) Descriptor
deprecated
func (*ListJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.
func (*ListJobsResponse) GetJobs ¶
func (x *ListJobsResponse) GetJobs() []*Job
func (*ListJobsResponse) GetNextPageToken ¶
func (x *ListJobsResponse) GetNextPageToken() string
func (*ListJobsResponse) ProtoMessage ¶
func (*ListJobsResponse) ProtoMessage()
func (*ListJobsResponse) ProtoReflect ¶
func (x *ListJobsResponse) ProtoReflect() protoreflect.Message
func (*ListJobsResponse) Reset ¶
func (x *ListJobsResponse) Reset()
func (*ListJobsResponse) SetJobs ¶
func (m *ListJobsResponse) SetJobs(v []*Job)
func (*ListJobsResponse) SetNextPageToken ¶
func (m *ListJobsResponse) SetNextPageToken(v string)
func (*ListJobsResponse) String ¶
func (x *ListJobsResponse) String() string
type ListResourcePresetsRequest ¶
type ListResourcePresetsRequest struct { // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListResourcePresetsResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. PageSize int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set [page_token] to the [ListResourcePresetsResponse.next_page_token] // returned by a previous list request. PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*ListResourcePresetsRequest) Descriptor
deprecated
func (*ListResourcePresetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListResourcePresetsRequest.ProtoReflect.Descriptor instead.
func (*ListResourcePresetsRequest) GetPageSize ¶
func (x *ListResourcePresetsRequest) GetPageSize() int64
func (*ListResourcePresetsRequest) GetPageToken ¶
func (x *ListResourcePresetsRequest) GetPageToken() string
func (*ListResourcePresetsRequest) ProtoMessage ¶
func (*ListResourcePresetsRequest) ProtoMessage()
func (*ListResourcePresetsRequest) ProtoReflect ¶
func (x *ListResourcePresetsRequest) ProtoReflect() protoreflect.Message
func (*ListResourcePresetsRequest) Reset ¶
func (x *ListResourcePresetsRequest) Reset()
func (*ListResourcePresetsRequest) SetPageSize ¶
func (m *ListResourcePresetsRequest) SetPageSize(v int64)
func (*ListResourcePresetsRequest) SetPageToken ¶
func (m *ListResourcePresetsRequest) SetPageToken(v string)
func (*ListResourcePresetsRequest) String ¶
func (x *ListResourcePresetsRequest) String() string
type ListResourcePresetsResponse ¶
type ListResourcePresetsResponse struct { // List of ResourcePreset resources. ResourcePresets []*ResourcePreset `protobuf:"bytes,1,rep,name=resource_presets,json=resourcePresets,proto3" json:"resource_presets,omitempty"` // This token allows you to get the next page of results for list requests. If the number of results // is larger than [ListResourcePresetsRequest.page_size], use the [next_page_token] as the value // for the [ListResourcePresetsRequest.page_token] parameter in the next list request. Each subsequent // list request will have its own [next_page_token] to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListResourcePresetsResponse) Descriptor
deprecated
func (*ListResourcePresetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResourcePresetsResponse.ProtoReflect.Descriptor instead.
func (*ListResourcePresetsResponse) GetNextPageToken ¶
func (x *ListResourcePresetsResponse) GetNextPageToken() string
func (*ListResourcePresetsResponse) GetResourcePresets ¶
func (x *ListResourcePresetsResponse) GetResourcePresets() []*ResourcePreset
func (*ListResourcePresetsResponse) ProtoMessage ¶
func (*ListResourcePresetsResponse) ProtoMessage()
func (*ListResourcePresetsResponse) ProtoReflect ¶
func (x *ListResourcePresetsResponse) ProtoReflect() protoreflect.Message
func (*ListResourcePresetsResponse) Reset ¶
func (x *ListResourcePresetsResponse) Reset()
func (*ListResourcePresetsResponse) SetNextPageToken ¶
func (m *ListResourcePresetsResponse) SetNextPageToken(v string)
func (*ListResourcePresetsResponse) SetResourcePresets ¶
func (m *ListResourcePresetsResponse) SetResourcePresets(v []*ResourcePreset)
func (*ListResourcePresetsResponse) String ¶
func (x *ListResourcePresetsResponse) String() string
type ListSubclustersRequest ¶
type ListSubclustersRequest struct { // ID of the Data Proc cluster to list subclusters in. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // The maximum number of results per page to return. If the number of available // results is larger than [page_size], the service returns a [ListSubclustersResponse.next_page_token] // that can be used to get the next page of results in subsequent list requests. // Default value: 100. PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token. To get the next page of results, set `page_token` to the // [ListSubclustersResponse.next_page_token] returned by a previous list request. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters subclusters listed in the response. // // The expression must specify: // 1. The field name. Currently you can use filtering only on [Subcluster.name] field. // 2. An `=` operator. // 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`. // Example of a filter: `name=dataproc123_subcluster456`. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListSubclustersRequest) Descriptor
deprecated
func (*ListSubclustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubclustersRequest.ProtoReflect.Descriptor instead.
func (*ListSubclustersRequest) GetClusterId ¶
func (x *ListSubclustersRequest) GetClusterId() string
func (*ListSubclustersRequest) GetFilter ¶
func (x *ListSubclustersRequest) GetFilter() string
func (*ListSubclustersRequest) GetPageSize ¶
func (x *ListSubclustersRequest) GetPageSize() int64
func (*ListSubclustersRequest) GetPageToken ¶
func (x *ListSubclustersRequest) GetPageToken() string
func (*ListSubclustersRequest) ProtoMessage ¶
func (*ListSubclustersRequest) ProtoMessage()
func (*ListSubclustersRequest) ProtoReflect ¶
func (x *ListSubclustersRequest) ProtoReflect() protoreflect.Message
func (*ListSubclustersRequest) Reset ¶
func (x *ListSubclustersRequest) Reset()
func (*ListSubclustersRequest) SetClusterId ¶
func (m *ListSubclustersRequest) SetClusterId(v string)
func (*ListSubclustersRequest) SetFilter ¶
func (m *ListSubclustersRequest) SetFilter(v string)
func (*ListSubclustersRequest) SetPageSize ¶
func (m *ListSubclustersRequest) SetPageSize(v int64)
func (*ListSubclustersRequest) SetPageToken ¶
func (m *ListSubclustersRequest) SetPageToken(v string)
func (*ListSubclustersRequest) String ¶
func (x *ListSubclustersRequest) String() string
type ListSubclustersResponse ¶
type ListSubclustersResponse struct { // List of subclusters in the specified cluster. Subclusters []*Subcluster `protobuf:"bytes,1,rep,name=subclusters,proto3" json:"subclusters,omitempty"` // Token for getting the next page of the list. If the number of results is greater than // the specified [ListSubclustersRequest.page_size], use `next_page_token` as the value // for the [ListSubclustersRequest.page_token] parameter in the next list request. // // Each subsequent page will have its own `next_page_token` to continue paging through the results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListSubclustersResponse) Descriptor
deprecated
func (*ListSubclustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSubclustersResponse.ProtoReflect.Descriptor instead.
func (*ListSubclustersResponse) GetNextPageToken ¶
func (x *ListSubclustersResponse) GetNextPageToken() string
func (*ListSubclustersResponse) GetSubclusters ¶
func (x *ListSubclustersResponse) GetSubclusters() []*Subcluster
func (*ListSubclustersResponse) ProtoMessage ¶
func (*ListSubclustersResponse) ProtoMessage()
func (*ListSubclustersResponse) ProtoReflect ¶
func (x *ListSubclustersResponse) ProtoReflect() protoreflect.Message
func (*ListSubclustersResponse) Reset ¶
func (x *ListSubclustersResponse) Reset()
func (*ListSubclustersResponse) SetNextPageToken ¶
func (m *ListSubclustersResponse) SetNextPageToken(v string)
func (*ListSubclustersResponse) SetSubclusters ¶
func (m *ListSubclustersResponse) SetSubclusters(v []*Subcluster)
func (*ListSubclustersResponse) String ¶
func (x *ListSubclustersResponse) String() string
type ListUILinksRequest ¶
type ListUILinksRequest struct { // Required. ID of the Hadoop cluster. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*ListUILinksRequest) Descriptor
deprecated
func (*ListUILinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListUILinksRequest.ProtoReflect.Descriptor instead.
func (*ListUILinksRequest) GetClusterId ¶
func (x *ListUILinksRequest) GetClusterId() string
func (*ListUILinksRequest) ProtoMessage ¶
func (*ListUILinksRequest) ProtoMessage()
func (*ListUILinksRequest) ProtoReflect ¶
func (x *ListUILinksRequest) ProtoReflect() protoreflect.Message
func (*ListUILinksRequest) Reset ¶
func (x *ListUILinksRequest) Reset()
func (*ListUILinksRequest) SetClusterId ¶
func (m *ListUILinksRequest) SetClusterId(v string)
func (*ListUILinksRequest) String ¶
func (x *ListUILinksRequest) String() string
type ListUILinksResponse ¶
type ListUILinksResponse struct { // Requested list of ui links. Links []*UILink `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"` // contains filtered or unexported fields }
func (*ListUILinksResponse) Descriptor
deprecated
func (*ListUILinksResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListUILinksResponse.ProtoReflect.Descriptor instead.
func (*ListUILinksResponse) GetLinks ¶
func (x *ListUILinksResponse) GetLinks() []*UILink
func (*ListUILinksResponse) ProtoMessage ¶
func (*ListUILinksResponse) ProtoMessage()
func (*ListUILinksResponse) ProtoReflect ¶
func (x *ListUILinksResponse) ProtoReflect() protoreflect.Message
func (*ListUILinksResponse) Reset ¶
func (x *ListUILinksResponse) Reset()
func (*ListUILinksResponse) SetLinks ¶
func (m *ListUILinksResponse) SetLinks(v []*UILink)
func (*ListUILinksResponse) String ¶
func (x *ListUILinksResponse) String() string
type MapreduceJob ¶
type MapreduceJob struct { // Optional arguments to pass to the driver. Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"` // JAR file URIs to add to CLASSPATH of the Data Proc driver and each task. JarFileUris []string `protobuf:"bytes,2,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"` // URIs of resource files to be copied to the working directory of Data Proc drivers // and distributed Hadoop tasks. FileUris []string `protobuf:"bytes,3,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"` // URIs of archives to be extracted to the working directory of Data Proc drivers and tasks. ArchiveUris []string `protobuf:"bytes,4,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"` // Property names and values, used to configure Data Proc and MapReduce. Properties map[string]string `` /* 161-byte string literal not displayed */ // Types that are assignable to Driver: // // *MapreduceJob_MainJarFileUri // *MapreduceJob_MainClass Driver isMapreduceJob_Driver `protobuf_oneof:"driver"` // contains filtered or unexported fields }
func (*MapreduceJob) Descriptor
deprecated
func (*MapreduceJob) Descriptor() ([]byte, []int)
Deprecated: Use MapreduceJob.ProtoReflect.Descriptor instead.
func (*MapreduceJob) GetArchiveUris ¶
func (x *MapreduceJob) GetArchiveUris() []string
func (*MapreduceJob) GetArgs ¶
func (x *MapreduceJob) GetArgs() []string
func (*MapreduceJob) GetDriver ¶
func (m *MapreduceJob) GetDriver() isMapreduceJob_Driver
func (*MapreduceJob) GetFileUris ¶
func (x *MapreduceJob) GetFileUris() []string
func (*MapreduceJob) GetJarFileUris ¶
func (x *MapreduceJob) GetJarFileUris() []string
func (*MapreduceJob) GetMainClass ¶
func (x *MapreduceJob) GetMainClass() string
func (*MapreduceJob) GetMainJarFileUri ¶
func (x *MapreduceJob) GetMainJarFileUri() string
func (*MapreduceJob) GetProperties ¶
func (x *MapreduceJob) GetProperties() map[string]string
func (*MapreduceJob) ProtoMessage ¶
func (*MapreduceJob) ProtoMessage()
func (*MapreduceJob) ProtoReflect ¶
func (x *MapreduceJob) ProtoReflect() protoreflect.Message
func (*MapreduceJob) Reset ¶
func (x *MapreduceJob) Reset()
func (*MapreduceJob) SetArchiveUris ¶
func (m *MapreduceJob) SetArchiveUris(v []string)
func (*MapreduceJob) SetArgs ¶
func (m *MapreduceJob) SetArgs(v []string)
func (*MapreduceJob) SetDriver ¶
func (m *MapreduceJob) SetDriver(v MapreduceJob_Driver)
func (*MapreduceJob) SetFileUris ¶
func (m *MapreduceJob) SetFileUris(v []string)
func (*MapreduceJob) SetJarFileUris ¶
func (m *MapreduceJob) SetJarFileUris(v []string)
func (*MapreduceJob) SetMainClass ¶
func (m *MapreduceJob) SetMainClass(v string)
func (*MapreduceJob) SetMainJarFileUri ¶
func (m *MapreduceJob) SetMainJarFileUri(v string)
func (*MapreduceJob) SetProperties ¶
func (m *MapreduceJob) SetProperties(v map[string]string)
func (*MapreduceJob) String ¶
func (x *MapreduceJob) String() string
type MapreduceJob_Driver ¶
type MapreduceJob_Driver = isMapreduceJob_Driver
type MapreduceJob_MainClass ¶
type MapreduceJob_MainClass struct { // The name of the driver class. MainClass string `protobuf:"bytes,7,opt,name=main_class,json=mainClass,proto3,oneof"` }
type MapreduceJob_MainJarFileUri ¶
type MapreduceJob_MainJarFileUri struct { // HCFS URI of the .jar file containing the driver class. MainJarFileUri string `protobuf:"bytes,6,opt,name=main_jar_file_uri,json=mainJarFileUri,proto3,oneof"` }
type Monitoring ¶
type Monitoring struct { // Name of the monitoring system. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Description of the monitoring system. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // Link to the monitoring system. Link string `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
Metadata of a monitoring system for a Data Proc cluster.
func (*Monitoring) Descriptor
deprecated
func (*Monitoring) Descriptor() ([]byte, []int)
Deprecated: Use Monitoring.ProtoReflect.Descriptor instead.
func (*Monitoring) GetDescription ¶
func (x *Monitoring) GetDescription() string
func (*Monitoring) GetLink ¶
func (x *Monitoring) GetLink() string
func (*Monitoring) GetName ¶
func (x *Monitoring) GetName() string
func (*Monitoring) ProtoMessage ¶
func (*Monitoring) ProtoMessage()
func (*Monitoring) ProtoReflect ¶
func (x *Monitoring) ProtoReflect() protoreflect.Message
func (*Monitoring) Reset ¶
func (x *Monitoring) Reset()
func (*Monitoring) SetDescription ¶
func (m *Monitoring) SetDescription(v string)
func (*Monitoring) SetLink ¶
func (m *Monitoring) SetLink(v string)
func (*Monitoring) SetName ¶
func (m *Monitoring) SetName(v string)
func (*Monitoring) String ¶
func (x *Monitoring) String() string
type PysparkJob ¶
type PysparkJob struct { // Optional arguments to pass to the driver. Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"` // JAR file URIs to add to CLASSPATH of the Data Proc driver and each task. JarFileUris []string `protobuf:"bytes,2,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"` // URIs of resource files to be copied to the working directory of Data Proc drivers // and distributed Hadoop tasks. FileUris []string `protobuf:"bytes,3,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"` // URIs of archives to be extracted to the working directory of Data Proc drivers and tasks. ArchiveUris []string `protobuf:"bytes,4,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"` // Property names and values, used to configure Data Proc and PySpark. Properties map[string]string `` /* 161-byte string literal not displayed */ // URI of the file with the driver code. Must be a .py file. MainPythonFileUri string `protobuf:"bytes,6,opt,name=main_python_file_uri,json=mainPythonFileUri,proto3" json:"main_python_file_uri,omitempty"` // URIs of Python files to pass to the PySpark framework. PythonFileUris []string `protobuf:"bytes,7,rep,name=python_file_uris,json=pythonFileUris,proto3" json:"python_file_uris,omitempty"` // List of maven coordinates of jars to include on the driver and executor classpaths. Packages []string `protobuf:"bytes,8,rep,name=packages,proto3" json:"packages,omitempty"` // List of additional remote repositories to search for the maven coordinates given with --packages. Repositories []string `protobuf:"bytes,9,rep,name=repositories,proto3" json:"repositories,omitempty"` // List of groupId:artifactId, to exclude while resolving the dependencies provided in --packages to avoid dependency conflicts. ExcludePackages []string `protobuf:"bytes,10,rep,name=exclude_packages,json=excludePackages,proto3" json:"exclude_packages,omitempty"` // contains filtered or unexported fields }
func (*PysparkJob) Descriptor
deprecated
func (*PysparkJob) Descriptor() ([]byte, []int)
Deprecated: Use PysparkJob.ProtoReflect.Descriptor instead.
func (*PysparkJob) GetArchiveUris ¶
func (x *PysparkJob) GetArchiveUris() []string
func (*PysparkJob) GetArgs ¶
func (x *PysparkJob) GetArgs() []string
func (*PysparkJob) GetExcludePackages ¶
func (x *PysparkJob) GetExcludePackages() []string
func (*PysparkJob) GetFileUris ¶
func (x *PysparkJob) GetFileUris() []string
func (*PysparkJob) GetJarFileUris ¶
func (x *PysparkJob) GetJarFileUris() []string
func (*PysparkJob) GetMainPythonFileUri ¶
func (x *PysparkJob) GetMainPythonFileUri() string
func (*PysparkJob) GetPackages ¶
func (x *PysparkJob) GetPackages() []string
func (*PysparkJob) GetProperties ¶
func (x *PysparkJob) GetProperties() map[string]string
func (*PysparkJob) GetPythonFileUris ¶
func (x *PysparkJob) GetPythonFileUris() []string
func (*PysparkJob) GetRepositories ¶
func (x *PysparkJob) GetRepositories() []string
func (*PysparkJob) ProtoMessage ¶
func (*PysparkJob) ProtoMessage()
func (*PysparkJob) ProtoReflect ¶
func (x *PysparkJob) ProtoReflect() protoreflect.Message
func (*PysparkJob) Reset ¶
func (x *PysparkJob) Reset()
func (*PysparkJob) SetArchiveUris ¶
func (m *PysparkJob) SetArchiveUris(v []string)
func (*PysparkJob) SetArgs ¶
func (m *PysparkJob) SetArgs(v []string)
func (*PysparkJob) SetExcludePackages ¶
func (m *PysparkJob) SetExcludePackages(v []string)
func (*PysparkJob) SetFileUris ¶
func (m *PysparkJob) SetFileUris(v []string)
func (*PysparkJob) SetJarFileUris ¶
func (m *PysparkJob) SetJarFileUris(v []string)
func (*PysparkJob) SetMainPythonFileUri ¶
func (m *PysparkJob) SetMainPythonFileUri(v string)
func (*PysparkJob) SetPackages ¶
func (m *PysparkJob) SetPackages(v []string)
func (*PysparkJob) SetProperties ¶
func (m *PysparkJob) SetProperties(v map[string]string)
func (*PysparkJob) SetPythonFileUris ¶
func (m *PysparkJob) SetPythonFileUris(v []string)
func (*PysparkJob) SetRepositories ¶
func (m *PysparkJob) SetRepositories(v []string)
func (*PysparkJob) String ¶
func (x *PysparkJob) String() string
type QueryList ¶
type QueryList struct { // List of Hive queries. Queries []string `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"` // contains filtered or unexported fields }
func (*QueryList) Descriptor
deprecated
func (*QueryList) GetQueries ¶
func (*QueryList) ProtoMessage ¶
func (*QueryList) ProtoMessage()
func (*QueryList) ProtoReflect ¶
func (x *QueryList) ProtoReflect() protoreflect.Message
func (*QueryList) SetQueries ¶
type ResourcePreset ¶
type ResourcePreset struct { // ID of the ResourcePreset resource. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // IDs of availability zones where the resource preset is available. ZoneIds []string `protobuf:"bytes,2,rep,name=zone_ids,json=zoneIds,proto3" json:"zone_ids,omitempty"` // Number of CPU cores for a Data Proc host created with the preset. Cores int64 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` // RAM volume for a Data Proc host created with the preset, in bytes. Memory int64 `protobuf:"varint,4,opt,name=memory,proto3" json:"memory,omitempty"` // contains filtered or unexported fields }
A ResourcePreset resource for describing hardware configuration presets.
func (*ResourcePreset) Descriptor
deprecated
func (*ResourcePreset) Descriptor() ([]byte, []int)
Deprecated: Use ResourcePreset.ProtoReflect.Descriptor instead.
func (*ResourcePreset) GetCores ¶
func (x *ResourcePreset) GetCores() int64
func (*ResourcePreset) GetId ¶
func (x *ResourcePreset) GetId() string
func (*ResourcePreset) GetMemory ¶
func (x *ResourcePreset) GetMemory() int64
func (*ResourcePreset) GetZoneIds ¶
func (x *ResourcePreset) GetZoneIds() []string
func (*ResourcePreset) ProtoMessage ¶
func (*ResourcePreset) ProtoMessage()
func (*ResourcePreset) ProtoReflect ¶
func (x *ResourcePreset) ProtoReflect() protoreflect.Message
func (*ResourcePreset) Reset ¶
func (x *ResourcePreset) Reset()
func (*ResourcePreset) SetCores ¶
func (m *ResourcePreset) SetCores(v int64)
func (*ResourcePreset) SetId ¶
func (m *ResourcePreset) SetId(v string)
func (*ResourcePreset) SetMemory ¶
func (m *ResourcePreset) SetMemory(v int64)
func (*ResourcePreset) SetZoneIds ¶
func (m *ResourcePreset) SetZoneIds(v []string)
func (*ResourcePreset) String ¶
func (x *ResourcePreset) String() string
type ResourcePresetServiceClient ¶
type ResourcePresetServiceClient interface { // Returns the specified ResourcePreset resource. // // To get the list of available ResourcePreset resources, make a [List] request. Get(ctx context.Context, in *GetResourcePresetRequest, opts ...grpc.CallOption) (*ResourcePreset, error) // Retrieves the list of available ResourcePreset resources. List(ctx context.Context, in *ListResourcePresetsRequest, opts ...grpc.CallOption) (*ListResourcePresetsResponse, error) }
ResourcePresetServiceClient is the client API for ResourcePresetService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewResourcePresetServiceClient ¶
func NewResourcePresetServiceClient(cc grpc.ClientConnInterface) ResourcePresetServiceClient
type ResourcePresetServiceServer ¶
type ResourcePresetServiceServer interface { // Returns the specified ResourcePreset resource. // // To get the list of available ResourcePreset resources, make a [List] request. Get(context.Context, *GetResourcePresetRequest) (*ResourcePreset, error) // Retrieves the list of available ResourcePreset resources. List(context.Context, *ListResourcePresetsRequest) (*ListResourcePresetsResponse, error) }
ResourcePresetServiceServer is the server API for ResourcePresetService service. All implementations should embed UnimplementedResourcePresetServiceServer for forward compatibility
type Resources ¶
type Resources struct { // ID of the resource preset for computational resources available to a host (CPU, memory etc.). // All available presets are listed in the [documentation](/docs/data-proc/concepts/instance-types). ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"` // Type of the storage environment for the host. // Possible values: // * network-hdd - network HDD drive, // * network-ssd - network SSD drive. DiskTypeId string `protobuf:"bytes,2,opt,name=disk_type_id,json=diskTypeId,proto3" json:"disk_type_id,omitempty"` // Volume of the storage available to a host, in bytes. DiskSize int64 `protobuf:"varint,3,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"` // contains filtered or unexported fields }
func (*Resources) Descriptor
deprecated
func (*Resources) GetDiskSize ¶
func (*Resources) GetDiskTypeId ¶
func (*Resources) GetResourcePresetId ¶
func (*Resources) ProtoMessage ¶
func (*Resources) ProtoMessage()
func (*Resources) ProtoReflect ¶
func (x *Resources) ProtoReflect() protoreflect.Message
func (*Resources) SetDiskSize ¶
func (*Resources) SetDiskTypeId ¶
func (*Resources) SetResourcePresetId ¶
type Role ¶
type Role int32
const ( Role_ROLE_UNSPECIFIED Role = 0 // The subcluster fulfills the master role. // // Master can run the following services, depending on the requested components: // * HDFS: Namenode, Secondary Namenode // * YARN: ResourceManager, Timeline Server // * HBase Master // * Hive: Server, Metastore, HCatalog // * Spark History Server // * Zeppelin // * ZooKeeper Role_MASTERNODE Role = 1 // The subcluster is a DATANODE in a Data Proc cluster. // // DATANODE can run the following services, depending on the requested components: // * HDFS DataNode // * YARN NodeManager // * HBase RegionServer // * Spark libraries Role_DATANODE Role = 2 // The subcluster is a COMPUTENODE in a Data Proc cluster. // // COMPUTENODE can run the following services, depending on the requested components: // * YARN NodeManager // * Spark libraries Role_COMPUTENODE Role = 3 )
func (Role) Descriptor ¶
func (Role) Descriptor() protoreflect.EnumDescriptor
func (Role) EnumDescriptor
deprecated
func (Role) Number ¶
func (x Role) Number() protoreflect.EnumNumber
func (Role) Type ¶
func (Role) Type() protoreflect.EnumType
type SparkJob ¶
type SparkJob struct { // Optional arguments to pass to the driver. Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"` // JAR file URIs to add to CLASSPATH of the Data Proc driver and each task. JarFileUris []string `protobuf:"bytes,2,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"` // URIs of resource files to be copied to the working directory of Data Proc drivers // and distributed Hadoop tasks. FileUris []string `protobuf:"bytes,3,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"` // URIs of archives to be extracted to the working directory of Data Proc drivers and tasks. ArchiveUris []string `protobuf:"bytes,4,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"` // Property names and values, used to configure Data Proc and Spark. Properties map[string]string `` /* 161-byte string literal not displayed */ // The HCFS URI of the JAR file containing the `main` class for the job. MainJarFileUri string `protobuf:"bytes,6,opt,name=main_jar_file_uri,json=mainJarFileUri,proto3" json:"main_jar_file_uri,omitempty"` // The name of the driver class. MainClass string `protobuf:"bytes,7,opt,name=main_class,json=mainClass,proto3" json:"main_class,omitempty"` // List of maven coordinates of jars to include on the driver and executor classpaths. Packages []string `protobuf:"bytes,8,rep,name=packages,proto3" json:"packages,omitempty"` // List of additional remote repositories to search for the maven coordinates given with --packages. Repositories []string `protobuf:"bytes,9,rep,name=repositories,proto3" json:"repositories,omitempty"` // List of groupId:artifactId, to exclude while resolving the dependencies provided in --packages to avoid dependency conflicts. ExcludePackages []string `protobuf:"bytes,10,rep,name=exclude_packages,json=excludePackages,proto3" json:"exclude_packages,omitempty"` // contains filtered or unexported fields }
func (*SparkJob) Descriptor
deprecated
func (*SparkJob) GetArchiveUris ¶
func (*SparkJob) GetExcludePackages ¶
func (*SparkJob) GetFileUris ¶
func (*SparkJob) GetJarFileUris ¶
func (*SparkJob) GetMainClass ¶
func (*SparkJob) GetMainJarFileUri ¶
func (*SparkJob) GetPackages ¶
func (*SparkJob) GetProperties ¶
func (*SparkJob) GetRepositories ¶
func (*SparkJob) ProtoMessage ¶
func (*SparkJob) ProtoMessage()
func (*SparkJob) ProtoReflect ¶
func (x *SparkJob) ProtoReflect() protoreflect.Message
func (*SparkJob) SetArchiveUris ¶
func (*SparkJob) SetExcludePackages ¶
func (*SparkJob) SetFileUris ¶
func (*SparkJob) SetJarFileUris ¶
func (*SparkJob) SetMainClass ¶
func (*SparkJob) SetMainJarFileUri ¶
func (*SparkJob) SetPackages ¶
func (*SparkJob) SetProperties ¶
func (*SparkJob) SetRepositories ¶
type StartClusterMetadata ¶
type StartClusterMetadata struct { // ID of the Data Proc cluster that is being started. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*StartClusterMetadata) Descriptor
deprecated
func (*StartClusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use StartClusterMetadata.ProtoReflect.Descriptor instead.
func (*StartClusterMetadata) GetClusterId ¶
func (x *StartClusterMetadata) GetClusterId() string
func (*StartClusterMetadata) ProtoMessage ¶
func (*StartClusterMetadata) ProtoMessage()
func (*StartClusterMetadata) ProtoReflect ¶
func (x *StartClusterMetadata) ProtoReflect() protoreflect.Message
func (*StartClusterMetadata) Reset ¶
func (x *StartClusterMetadata) Reset()
func (*StartClusterMetadata) SetClusterId ¶
func (m *StartClusterMetadata) SetClusterId(v string)
func (*StartClusterMetadata) String ¶
func (x *StartClusterMetadata) String() string
type StartClusterRequest ¶
type StartClusterRequest struct { // ID of the cluster to start. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*StartClusterRequest) Descriptor
deprecated
func (*StartClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartClusterRequest.ProtoReflect.Descriptor instead.
func (*StartClusterRequest) GetClusterId ¶
func (x *StartClusterRequest) GetClusterId() string
func (*StartClusterRequest) ProtoMessage ¶
func (*StartClusterRequest) ProtoMessage()
func (*StartClusterRequest) ProtoReflect ¶
func (x *StartClusterRequest) ProtoReflect() protoreflect.Message
func (*StartClusterRequest) Reset ¶
func (x *StartClusterRequest) Reset()
func (*StartClusterRequest) SetClusterId ¶
func (m *StartClusterRequest) SetClusterId(v string)
func (*StartClusterRequest) String ¶
func (x *StartClusterRequest) String() string
type StopClusterMetadata ¶
type StopClusterMetadata struct { // ID of the Data Proc cluster that is being stopped. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*StopClusterMetadata) Descriptor
deprecated
func (*StopClusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use StopClusterMetadata.ProtoReflect.Descriptor instead.
func (*StopClusterMetadata) GetClusterId ¶
func (x *StopClusterMetadata) GetClusterId() string
func (*StopClusterMetadata) ProtoMessage ¶
func (*StopClusterMetadata) ProtoMessage()
func (*StopClusterMetadata) ProtoReflect ¶
func (x *StopClusterMetadata) ProtoReflect() protoreflect.Message
func (*StopClusterMetadata) Reset ¶
func (x *StopClusterMetadata) Reset()
func (*StopClusterMetadata) SetClusterId ¶
func (m *StopClusterMetadata) SetClusterId(v string)
func (*StopClusterMetadata) String ¶
func (x *StopClusterMetadata) String() string
type StopClusterRequest ¶
type StopClusterRequest struct { // ID of the cluster to stop. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Timeout to gracefully decommission nodes. In seconds. Default value: 0 DecommissionTimeout int64 `protobuf:"varint,2,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // contains filtered or unexported fields }
func (*StopClusterRequest) Descriptor
deprecated
func (*StopClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopClusterRequest.ProtoReflect.Descriptor instead.
func (*StopClusterRequest) GetClusterId ¶
func (x *StopClusterRequest) GetClusterId() string
func (*StopClusterRequest) GetDecommissionTimeout ¶
func (x *StopClusterRequest) GetDecommissionTimeout() int64
func (*StopClusterRequest) ProtoMessage ¶
func (*StopClusterRequest) ProtoMessage()
func (*StopClusterRequest) ProtoReflect ¶
func (x *StopClusterRequest) ProtoReflect() protoreflect.Message
func (*StopClusterRequest) Reset ¶
func (x *StopClusterRequest) Reset()
func (*StopClusterRequest) SetClusterId ¶
func (m *StopClusterRequest) SetClusterId(v string)
func (*StopClusterRequest) SetDecommissionTimeout ¶
func (m *StopClusterRequest) SetDecommissionTimeout(v int64)
func (*StopClusterRequest) String ¶
func (x *StopClusterRequest) String() string
type Subcluster ¶
type Subcluster struct { // ID of the subcluster. Generated at creation time. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of the Data Proc cluster that the subcluster belongs to. ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Creation timestamp. CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // Name of the subcluster. The name is unique within the cluster. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Role that is fulfilled by hosts of the subcluster. Role Role `protobuf:"varint,5,opt,name=role,proto3,enum=yandex.cloud.dataproc.v1.Role" json:"role,omitempty"` // Resources allocated for each host in the subcluster. Resources *Resources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` // ID of the VPC subnet used for hosts in the subcluster. SubnetId string `protobuf:"bytes,7,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` // Number of hosts in the subcluster. HostsCount int64 `protobuf:"varint,8,opt,name=hosts_count,json=hostsCount,proto3" json:"hosts_count,omitempty"` // Assign public ip addresses for all hosts in subcluter. AssignPublicIp bool `protobuf:"varint,9,opt,name=assign_public_ip,json=assignPublicIp,proto3" json:"assign_public_ip,omitempty"` // Configuration for instance group based subclusters AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,10,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` // ID of Compute Instance Group for autoscaling subclusters InstanceGroupId string `protobuf:"bytes,11,opt,name=instance_group_id,json=instanceGroupId,proto3" json:"instance_group_id,omitempty"` // contains filtered or unexported fields }
A Data Proc subcluster. For details about the concept, see [documentation](/docs/data-proc/concepts/).
func (*Subcluster) Descriptor
deprecated
func (*Subcluster) Descriptor() ([]byte, []int)
Deprecated: Use Subcluster.ProtoReflect.Descriptor instead.
func (*Subcluster) GetAssignPublicIp ¶
func (x *Subcluster) GetAssignPublicIp() bool
func (*Subcluster) GetAutoscalingConfig ¶
func (x *Subcluster) GetAutoscalingConfig() *AutoscalingConfig
func (*Subcluster) GetClusterId ¶
func (x *Subcluster) GetClusterId() string
func (*Subcluster) GetCreatedAt ¶
func (x *Subcluster) GetCreatedAt() *timestamppb.Timestamp
func (*Subcluster) GetHostsCount ¶
func (x *Subcluster) GetHostsCount() int64
func (*Subcluster) GetId ¶
func (x *Subcluster) GetId() string
func (*Subcluster) GetInstanceGroupId ¶
func (x *Subcluster) GetInstanceGroupId() string
func (*Subcluster) GetName ¶
func (x *Subcluster) GetName() string
func (*Subcluster) GetResources ¶
func (x *Subcluster) GetResources() *Resources
func (*Subcluster) GetRole ¶
func (x *Subcluster) GetRole() Role
func (*Subcluster) GetSubnetId ¶
func (x *Subcluster) GetSubnetId() string
func (*Subcluster) ProtoMessage ¶
func (*Subcluster) ProtoMessage()
func (*Subcluster) ProtoReflect ¶
func (x *Subcluster) ProtoReflect() protoreflect.Message
func (*Subcluster) Reset ¶
func (x *Subcluster) Reset()
func (*Subcluster) SetAssignPublicIp ¶
func (m *Subcluster) SetAssignPublicIp(v bool)
func (*Subcluster) SetAutoscalingConfig ¶
func (m *Subcluster) SetAutoscalingConfig(v *AutoscalingConfig)
func (*Subcluster) SetClusterId ¶
func (m *Subcluster) SetClusterId(v string)
func (*Subcluster) SetCreatedAt ¶
func (m *Subcluster) SetCreatedAt(v *timestamppb.Timestamp)
func (*Subcluster) SetHostsCount ¶
func (m *Subcluster) SetHostsCount(v int64)
func (*Subcluster) SetId ¶
func (m *Subcluster) SetId(v string)
func (*Subcluster) SetInstanceGroupId ¶
func (m *Subcluster) SetInstanceGroupId(v string)
func (*Subcluster) SetName ¶
func (m *Subcluster) SetName(v string)
func (*Subcluster) SetResources ¶
func (m *Subcluster) SetResources(v *Resources)
func (*Subcluster) SetRole ¶
func (m *Subcluster) SetRole(v Role)
func (*Subcluster) SetSubnetId ¶
func (m *Subcluster) SetSubnetId(v string)
func (*Subcluster) String ¶
func (x *Subcluster) String() string
type SubclusterServiceClient ¶
type SubclusterServiceClient interface { // Returns the specified subcluster. // // To get the list of all available subclusters, make a [SubclusterService.List] request. Get(ctx context.Context, in *GetSubclusterRequest, opts ...grpc.CallOption) (*Subcluster, error) // Retrieves a list of subclusters in the specified cluster. List(ctx context.Context, in *ListSubclustersRequest, opts ...grpc.CallOption) (*ListSubclustersResponse, error) // Creates a subcluster in the specified cluster. Create(ctx context.Context, in *CreateSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Updates the specified subcluster. Update(ctx context.Context, in *UpdateSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) // Deletes the specified subcluster. Delete(ctx context.Context, in *DeleteSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error) }
SubclusterServiceClient is the client API for SubclusterService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSubclusterServiceClient ¶
func NewSubclusterServiceClient(cc grpc.ClientConnInterface) SubclusterServiceClient
type SubclusterServiceServer ¶
type SubclusterServiceServer interface { // Returns the specified subcluster. // // To get the list of all available subclusters, make a [SubclusterService.List] request. Get(context.Context, *GetSubclusterRequest) (*Subcluster, error) // Retrieves a list of subclusters in the specified cluster. List(context.Context, *ListSubclustersRequest) (*ListSubclustersResponse, error) // Creates a subcluster in the specified cluster. Create(context.Context, *CreateSubclusterRequest) (*operation.Operation, error) // Updates the specified subcluster. Update(context.Context, *UpdateSubclusterRequest) (*operation.Operation, error) // Deletes the specified subcluster. Delete(context.Context, *DeleteSubclusterRequest) (*operation.Operation, error) }
SubclusterServiceServer is the server API for SubclusterService service. All implementations should embed UnimplementedSubclusterServiceServer for forward compatibility
type UILink ¶
type UILink struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
func (*UILink) Descriptor
deprecated
func (*UILink) ProtoMessage ¶
func (*UILink) ProtoMessage()
func (*UILink) ProtoReflect ¶
func (x *UILink) ProtoReflect() protoreflect.Message
type UnimplementedClusterServiceServer ¶
type UnimplementedClusterServiceServer struct { }
UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedClusterServiceServer) Create ¶
func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)
func (UnimplementedClusterServiceServer) Delete ¶
func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)
func (UnimplementedClusterServiceServer) Get ¶
func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)
func (UnimplementedClusterServiceServer) List ¶
func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (UnimplementedClusterServiceServer) ListHosts ¶
func (UnimplementedClusterServiceServer) ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
func (UnimplementedClusterServiceServer) ListOperations ¶
func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
func (UnimplementedClusterServiceServer) ListUILinks ¶
func (UnimplementedClusterServiceServer) ListUILinks(context.Context, *ListUILinksRequest) (*ListUILinksResponse, error)
func (UnimplementedClusterServiceServer) Start ¶
func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*operation.Operation, error)
func (UnimplementedClusterServiceServer) Stop ¶
func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)
func (UnimplementedClusterServiceServer) Update ¶
func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)
type UnimplementedJobServiceServer ¶
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedJobServiceServer) Cancel ¶
func (UnimplementedJobServiceServer) Cancel(context.Context, *CancelJobRequest) (*operation.Operation, error)
func (UnimplementedJobServiceServer) Create ¶
func (UnimplementedJobServiceServer) Create(context.Context, *CreateJobRequest) (*operation.Operation, error)
func (UnimplementedJobServiceServer) Get ¶
func (UnimplementedJobServiceServer) Get(context.Context, *GetJobRequest) (*Job, error)
func (UnimplementedJobServiceServer) List ¶
func (UnimplementedJobServiceServer) List(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
func (UnimplementedJobServiceServer) ListLog ¶
func (UnimplementedJobServiceServer) ListLog(context.Context, *ListJobLogRequest) (*ListJobLogResponse, error)
type UnimplementedResourcePresetServiceServer ¶
type UnimplementedResourcePresetServiceServer struct { }
UnimplementedResourcePresetServiceServer should be embedded to have forward compatible implementations.
type UnimplementedSubclusterServiceServer ¶
type UnimplementedSubclusterServiceServer struct { }
UnimplementedSubclusterServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedSubclusterServiceServer) Create ¶
func (UnimplementedSubclusterServiceServer) Create(context.Context, *CreateSubclusterRequest) (*operation.Operation, error)
func (UnimplementedSubclusterServiceServer) Delete ¶
func (UnimplementedSubclusterServiceServer) Delete(context.Context, *DeleteSubclusterRequest) (*operation.Operation, error)
func (UnimplementedSubclusterServiceServer) Get ¶
func (UnimplementedSubclusterServiceServer) Get(context.Context, *GetSubclusterRequest) (*Subcluster, error)
func (UnimplementedSubclusterServiceServer) Update ¶
func (UnimplementedSubclusterServiceServer) Update(context.Context, *UpdateSubclusterRequest) (*operation.Operation, error)
type UnsafeClusterServiceServer ¶
type UnsafeClusterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.
type UnsafeJobServiceServer ¶
type UnsafeJobServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServiceServer will result in compilation errors.
type UnsafeResourcePresetServiceServer ¶
type UnsafeResourcePresetServiceServer interface {
// contains filtered or unexported methods
}
UnsafeResourcePresetServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourcePresetServiceServer will result in compilation errors.
type UnsafeSubclusterServiceServer ¶
type UnsafeSubclusterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSubclusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubclusterServiceServer will result in compilation errors.
type UpdateClusterConfigSpec ¶
type UpdateClusterConfigSpec struct { // New configuration for subclusters in a cluster. SubclustersSpec []*UpdateSubclusterConfigSpec `protobuf:"bytes,1,rep,name=subclusters_spec,json=subclustersSpec,proto3" json:"subclusters_spec,omitempty"` // Hadoop specific options Hadoop *HadoopConfig `protobuf:"bytes,2,opt,name=hadoop,proto3" json:"hadoop,omitempty"` // contains filtered or unexported fields }
func (*UpdateClusterConfigSpec) Descriptor
deprecated
func (*UpdateClusterConfigSpec) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterConfigSpec.ProtoReflect.Descriptor instead.
func (*UpdateClusterConfigSpec) GetHadoop ¶
func (x *UpdateClusterConfigSpec) GetHadoop() *HadoopConfig
func (*UpdateClusterConfigSpec) GetSubclustersSpec ¶
func (x *UpdateClusterConfigSpec) GetSubclustersSpec() []*UpdateSubclusterConfigSpec
func (*UpdateClusterConfigSpec) ProtoMessage ¶
func (*UpdateClusterConfigSpec) ProtoMessage()
func (*UpdateClusterConfigSpec) ProtoReflect ¶
func (x *UpdateClusterConfigSpec) ProtoReflect() protoreflect.Message
func (*UpdateClusterConfigSpec) Reset ¶
func (x *UpdateClusterConfigSpec) Reset()
func (*UpdateClusterConfigSpec) SetHadoop ¶
func (m *UpdateClusterConfigSpec) SetHadoop(v *HadoopConfig)
func (*UpdateClusterConfigSpec) SetSubclustersSpec ¶
func (m *UpdateClusterConfigSpec) SetSubclustersSpec(v []*UpdateSubclusterConfigSpec)
func (*UpdateClusterConfigSpec) String ¶
func (x *UpdateClusterConfigSpec) String() string
type UpdateClusterMetadata ¶
type UpdateClusterMetadata struct { // ID of the cluster that is being updated. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*UpdateClusterMetadata) Descriptor
deprecated
func (*UpdateClusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterMetadata.ProtoReflect.Descriptor instead.
func (*UpdateClusterMetadata) GetClusterId ¶
func (x *UpdateClusterMetadata) GetClusterId() string
func (*UpdateClusterMetadata) ProtoMessage ¶
func (*UpdateClusterMetadata) ProtoMessage()
func (*UpdateClusterMetadata) ProtoReflect ¶
func (x *UpdateClusterMetadata) ProtoReflect() protoreflect.Message
func (*UpdateClusterMetadata) Reset ¶
func (x *UpdateClusterMetadata) Reset()
func (*UpdateClusterMetadata) SetClusterId ¶
func (m *UpdateClusterMetadata) SetClusterId(v string)
func (*UpdateClusterMetadata) String ¶
func (x *UpdateClusterMetadata) String() string
type UpdateClusterRequest ¶
type UpdateClusterRequest struct { // ID of the cluster to update. // // To get the cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Field mask that specifies which attributes of the cluster should be updated. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // New description for the cluster. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // A new set of cluster labels as `key:value` pairs. Labels map[string]string `` /* 153-byte string literal not displayed */ // Configuration and resources for hosts that should be created with the Data Proc cluster. ConfigSpec *UpdateClusterConfigSpec `protobuf:"bytes,5,opt,name=config_spec,json=configSpec,proto3" json:"config_spec,omitempty"` // New name for the Data Proc cluster. The name must be unique within the folder. Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // ID of the new service account to be used by the Data Proc manager agent. ServiceAccountId string `protobuf:"bytes,7,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"` // Name of the new Object Storage bucket to use for Data Proc jobs. Bucket string `protobuf:"bytes,8,opt,name=bucket,proto3" json:"bucket,omitempty"` // Timeout to gracefully decommission nodes. In seconds. Default value: 0 DecommissionTimeout int64 `protobuf:"varint,9,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // Enable UI Proxy feature. UiProxy bool `protobuf:"varint,10,opt,name=ui_proxy,json=uiProxy,proto3" json:"ui_proxy,omitempty"` // User security groups. SecurityGroupIds []string `protobuf:"bytes,11,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"` // Deletion Protection inhibits deletion of the cluster DeletionProtection bool `protobuf:"varint,12,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"` // ID of the cloud logging log group to write logs. If not set, logs will not be sent to logging service LogGroupId string `protobuf:"bytes,13,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"` // contains filtered or unexported fields }
func (*UpdateClusterRequest) Descriptor
deprecated
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.
func (*UpdateClusterRequest) GetBucket ¶
func (x *UpdateClusterRequest) GetBucket() string
func (*UpdateClusterRequest) GetClusterId ¶
func (x *UpdateClusterRequest) GetClusterId() string
func (*UpdateClusterRequest) GetConfigSpec ¶
func (x *UpdateClusterRequest) GetConfigSpec() *UpdateClusterConfigSpec
func (*UpdateClusterRequest) GetDecommissionTimeout ¶
func (x *UpdateClusterRequest) GetDecommissionTimeout() int64
func (*UpdateClusterRequest) GetDeletionProtection ¶
func (x *UpdateClusterRequest) GetDeletionProtection() bool
func (*UpdateClusterRequest) GetDescription ¶
func (x *UpdateClusterRequest) GetDescription() string
func (*UpdateClusterRequest) GetLabels ¶
func (x *UpdateClusterRequest) GetLabels() map[string]string
func (*UpdateClusterRequest) GetLogGroupId ¶
func (x *UpdateClusterRequest) GetLogGroupId() string
func (*UpdateClusterRequest) GetName ¶
func (x *UpdateClusterRequest) GetName() string
func (*UpdateClusterRequest) GetSecurityGroupIds ¶
func (x *UpdateClusterRequest) GetSecurityGroupIds() []string
func (*UpdateClusterRequest) GetServiceAccountId ¶
func (x *UpdateClusterRequest) GetServiceAccountId() string
func (*UpdateClusterRequest) GetUiProxy ¶
func (x *UpdateClusterRequest) GetUiProxy() bool
func (*UpdateClusterRequest) GetUpdateMask ¶
func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateClusterRequest) ProtoMessage ¶
func (*UpdateClusterRequest) ProtoMessage()
func (*UpdateClusterRequest) ProtoReflect ¶
func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
func (*UpdateClusterRequest) Reset ¶
func (x *UpdateClusterRequest) Reset()
func (*UpdateClusterRequest) SetBucket ¶
func (m *UpdateClusterRequest) SetBucket(v string)
func (*UpdateClusterRequest) SetClusterId ¶
func (m *UpdateClusterRequest) SetClusterId(v string)
func (*UpdateClusterRequest) SetConfigSpec ¶
func (m *UpdateClusterRequest) SetConfigSpec(v *UpdateClusterConfigSpec)
func (*UpdateClusterRequest) SetDecommissionTimeout ¶
func (m *UpdateClusterRequest) SetDecommissionTimeout(v int64)
func (*UpdateClusterRequest) SetDeletionProtection ¶
func (m *UpdateClusterRequest) SetDeletionProtection(v bool)
func (*UpdateClusterRequest) SetDescription ¶
func (m *UpdateClusterRequest) SetDescription(v string)
func (*UpdateClusterRequest) SetLabels ¶
func (m *UpdateClusterRequest) SetLabels(v map[string]string)
func (*UpdateClusterRequest) SetLogGroupId ¶
func (m *UpdateClusterRequest) SetLogGroupId(v string)
func (*UpdateClusterRequest) SetName ¶
func (m *UpdateClusterRequest) SetName(v string)
func (*UpdateClusterRequest) SetSecurityGroupIds ¶
func (m *UpdateClusterRequest) SetSecurityGroupIds(v []string)
func (*UpdateClusterRequest) SetServiceAccountId ¶
func (m *UpdateClusterRequest) SetServiceAccountId(v string)
func (*UpdateClusterRequest) SetUiProxy ¶
func (m *UpdateClusterRequest) SetUiProxy(v bool)
func (*UpdateClusterRequest) SetUpdateMask ¶
func (m *UpdateClusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)
func (*UpdateClusterRequest) String ¶
func (x *UpdateClusterRequest) String() string
type UpdateSubclusterConfigSpec ¶
type UpdateSubclusterConfigSpec struct { // ID of the subcluster to update. // // To get the subcluster ID make a [SubclusterService.List] request. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Name of the subcluster. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Resource configuration for each host in the subcluster. Resources *Resources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` // Number of hosts in the subcluster. HostsCount int64 `protobuf:"varint,4,opt,name=hosts_count,json=hostsCount,proto3" json:"hosts_count,omitempty"` // Configuration for instance group based subclusters AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,5,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` // contains filtered or unexported fields }
func (*UpdateSubclusterConfigSpec) Descriptor
deprecated
func (*UpdateSubclusterConfigSpec) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSubclusterConfigSpec.ProtoReflect.Descriptor instead.
func (*UpdateSubclusterConfigSpec) GetAutoscalingConfig ¶
func (x *UpdateSubclusterConfigSpec) GetAutoscalingConfig() *AutoscalingConfig
func (*UpdateSubclusterConfigSpec) GetHostsCount ¶
func (x *UpdateSubclusterConfigSpec) GetHostsCount() int64
func (*UpdateSubclusterConfigSpec) GetId ¶
func (x *UpdateSubclusterConfigSpec) GetId() string
func (*UpdateSubclusterConfigSpec) GetName ¶
func (x *UpdateSubclusterConfigSpec) GetName() string
func (*UpdateSubclusterConfigSpec) GetResources ¶
func (x *UpdateSubclusterConfigSpec) GetResources() *Resources
func (*UpdateSubclusterConfigSpec) ProtoMessage ¶
func (*UpdateSubclusterConfigSpec) ProtoMessage()
func (*UpdateSubclusterConfigSpec) ProtoReflect ¶
func (x *UpdateSubclusterConfigSpec) ProtoReflect() protoreflect.Message
func (*UpdateSubclusterConfigSpec) Reset ¶
func (x *UpdateSubclusterConfigSpec) Reset()
func (*UpdateSubclusterConfigSpec) SetAutoscalingConfig ¶
func (m *UpdateSubclusterConfigSpec) SetAutoscalingConfig(v *AutoscalingConfig)
func (*UpdateSubclusterConfigSpec) SetHostsCount ¶
func (m *UpdateSubclusterConfigSpec) SetHostsCount(v int64)
func (*UpdateSubclusterConfigSpec) SetId ¶
func (m *UpdateSubclusterConfigSpec) SetId(v string)
func (*UpdateSubclusterConfigSpec) SetName ¶
func (m *UpdateSubclusterConfigSpec) SetName(v string)
func (*UpdateSubclusterConfigSpec) SetResources ¶
func (m *UpdateSubclusterConfigSpec) SetResources(v *Resources)
func (*UpdateSubclusterConfigSpec) String ¶
func (x *UpdateSubclusterConfigSpec) String() string
type UpdateSubclusterMetadata ¶
type UpdateSubclusterMetadata struct { // ID of the cluster whose subcluster is being updated. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster that is being updated. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // contains filtered or unexported fields }
func (*UpdateSubclusterMetadata) Descriptor
deprecated
func (*UpdateSubclusterMetadata) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSubclusterMetadata.ProtoReflect.Descriptor instead.
func (*UpdateSubclusterMetadata) GetClusterId ¶
func (x *UpdateSubclusterMetadata) GetClusterId() string
func (*UpdateSubclusterMetadata) GetSubclusterId ¶
func (x *UpdateSubclusterMetadata) GetSubclusterId() string
func (*UpdateSubclusterMetadata) ProtoMessage ¶
func (*UpdateSubclusterMetadata) ProtoMessage()
func (*UpdateSubclusterMetadata) ProtoReflect ¶
func (x *UpdateSubclusterMetadata) ProtoReflect() protoreflect.Message
func (*UpdateSubclusterMetadata) Reset ¶
func (x *UpdateSubclusterMetadata) Reset()
func (*UpdateSubclusterMetadata) SetClusterId ¶
func (m *UpdateSubclusterMetadata) SetClusterId(v string)
func (*UpdateSubclusterMetadata) SetSubclusterId ¶
func (m *UpdateSubclusterMetadata) SetSubclusterId(v string)
func (*UpdateSubclusterMetadata) String ¶
func (x *UpdateSubclusterMetadata) String() string
type UpdateSubclusterRequest ¶
type UpdateSubclusterRequest struct { // ID of the cluster to update a subcluster in. // // To get a cluster ID, make a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // ID of the subcluster to update. // // To get a subcluster ID, make a [SubclusterService.List] request. SubclusterId string `protobuf:"bytes,2,opt,name=subcluster_id,json=subclusterId,proto3" json:"subcluster_id,omitempty"` // Field mask that specifies which attributes of the subcluster should be updated. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // New configuration of resources that should be allocated for each host in the subcluster. Resources *Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"` // New name for the subcluster. The name must be unique within the cluster. Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` // New number of hosts in the subcluster. HostsCount int64 `protobuf:"varint,6,opt,name=hosts_count,json=hostsCount,proto3" json:"hosts_count,omitempty"` // Timeout to gracefully decommission nodes. In seconds. Default value: 0 DecommissionTimeout int64 `protobuf:"varint,7,opt,name=decommission_timeout,json=decommissionTimeout,proto3" json:"decommission_timeout,omitempty"` // Configuration for instance group based subclusters AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,8,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` // contains filtered or unexported fields }
func (*UpdateSubclusterRequest) Descriptor
deprecated
func (*UpdateSubclusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSubclusterRequest.ProtoReflect.Descriptor instead.
func (*UpdateSubclusterRequest) GetAutoscalingConfig ¶
func (x *UpdateSubclusterRequest) GetAutoscalingConfig() *AutoscalingConfig
func (*UpdateSubclusterRequest) GetClusterId ¶
func (x *UpdateSubclusterRequest) GetClusterId() string
func (*UpdateSubclusterRequest) GetDecommissionTimeout ¶
func (x *UpdateSubclusterRequest) GetDecommissionTimeout() int64
func (*UpdateSubclusterRequest) GetHostsCount ¶
func (x *UpdateSubclusterRequest) GetHostsCount() int64
func (*UpdateSubclusterRequest) GetName ¶
func (x *UpdateSubclusterRequest) GetName() string
func (*UpdateSubclusterRequest) GetResources ¶
func (x *UpdateSubclusterRequest) GetResources() *Resources
func (*UpdateSubclusterRequest) GetSubclusterId ¶
func (x *UpdateSubclusterRequest) GetSubclusterId() string
func (*UpdateSubclusterRequest) GetUpdateMask ¶
func (x *UpdateSubclusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateSubclusterRequest) ProtoMessage ¶
func (*UpdateSubclusterRequest) ProtoMessage()
func (*UpdateSubclusterRequest) ProtoReflect ¶
func (x *UpdateSubclusterRequest) ProtoReflect() protoreflect.Message
func (*UpdateSubclusterRequest) Reset ¶
func (x *UpdateSubclusterRequest) Reset()
func (*UpdateSubclusterRequest) SetAutoscalingConfig ¶
func (m *UpdateSubclusterRequest) SetAutoscalingConfig(v *AutoscalingConfig)
func (*UpdateSubclusterRequest) SetClusterId ¶
func (m *UpdateSubclusterRequest) SetClusterId(v string)
func (*UpdateSubclusterRequest) SetDecommissionTimeout ¶
func (m *UpdateSubclusterRequest) SetDecommissionTimeout(v int64)
func (*UpdateSubclusterRequest) SetHostsCount ¶
func (m *UpdateSubclusterRequest) SetHostsCount(v int64)
func (*UpdateSubclusterRequest) SetName ¶
func (m *UpdateSubclusterRequest) SetName(v string)
func (*UpdateSubclusterRequest) SetResources ¶
func (m *UpdateSubclusterRequest) SetResources(v *Resources)
func (*UpdateSubclusterRequest) SetSubclusterId ¶
func (m *UpdateSubclusterRequest) SetSubclusterId(v string)
func (*UpdateSubclusterRequest) SetUpdateMask ¶
func (m *UpdateSubclusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)
func (*UpdateSubclusterRequest) String ¶
func (x *UpdateSubclusterRequest) String() string
Source Files ¶
- cluster.pb.go
- cluster.pbext.go
- cluster_service.pb.go
- cluster_service.pbext.go
- cluster_service_grpc.pb.go
- common.pb.go
- common.pbext.go
- job.pb.go
- job.pbext.go
- job_service.pb.go
- job_service.pbext.go
- job_service_grpc.pb.go
- resource_preset.pb.go
- resource_preset.pbext.go
- resource_preset_service.pb.go
- resource_preset_service.pbext.go
- resource_preset_service_grpc.pb.go
- subcluster.pb.go
- subcluster.pbext.go
- subcluster_service.pb.go
- subcluster_service.pbext.go
- subcluster_service_grpc.pb.go