dataproc

package
v0.0.0-...-a04abcf Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2024 License: MIT Imports: 15 Imported by: 6

Documentation

Index

Constants

View Source 
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"
)
View Source 
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"
)
View Source 
const (
	ResourcePresetService_Get_FullMethodName  = "/yandex.cloud.dataproc.v1.ResourcePresetService/Get"
	ResourcePresetService_List_FullMethodName = "/yandex.cloud.dataproc.v1.ResourcePresetService/List"
)
View Source 
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

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
var File_yandex_cloud_dataproc_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_cluster_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_job_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_job_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_resource_preset_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_resource_preset_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_subcluster_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_dataproc_v1_subcluster_service_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetBucket 

func (x *Cluster) GetBucket() string

func (*Cluster) GetConfig 

func (x *Cluster) GetConfig() *ClusterConfig

func (*Cluster) GetCreatedAt 

func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp

func (*Cluster) GetDeletionProtection 

func (x *Cluster) GetDeletionProtection() bool

func (*Cluster) GetDescription 

func (x *Cluster) GetDescription() string

func (*Cluster) GetFolderId 

func (x *Cluster) GetFolderId() string

func (*Cluster) GetHealth 

func (x *Cluster) GetHealth() Health

func (*Cluster) GetHostGroupIds 

func (x *Cluster) GetHostGroupIds() []string

func (*Cluster) GetId 

func (x *Cluster) GetId() string

func (*Cluster) GetLabels 

func (x *Cluster) GetLabels() map[string]string

func (*Cluster) GetLogGroupId 

func (x *Cluster) GetLogGroupId() string

func (*Cluster) GetMonitoring 

func (x *Cluster) GetMonitoring() []*Monitoring

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetSecurityGroupIds 

func (x *Cluster) GetSecurityGroupIds() []string

func (*Cluster) GetServiceAccountId 

func (x *Cluster) GetServiceAccountId() string

func (*Cluster) GetStatus 

func (x *Cluster) GetStatus() Cluster_Status

func (*Cluster) GetUiProxy 

func (x *Cluster) GetUiProxy() bool

func (*Cluster) GetZoneId 

func (x *Cluster) GetZoneId() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SetBucket 

func (m *Cluster) SetBucket(v string)

func (*Cluster) SetConfig 

func (m *Cluster) SetConfig(v *ClusterConfig)

func (*Cluster) SetCreatedAt 

func (m *Cluster) SetCreatedAt(v *timestamppb.Timestamp)

func (*Cluster) SetDeletionProtection 

func (m *Cluster) SetDeletionProtection(v bool)

func (*Cluster) SetDescription 

func (m *Cluster) SetDescription(v string)

func (*Cluster) SetFolderId 

func (m *Cluster) SetFolderId(v string)

func (*Cluster) SetHealth 

func (m *Cluster) SetHealth(v Health)

func (*Cluster) SetHostGroupIds 

func (m *Cluster) SetHostGroupIds(v []string)

func (*Cluster) SetId 

func (m *Cluster) SetId(v string)

func (*Cluster) SetLabels 

func (m *Cluster) SetLabels(v map[string]string)

func (*Cluster) SetLogGroupId 

func (m *Cluster) SetLogGroupId(v string)

func (*Cluster) SetMonitoring 

func (m *Cluster) SetMonitoring(v []*Monitoring)

func (*Cluster) SetName 

func (m *Cluster) SetName(v string)

func (*Cluster) SetSecurityGroupIds 

func (m *Cluster) SetSecurityGroupIds(v []string)

func (*Cluster) SetServiceAccountId 

func (m *Cluster) SetServiceAccountId(v string)

func (*Cluster) SetStatus 

func (m *Cluster) SetStatus(v Cluster_Status)

func (*Cluster) SetUiProxy 

func (m *Cluster) SetUiProxy(v bool)

func (*Cluster) SetZoneId 

func (m *Cluster) SetZoneId(v string)

func (*Cluster) String 

func (x *Cluster) String() string

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) Enum 

func (x Health) Enum() *Health

func (Health) EnumDescriptor deprecated 

func (Health) EnumDescriptor() ([]byte, []int)

Deprecated: Use Health.Descriptor instead.

func (Health) Number 

func (x Health) Number() protoreflect.EnumNumber

func (Health) String 

func (x Health) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use HiveJob.ProtoReflect.Descriptor instead.

func (*HiveJob) GetContinueOnFailure 

func (x *HiveJob) GetContinueOnFailure() bool

func (*HiveJob) GetJarFileUris 

func (x *HiveJob) GetJarFileUris() []string

func (*HiveJob) GetProperties 

func (x *HiveJob) GetProperties() map[string]string

func (*HiveJob) GetQueryFileUri 

func (x *HiveJob) GetQueryFileUri() string

func (*HiveJob) GetQueryList 

func (x *HiveJob) GetQueryList() *QueryList

func (*HiveJob) GetQueryType 

func (m *HiveJob) GetQueryType() isHiveJob_QueryType

func (*HiveJob) GetScriptVariables 

func (x *HiveJob) GetScriptVariables() map[string]string

func (*HiveJob) ProtoMessage 

func (*HiveJob) ProtoMessage()

func (*HiveJob) ProtoReflect 

func (x *HiveJob) ProtoReflect() protoreflect.Message

func (*HiveJob) Reset 

func (x *HiveJob) Reset()

func (*HiveJob) SetContinueOnFailure 

func (m *HiveJob) SetContinueOnFailure(v bool)

func (*HiveJob) SetJarFileUris 

func (m *HiveJob) SetJarFileUris(v []string)

func (*HiveJob) SetProperties 

func (m *HiveJob) SetProperties(v map[string]string)

func (*HiveJob) SetQueryFileUri 

func (m *HiveJob) SetQueryFileUri(v string)

func (*HiveJob) SetQueryList 

func (m *HiveJob) SetQueryList(v *QueryList)

func (*HiveJob) SetQueryType 

func (m *HiveJob) SetQueryType(v HiveJob_QueryType)

func (*HiveJob) SetScriptVariables 

func (m *HiveJob) SetScriptVariables(v map[string]string)

func (*HiveJob) String 

func (x *HiveJob) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetComputeInstanceId 

func (x *Host) GetComputeInstanceId() string

func (*Host) GetHealth 

func (x *Host) GetHealth() Health

func (*Host) GetName 

func (x *Host) GetName() string

func (*Host) GetRole 

func (x *Host) GetRole() Role

func (*Host) GetSubclusterId 

func (x *Host) GetSubclusterId() string

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

func (x *Host) ProtoReflect() protoreflect.Message

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) SetComputeInstanceId 

func (m *Host) SetComputeInstanceId(v string)

func (*Host) SetHealth 

func (m *Host) SetHealth(v Health)

func (*Host) SetName 

func (m *Host) SetName(v string)

func (*Host) SetRole 

func (m *Host) SetRole(v Role)

func (*Host) SetSubclusterId 

func (m *Host) SetSubclusterId(v string)

func (*Host) String 

func (x *Host) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetApplicationInfo 

func (x *Job) GetApplicationInfo() *ApplicationInfo

func (*Job) GetClusterId 

func (x *Job) GetClusterId() string

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() *timestamppb.Timestamp

func (*Job) GetCreatedBy 

func (x *Job) GetCreatedBy() string

func (*Job) GetFinishedAt 

func (x *Job) GetFinishedAt() *timestamppb.Timestamp

func (*Job) GetHiveJob 

func (x *Job) GetHiveJob() *HiveJob

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetJobSpec 

func (m *Job) GetJobSpec() isJob_JobSpec

func (*Job) GetMapreduceJob 

func (x *Job) GetMapreduceJob() *MapreduceJob

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetPysparkJob 

func (x *Job) GetPysparkJob() *PysparkJob

func (*Job) GetSparkJob 

func (x *Job) GetSparkJob() *SparkJob

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) Reset 

func (x *Job) Reset()

func (*Job) SetApplicationInfo 

func (m *Job) SetApplicationInfo(v *ApplicationInfo)

func (*Job) SetClusterId 

func (m *Job) SetClusterId(v string)

func (*Job) SetCreatedAt 

func (m *Job) SetCreatedAt(v *timestamppb.Timestamp)

func (*Job) SetCreatedBy 

func (m *Job) SetCreatedBy(v string)

func (*Job) SetFinishedAt 

func (m *Job) SetFinishedAt(v *timestamppb.Timestamp)

func (*Job) SetHiveJob 

func (m *Job) SetHiveJob(v *HiveJob)

func (*Job) SetId 

func (m *Job) SetId(v string)

func (*Job) SetJobSpec 

func (m *Job) SetJobSpec(v Job_JobSpec)

func (*Job) SetMapreduceJob 

func (m *Job) SetMapreduceJob(v *MapreduceJob)

func (*Job) SetName 

func (m *Job) SetName(v string)

func (*Job) SetPysparkJob 

func (m *Job) SetPysparkJob(v *PysparkJob)

func (*Job) SetSparkJob 

func (m *Job) SetSparkJob(v *SparkJob)

func (*Job) SetStartedAt 

func (m *Job) SetStartedAt(v *timestamppb.Timestamp)

func (*Job) SetStatus 

func (m *Job) SetStatus(v Job_Status)

func (*Job) String 

func (x *Job) String() string

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 (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 (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 (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 (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) Descriptor() ([]byte, []int)

Deprecated: Use QueryList.ProtoReflect.Descriptor instead.

func (*QueryList) GetQueries 

func (x *QueryList) GetQueries() []string

func (*QueryList) ProtoMessage 

func (*QueryList) ProtoMessage()

func (*QueryList) ProtoReflect 

func (x *QueryList) ProtoReflect() protoreflect.Message

func (*QueryList) Reset 

func (x *QueryList) Reset()

func (*QueryList) SetQueries 

func (m *QueryList) SetQueries(v []string)

func (*QueryList) String 

func (x *QueryList) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetDiskSize 

func (x *Resources) GetDiskSize() int64

func (*Resources) GetDiskTypeId 

func (x *Resources) GetDiskTypeId() string

func (*Resources) GetResourcePresetId 

func (x *Resources) GetResourcePresetId() string

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

func (x *Resources) ProtoReflect() protoreflect.Message

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) SetDiskSize 

func (m *Resources) SetDiskSize(v int64)

func (*Resources) SetDiskTypeId 

func (m *Resources) SetDiskTypeId(v string)

func (*Resources) SetResourcePresetId 

func (m *Resources) SetResourcePresetId(v string)

func (*Resources) String 

func (x *Resources) String() string

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) Enum 

func (x Role) Enum() *Role

func (Role) EnumDescriptor deprecated 

func (Role) EnumDescriptor() ([]byte, []int)

Deprecated: Use Role.Descriptor instead.

func (Role) Number 

func (x Role) Number() protoreflect.EnumNumber

func (Role) String 

func (x Role) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use SparkJob.ProtoReflect.Descriptor instead.

func (*SparkJob) GetArchiveUris 

func (x *SparkJob) GetArchiveUris() []string

func (*SparkJob) GetArgs 

func (x *SparkJob) GetArgs() []string

func (*SparkJob) GetExcludePackages 

func (x *SparkJob) GetExcludePackages() []string

func (*SparkJob) GetFileUris 

func (x *SparkJob) GetFileUris() []string

func (*SparkJob) GetJarFileUris 

func (x *SparkJob) GetJarFileUris() []string

func (*SparkJob) GetMainClass 

func (x *SparkJob) GetMainClass() string

func (*SparkJob) GetMainJarFileUri 

func (x *SparkJob) GetMainJarFileUri() string

func (*SparkJob) GetPackages 

func (x *SparkJob) GetPackages() []string

func (*SparkJob) GetProperties 

func (x *SparkJob) GetProperties() map[string]string

func (*SparkJob) GetRepositories 

func (x *SparkJob) GetRepositories() []string

func (*SparkJob) ProtoMessage 

func (*SparkJob) ProtoMessage()

func (*SparkJob) ProtoReflect 

func (x *SparkJob) ProtoReflect() protoreflect.Message

func (*SparkJob) Reset 

func (x *SparkJob) Reset()

func (*SparkJob) SetArchiveUris 

func (m *SparkJob) SetArchiveUris(v []string)

func (*SparkJob) SetArgs 

func (m *SparkJob) SetArgs(v []string)

func (*SparkJob) SetExcludePackages 

func (m *SparkJob) SetExcludePackages(v []string)

func (*SparkJob) SetFileUris 

func (m *SparkJob) SetFileUris(v []string)

func (*SparkJob) SetJarFileUris 

func (m *SparkJob) SetJarFileUris(v []string)

func (*SparkJob) SetMainClass 

func (m *SparkJob) SetMainClass(v string)

func (*SparkJob) SetMainJarFileUri 

func (m *SparkJob) SetMainJarFileUri(v string)

func (*SparkJob) SetPackages 

func (m *SparkJob) SetPackages(v []string)

func (*SparkJob) SetProperties 

func (m *SparkJob) SetProperties(v map[string]string)

func (*SparkJob) SetRepositories 

func (m *SparkJob) SetRepositories(v []string)

func (*SparkJob) String 

func (x *SparkJob) String() string

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 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) Descriptor() ([]byte, []int)

Deprecated: Use UILink.ProtoReflect.Descriptor instead.

func (*UILink) GetName 

func (x *UILink) GetName() string

func (*UILink) GetUrl 

func (x *UILink) GetUrl() string

func (*UILink) ProtoMessage 

func (*UILink) ProtoMessage()

func (*UILink) ProtoReflect 

func (x *UILink) ProtoReflect() protoreflect.Message

func (*UILink) Reset 

func (x *UILink) Reset()

func (*UILink) SetName 

func (m *UILink) SetName(v string)

func (*UILink) SetUrl 

func (m *UILink) SetUrl(v string)

func (*UILink) String 

func (x *UILink) String() string

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(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.

func (UnimplementedResourcePresetServiceServer) Get 

func (UnimplementedResourcePresetServiceServer) Get(context.Context, *GetResourcePresetRequest) (*ResourcePreset, error)

func (UnimplementedResourcePresetServiceServer) List 

func (UnimplementedResourcePresetServiceServer) List(context.Context, *ListResourcePresetsRequest) (*ListResourcePresetsResponse, error)

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) List 

func (UnimplementedSubclusterServiceServer) List(context.Context, *ListSubclustersRequest) (*ListSubclustersResponse, 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.