1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/dataflow/v1beta3/environment.proto 20 21package dataflow 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 _ "google.golang.org/genproto/googleapis/api/annotations" 28 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 29 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 30 anypb "google.golang.org/protobuf/types/known/anypb" 31 structpb "google.golang.org/protobuf/types/known/structpb" 32) 33 34const ( 35 // Verify that this generated code is sufficiently up-to-date. 36 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 37 // Verify that runtime/protoimpl is sufficiently up-to-date. 38 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 39) 40 41// Specifies the processing model used by a 42// [google.dataflow.v1beta3.Job], which determines the way the Job is 43// managed by the Cloud Dataflow service (how workers are scheduled, how 44// inputs are sharded, etc). 45type JobType int32 46 47const ( 48 // The type of the job is unspecified, or unknown. 49 JobType_JOB_TYPE_UNKNOWN JobType = 0 50 // A batch job with a well-defined end point: data is read, data is 51 // processed, data is written, and the job is done. 52 JobType_JOB_TYPE_BATCH JobType = 1 53 // A continuously streaming job with no end: data is read, 54 // processed, and written continuously. 55 JobType_JOB_TYPE_STREAMING JobType = 2 56) 57 58// Enum value maps for JobType. 59var ( 60 JobType_name = map[int32]string{ 61 0: "JOB_TYPE_UNKNOWN", 62 1: "JOB_TYPE_BATCH", 63 2: "JOB_TYPE_STREAMING", 64 } 65 JobType_value = map[string]int32{ 66 "JOB_TYPE_UNKNOWN": 0, 67 "JOB_TYPE_BATCH": 1, 68 "JOB_TYPE_STREAMING": 2, 69 } 70) 71 72func (x JobType) Enum() *JobType { 73 p := new(JobType) 74 *p = x 75 return p 76} 77 78func (x JobType) String() string { 79 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 80} 81 82func (JobType) Descriptor() protoreflect.EnumDescriptor { 83 return file_google_dataflow_v1beta3_environment_proto_enumTypes[0].Descriptor() 84} 85 86func (JobType) Type() protoreflect.EnumType { 87 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[0] 88} 89 90func (x JobType) Number() protoreflect.EnumNumber { 91 return protoreflect.EnumNumber(x) 92} 93 94// Deprecated: Use JobType.Descriptor instead. 95func (JobType) EnumDescriptor() ([]byte, []int) { 96 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{0} 97} 98 99// Specifies the resource to optimize for in Flexible Resource Scheduling. 100type FlexResourceSchedulingGoal int32 101 102const ( 103 // Run in the default mode. 104 FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED FlexResourceSchedulingGoal = 0 105 // Optimize for lower execution time. 106 FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED FlexResourceSchedulingGoal = 1 107 // Optimize for lower cost. 108 FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED FlexResourceSchedulingGoal = 2 109) 110 111// Enum value maps for FlexResourceSchedulingGoal. 112var ( 113 FlexResourceSchedulingGoal_name = map[int32]string{ 114 0: "FLEXRS_UNSPECIFIED", 115 1: "FLEXRS_SPEED_OPTIMIZED", 116 2: "FLEXRS_COST_OPTIMIZED", 117 } 118 FlexResourceSchedulingGoal_value = map[string]int32{ 119 "FLEXRS_UNSPECIFIED": 0, 120 "FLEXRS_SPEED_OPTIMIZED": 1, 121 "FLEXRS_COST_OPTIMIZED": 2, 122 } 123) 124 125func (x FlexResourceSchedulingGoal) Enum() *FlexResourceSchedulingGoal { 126 p := new(FlexResourceSchedulingGoal) 127 *p = x 128 return p 129} 130 131func (x FlexResourceSchedulingGoal) String() string { 132 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 133} 134 135func (FlexResourceSchedulingGoal) Descriptor() protoreflect.EnumDescriptor { 136 return file_google_dataflow_v1beta3_environment_proto_enumTypes[1].Descriptor() 137} 138 139func (FlexResourceSchedulingGoal) Type() protoreflect.EnumType { 140 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[1] 141} 142 143func (x FlexResourceSchedulingGoal) Number() protoreflect.EnumNumber { 144 return protoreflect.EnumNumber(x) 145} 146 147// Deprecated: Use FlexResourceSchedulingGoal.Descriptor instead. 148func (FlexResourceSchedulingGoal) EnumDescriptor() ([]byte, []int) { 149 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{1} 150} 151 152// Specifies what happens to a resource when a Cloud Dataflow 153// [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job] has completed. 154type TeardownPolicy int32 155 156const ( 157 // The teardown policy isn't specified, or is unknown. 158 TeardownPolicy_TEARDOWN_POLICY_UNKNOWN TeardownPolicy = 0 159 // Always teardown the resource. 160 TeardownPolicy_TEARDOWN_ALWAYS TeardownPolicy = 1 161 // Teardown the resource on success. This is useful for debugging 162 // failures. 163 TeardownPolicy_TEARDOWN_ON_SUCCESS TeardownPolicy = 2 164 // Never teardown the resource. This is useful for debugging and 165 // development. 166 TeardownPolicy_TEARDOWN_NEVER TeardownPolicy = 3 167) 168 169// Enum value maps for TeardownPolicy. 170var ( 171 TeardownPolicy_name = map[int32]string{ 172 0: "TEARDOWN_POLICY_UNKNOWN", 173 1: "TEARDOWN_ALWAYS", 174 2: "TEARDOWN_ON_SUCCESS", 175 3: "TEARDOWN_NEVER", 176 } 177 TeardownPolicy_value = map[string]int32{ 178 "TEARDOWN_POLICY_UNKNOWN": 0, 179 "TEARDOWN_ALWAYS": 1, 180 "TEARDOWN_ON_SUCCESS": 2, 181 "TEARDOWN_NEVER": 3, 182 } 183) 184 185func (x TeardownPolicy) Enum() *TeardownPolicy { 186 p := new(TeardownPolicy) 187 *p = x 188 return p 189} 190 191func (x TeardownPolicy) String() string { 192 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 193} 194 195func (TeardownPolicy) Descriptor() protoreflect.EnumDescriptor { 196 return file_google_dataflow_v1beta3_environment_proto_enumTypes[2].Descriptor() 197} 198 199func (TeardownPolicy) Type() protoreflect.EnumType { 200 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[2] 201} 202 203func (x TeardownPolicy) Number() protoreflect.EnumNumber { 204 return protoreflect.EnumNumber(x) 205} 206 207// Deprecated: Use TeardownPolicy.Descriptor instead. 208func (TeardownPolicy) EnumDescriptor() ([]byte, []int) { 209 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{2} 210} 211 212// The default set of packages to be staged on a pool of workers. 213type DefaultPackageSet int32 214 215const ( 216 // The default set of packages to stage is unknown, or unspecified. 217 DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN DefaultPackageSet = 0 218 // Indicates that no packages should be staged at the worker unless 219 // explicitly specified by the job. 220 DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE DefaultPackageSet = 1 221 // Stage packages typically useful to workers written in Java. 222 DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA DefaultPackageSet = 2 223 // Stage packages typically useful to workers written in Python. 224 DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON DefaultPackageSet = 3 225) 226 227// Enum value maps for DefaultPackageSet. 228var ( 229 DefaultPackageSet_name = map[int32]string{ 230 0: "DEFAULT_PACKAGE_SET_UNKNOWN", 231 1: "DEFAULT_PACKAGE_SET_NONE", 232 2: "DEFAULT_PACKAGE_SET_JAVA", 233 3: "DEFAULT_PACKAGE_SET_PYTHON", 234 } 235 DefaultPackageSet_value = map[string]int32{ 236 "DEFAULT_PACKAGE_SET_UNKNOWN": 0, 237 "DEFAULT_PACKAGE_SET_NONE": 1, 238 "DEFAULT_PACKAGE_SET_JAVA": 2, 239 "DEFAULT_PACKAGE_SET_PYTHON": 3, 240 } 241) 242 243func (x DefaultPackageSet) Enum() *DefaultPackageSet { 244 p := new(DefaultPackageSet) 245 *p = x 246 return p 247} 248 249func (x DefaultPackageSet) String() string { 250 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 251} 252 253func (DefaultPackageSet) Descriptor() protoreflect.EnumDescriptor { 254 return file_google_dataflow_v1beta3_environment_proto_enumTypes[3].Descriptor() 255} 256 257func (DefaultPackageSet) Type() protoreflect.EnumType { 258 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[3] 259} 260 261func (x DefaultPackageSet) Number() protoreflect.EnumNumber { 262 return protoreflect.EnumNumber(x) 263} 264 265// Deprecated: Use DefaultPackageSet.Descriptor instead. 266func (DefaultPackageSet) EnumDescriptor() ([]byte, []int) { 267 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{3} 268} 269 270// Specifies the algorithm used to determine the number of worker 271// processes to run at any given point in time, based on the amount of 272// data left to process, the number of workers, and how quickly 273// existing workers are processing data. 274type AutoscalingAlgorithm int32 275 276const ( 277 // The algorithm is unknown, or unspecified. 278 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN AutoscalingAlgorithm = 0 279 // Disable autoscaling. 280 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE AutoscalingAlgorithm = 1 281 // Increase worker count over time to reduce job execution time. 282 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC AutoscalingAlgorithm = 2 283) 284 285// Enum value maps for AutoscalingAlgorithm. 286var ( 287 AutoscalingAlgorithm_name = map[int32]string{ 288 0: "AUTOSCALING_ALGORITHM_UNKNOWN", 289 1: "AUTOSCALING_ALGORITHM_NONE", 290 2: "AUTOSCALING_ALGORITHM_BASIC", 291 } 292 AutoscalingAlgorithm_value = map[string]int32{ 293 "AUTOSCALING_ALGORITHM_UNKNOWN": 0, 294 "AUTOSCALING_ALGORITHM_NONE": 1, 295 "AUTOSCALING_ALGORITHM_BASIC": 2, 296 } 297) 298 299func (x AutoscalingAlgorithm) Enum() *AutoscalingAlgorithm { 300 p := new(AutoscalingAlgorithm) 301 *p = x 302 return p 303} 304 305func (x AutoscalingAlgorithm) String() string { 306 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 307} 308 309func (AutoscalingAlgorithm) Descriptor() protoreflect.EnumDescriptor { 310 return file_google_dataflow_v1beta3_environment_proto_enumTypes[4].Descriptor() 311} 312 313func (AutoscalingAlgorithm) Type() protoreflect.EnumType { 314 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[4] 315} 316 317func (x AutoscalingAlgorithm) Number() protoreflect.EnumNumber { 318 return protoreflect.EnumNumber(x) 319} 320 321// Deprecated: Use AutoscalingAlgorithm.Descriptor instead. 322func (AutoscalingAlgorithm) EnumDescriptor() ([]byte, []int) { 323 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{4} 324} 325 326// Specifies how IP addresses should be allocated to the worker machines. 327type WorkerIPAddressConfiguration int32 328 329const ( 330 // The configuration is unknown, or unspecified. 331 WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED WorkerIPAddressConfiguration = 0 332 // Workers should have public IP addresses. 333 WorkerIPAddressConfiguration_WORKER_IP_PUBLIC WorkerIPAddressConfiguration = 1 334 // Workers should have private IP addresses. 335 WorkerIPAddressConfiguration_WORKER_IP_PRIVATE WorkerIPAddressConfiguration = 2 336) 337 338// Enum value maps for WorkerIPAddressConfiguration. 339var ( 340 WorkerIPAddressConfiguration_name = map[int32]string{ 341 0: "WORKER_IP_UNSPECIFIED", 342 1: "WORKER_IP_PUBLIC", 343 2: "WORKER_IP_PRIVATE", 344 } 345 WorkerIPAddressConfiguration_value = map[string]int32{ 346 "WORKER_IP_UNSPECIFIED": 0, 347 "WORKER_IP_PUBLIC": 1, 348 "WORKER_IP_PRIVATE": 2, 349 } 350) 351 352func (x WorkerIPAddressConfiguration) Enum() *WorkerIPAddressConfiguration { 353 p := new(WorkerIPAddressConfiguration) 354 *p = x 355 return p 356} 357 358func (x WorkerIPAddressConfiguration) String() string { 359 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 360} 361 362func (WorkerIPAddressConfiguration) Descriptor() protoreflect.EnumDescriptor { 363 return file_google_dataflow_v1beta3_environment_proto_enumTypes[5].Descriptor() 364} 365 366func (WorkerIPAddressConfiguration) Type() protoreflect.EnumType { 367 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[5] 368} 369 370func (x WorkerIPAddressConfiguration) Number() protoreflect.EnumNumber { 371 return protoreflect.EnumNumber(x) 372} 373 374// Deprecated: Use WorkerIPAddressConfiguration.Descriptor instead. 375func (WorkerIPAddressConfiguration) EnumDescriptor() ([]byte, []int) { 376 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{5} 377} 378 379// Specifies the shuffle mode used by a 380// [google.dataflow.v1beta3.Job], which determines the approach data is shuffled 381// during processing. More details in: 382// https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-shuffle 383type ShuffleMode int32 384 385const ( 386 // Shuffle mode information is not available. 387 ShuffleMode_SHUFFLE_MODE_UNSPECIFIED ShuffleMode = 0 388 // Shuffle is done on the worker VMs. 389 ShuffleMode_VM_BASED ShuffleMode = 1 390 // Shuffle is done on the service side. 391 ShuffleMode_SERVICE_BASED ShuffleMode = 2 392) 393 394// Enum value maps for ShuffleMode. 395var ( 396 ShuffleMode_name = map[int32]string{ 397 0: "SHUFFLE_MODE_UNSPECIFIED", 398 1: "VM_BASED", 399 2: "SERVICE_BASED", 400 } 401 ShuffleMode_value = map[string]int32{ 402 "SHUFFLE_MODE_UNSPECIFIED": 0, 403 "VM_BASED": 1, 404 "SERVICE_BASED": 2, 405 } 406) 407 408func (x ShuffleMode) Enum() *ShuffleMode { 409 p := new(ShuffleMode) 410 *p = x 411 return p 412} 413 414func (x ShuffleMode) String() string { 415 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 416} 417 418func (ShuffleMode) Descriptor() protoreflect.EnumDescriptor { 419 return file_google_dataflow_v1beta3_environment_proto_enumTypes[6].Descriptor() 420} 421 422func (ShuffleMode) Type() protoreflect.EnumType { 423 return &file_google_dataflow_v1beta3_environment_proto_enumTypes[6] 424} 425 426func (x ShuffleMode) Number() protoreflect.EnumNumber { 427 return protoreflect.EnumNumber(x) 428} 429 430// Deprecated: Use ShuffleMode.Descriptor instead. 431func (ShuffleMode) EnumDescriptor() ([]byte, []int) { 432 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{6} 433} 434 435// Describes the environment in which a Dataflow Job runs. 436type Environment struct { 437 state protoimpl.MessageState 438 sizeCache protoimpl.SizeCache 439 unknownFields protoimpl.UnknownFields 440 441 // The prefix of the resources the system should use for temporary 442 // storage. The system will append the suffix "/temp-{JOBNAME} to 443 // this resource prefix, where {JOBNAME} is the value of the 444 // job_name field. The resulting bucket and object prefix is used 445 // as the prefix of the resources used to store temporary data 446 // needed during the job execution. NOTE: This will override the 447 // value in taskrunner_settings. 448 // The supported resource type is: 449 // 450 // Google Cloud Storage: 451 // 452 // storage.googleapis.com/{bucket}/{object} 453 // bucket.storage.googleapis.com/{object} 454 TempStoragePrefix string `protobuf:"bytes,1,opt,name=temp_storage_prefix,json=tempStoragePrefix,proto3" json:"temp_storage_prefix,omitempty"` 455 // The type of cluster manager API to use. If unknown or 456 // unspecified, the service will attempt to choose a reasonable 457 // default. This should be in the form of the API service name, 458 // e.g. "compute.googleapis.com". 459 ClusterManagerApiService string `protobuf:"bytes,2,opt,name=cluster_manager_api_service,json=clusterManagerApiService,proto3" json:"cluster_manager_api_service,omitempty"` 460 // The list of experiments to enable. This field should be used for SDK 461 // related experiments and not for service related experiments. The proper 462 // field for service related experiments is service_options. 463 Experiments []string `protobuf:"bytes,3,rep,name=experiments,proto3" json:"experiments,omitempty"` 464 // The list of service options to enable. This field should be used for 465 // service related experiments only. These experiments, when graduating to GA, 466 // should be replaced by dedicated fields or become default (i.e. always on). 467 ServiceOptions []string `protobuf:"bytes,16,rep,name=service_options,json=serviceOptions,proto3" json:"service_options,omitempty"` 468 // If set, contains the Cloud KMS key identifier used to encrypt data 469 // at rest, AKA a Customer Managed Encryption Key (CMEK). 470 // 471 // Format: 472 // projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY 473 ServiceKmsKeyName string `protobuf:"bytes,12,opt,name=service_kms_key_name,json=serviceKmsKeyName,proto3" json:"service_kms_key_name,omitempty"` 474 // The worker pools. At least one "harness" worker pool must be 475 // specified in order for the job to have workers. 476 WorkerPools []*WorkerPool `protobuf:"bytes,4,rep,name=worker_pools,json=workerPools,proto3" json:"worker_pools,omitempty"` 477 // A description of the process that generated the request. 478 UserAgent *structpb.Struct `protobuf:"bytes,5,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` 479 // A structure describing which components and their versions of the service 480 // are required in order to run the job. 481 Version *structpb.Struct `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` 482 // The dataset for the current project where various workflow 483 // related tables are stored. 484 // 485 // The supported resource type is: 486 // 487 // Google BigQuery: 488 // bigquery.googleapis.com/{dataset} 489 Dataset string `protobuf:"bytes,7,opt,name=dataset,proto3" json:"dataset,omitempty"` 490 // The Cloud Dataflow SDK pipeline options specified by the user. These 491 // options are passed through the service and are used to recreate the 492 // SDK pipeline options on the worker in a language agnostic and platform 493 // independent way. 494 SdkPipelineOptions *structpb.Struct `protobuf:"bytes,8,opt,name=sdk_pipeline_options,json=sdkPipelineOptions,proto3" json:"sdk_pipeline_options,omitempty"` 495 // Experimental settings. 496 InternalExperiments *anypb.Any `protobuf:"bytes,9,opt,name=internal_experiments,json=internalExperiments,proto3" json:"internal_experiments,omitempty"` 497 // Identity to run virtual machines as. Defaults to the default account. 498 ServiceAccountEmail string `protobuf:"bytes,10,opt,name=service_account_email,json=serviceAccountEmail,proto3" json:"service_account_email,omitempty"` 499 // Which Flexible Resource Scheduling mode to run in. 500 FlexResourceSchedulingGoal FlexResourceSchedulingGoal `protobuf:"varint,11,opt,name=flex_resource_scheduling_goal,json=flexResourceSchedulingGoal,proto3,enum=google.dataflow.v1beta3.FlexResourceSchedulingGoal" json:"flex_resource_scheduling_goal,omitempty"` 501 // The Compute Engine region 502 // (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in 503 // which worker processing should occur, e.g. "us-west1". Mutually exclusive 504 // with worker_zone. If neither worker_region nor worker_zone is specified, 505 // default to the control plane's region. 506 WorkerRegion string `protobuf:"bytes,13,opt,name=worker_region,json=workerRegion,proto3" json:"worker_region,omitempty"` 507 // The Compute Engine zone 508 // (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in 509 // which worker processing should occur, e.g. "us-west1-a". Mutually exclusive 510 // with worker_region. If neither worker_region nor worker_zone is specified, 511 // a zone in the control plane's region is chosen based on available capacity. 512 WorkerZone string `protobuf:"bytes,14,opt,name=worker_zone,json=workerZone,proto3" json:"worker_zone,omitempty"` 513 // Output only. The shuffle mode used for the job. 514 ShuffleMode ShuffleMode `protobuf:"varint,15,opt,name=shuffle_mode,json=shuffleMode,proto3,enum=google.dataflow.v1beta3.ShuffleMode" json:"shuffle_mode,omitempty"` 515 // Any debugging options to be supplied to the job. 516 DebugOptions *DebugOptions `protobuf:"bytes,17,opt,name=debug_options,json=debugOptions,proto3" json:"debug_options,omitempty"` 517} 518 519func (x *Environment) Reset() { 520 *x = Environment{} 521 if protoimpl.UnsafeEnabled { 522 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[0] 523 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 524 ms.StoreMessageInfo(mi) 525 } 526} 527 528func (x *Environment) String() string { 529 return protoimpl.X.MessageStringOf(x) 530} 531 532func (*Environment) ProtoMessage() {} 533 534func (x *Environment) ProtoReflect() protoreflect.Message { 535 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[0] 536 if protoimpl.UnsafeEnabled && x != nil { 537 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 538 if ms.LoadMessageInfo() == nil { 539 ms.StoreMessageInfo(mi) 540 } 541 return ms 542 } 543 return mi.MessageOf(x) 544} 545 546// Deprecated: Use Environment.ProtoReflect.Descriptor instead. 547func (*Environment) Descriptor() ([]byte, []int) { 548 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{0} 549} 550 551func (x *Environment) GetTempStoragePrefix() string { 552 if x != nil { 553 return x.TempStoragePrefix 554 } 555 return "" 556} 557 558func (x *Environment) GetClusterManagerApiService() string { 559 if x != nil { 560 return x.ClusterManagerApiService 561 } 562 return "" 563} 564 565func (x *Environment) GetExperiments() []string { 566 if x != nil { 567 return x.Experiments 568 } 569 return nil 570} 571 572func (x *Environment) GetServiceOptions() []string { 573 if x != nil { 574 return x.ServiceOptions 575 } 576 return nil 577} 578 579func (x *Environment) GetServiceKmsKeyName() string { 580 if x != nil { 581 return x.ServiceKmsKeyName 582 } 583 return "" 584} 585 586func (x *Environment) GetWorkerPools() []*WorkerPool { 587 if x != nil { 588 return x.WorkerPools 589 } 590 return nil 591} 592 593func (x *Environment) GetUserAgent() *structpb.Struct { 594 if x != nil { 595 return x.UserAgent 596 } 597 return nil 598} 599 600func (x *Environment) GetVersion() *structpb.Struct { 601 if x != nil { 602 return x.Version 603 } 604 return nil 605} 606 607func (x *Environment) GetDataset() string { 608 if x != nil { 609 return x.Dataset 610 } 611 return "" 612} 613 614func (x *Environment) GetSdkPipelineOptions() *structpb.Struct { 615 if x != nil { 616 return x.SdkPipelineOptions 617 } 618 return nil 619} 620 621func (x *Environment) GetInternalExperiments() *anypb.Any { 622 if x != nil { 623 return x.InternalExperiments 624 } 625 return nil 626} 627 628func (x *Environment) GetServiceAccountEmail() string { 629 if x != nil { 630 return x.ServiceAccountEmail 631 } 632 return "" 633} 634 635func (x *Environment) GetFlexResourceSchedulingGoal() FlexResourceSchedulingGoal { 636 if x != nil { 637 return x.FlexResourceSchedulingGoal 638 } 639 return FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED 640} 641 642func (x *Environment) GetWorkerRegion() string { 643 if x != nil { 644 return x.WorkerRegion 645 } 646 return "" 647} 648 649func (x *Environment) GetWorkerZone() string { 650 if x != nil { 651 return x.WorkerZone 652 } 653 return "" 654} 655 656func (x *Environment) GetShuffleMode() ShuffleMode { 657 if x != nil { 658 return x.ShuffleMode 659 } 660 return ShuffleMode_SHUFFLE_MODE_UNSPECIFIED 661} 662 663func (x *Environment) GetDebugOptions() *DebugOptions { 664 if x != nil { 665 return x.DebugOptions 666 } 667 return nil 668} 669 670// The packages that must be installed in order for a worker to run the 671// steps of the Cloud Dataflow job that will be assigned to its worker 672// pool. 673// 674// This is the mechanism by which the Cloud Dataflow SDK causes code to 675// be loaded onto the workers. For example, the Cloud Dataflow Java SDK 676// might use this to install jars containing the user's code and all of the 677// various dependencies (libraries, data files, etc.) required in order 678// for that code to run. 679type Package struct { 680 state protoimpl.MessageState 681 sizeCache protoimpl.SizeCache 682 unknownFields protoimpl.UnknownFields 683 684 // The name of the package. 685 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 686 // The resource to read the package from. The supported resource type is: 687 // 688 // Google Cloud Storage: 689 // 690 // storage.googleapis.com/{bucket} 691 // bucket.storage.googleapis.com/ 692 Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` 693} 694 695func (x *Package) Reset() { 696 *x = Package{} 697 if protoimpl.UnsafeEnabled { 698 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[1] 699 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 700 ms.StoreMessageInfo(mi) 701 } 702} 703 704func (x *Package) String() string { 705 return protoimpl.X.MessageStringOf(x) 706} 707 708func (*Package) ProtoMessage() {} 709 710func (x *Package) ProtoReflect() protoreflect.Message { 711 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[1] 712 if protoimpl.UnsafeEnabled && x != nil { 713 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 714 if ms.LoadMessageInfo() == nil { 715 ms.StoreMessageInfo(mi) 716 } 717 return ms 718 } 719 return mi.MessageOf(x) 720} 721 722// Deprecated: Use Package.ProtoReflect.Descriptor instead. 723func (*Package) Descriptor() ([]byte, []int) { 724 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{1} 725} 726 727func (x *Package) GetName() string { 728 if x != nil { 729 return x.Name 730 } 731 return "" 732} 733 734func (x *Package) GetLocation() string { 735 if x != nil { 736 return x.Location 737 } 738 return "" 739} 740 741// Describes the data disk used by a workflow job. 742type Disk struct { 743 state protoimpl.MessageState 744 sizeCache protoimpl.SizeCache 745 unknownFields protoimpl.UnknownFields 746 747 // Size of disk in GB. If zero or unspecified, the service will 748 // attempt to choose a reasonable default. 749 SizeGb int32 `protobuf:"varint,1,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` 750 // Disk storage type, as defined by Google Compute Engine. This 751 // must be a disk type appropriate to the project and zone in which 752 // the workers will run. If unknown or unspecified, the service 753 // will attempt to choose a reasonable default. 754 // 755 // For example, the standard persistent disk type is a resource name 756 // typically ending in "pd-standard". If SSD persistent disks are 757 // available, the resource name typically ends with "pd-ssd". The 758 // actual valid values are defined the Google Compute Engine API, 759 // not by the Cloud Dataflow API; consult the Google Compute Engine 760 // documentation for more information about determining the set of 761 // available disk types for a particular project and zone. 762 // 763 // Google Compute Engine Disk types are local to a particular 764 // project in a particular zone, and so the resource name will 765 // typically look something like this: 766 // 767 // compute.googleapis.com/projects/project-id/zones/zone/diskTypes/pd-standard 768 DiskType string `protobuf:"bytes,2,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` 769 // Directory in a VM where disk is mounted. 770 MountPoint string `protobuf:"bytes,3,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"` 771} 772 773func (x *Disk) Reset() { 774 *x = Disk{} 775 if protoimpl.UnsafeEnabled { 776 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[2] 777 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 778 ms.StoreMessageInfo(mi) 779 } 780} 781 782func (x *Disk) String() string { 783 return protoimpl.X.MessageStringOf(x) 784} 785 786func (*Disk) ProtoMessage() {} 787 788func (x *Disk) ProtoReflect() protoreflect.Message { 789 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[2] 790 if protoimpl.UnsafeEnabled && x != nil { 791 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 792 if ms.LoadMessageInfo() == nil { 793 ms.StoreMessageInfo(mi) 794 } 795 return ms 796 } 797 return mi.MessageOf(x) 798} 799 800// Deprecated: Use Disk.ProtoReflect.Descriptor instead. 801func (*Disk) Descriptor() ([]byte, []int) { 802 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{2} 803} 804 805func (x *Disk) GetSizeGb() int32 { 806 if x != nil { 807 return x.SizeGb 808 } 809 return 0 810} 811 812func (x *Disk) GetDiskType() string { 813 if x != nil { 814 return x.DiskType 815 } 816 return "" 817} 818 819func (x *Disk) GetMountPoint() string { 820 if x != nil { 821 return x.MountPoint 822 } 823 return "" 824} 825 826// Provides data to pass through to the worker harness. 827type WorkerSettings struct { 828 state protoimpl.MessageState 829 sizeCache protoimpl.SizeCache 830 unknownFields protoimpl.UnknownFields 831 832 // The base URL for accessing Google Cloud APIs. 833 // 834 // When workers access Google Cloud APIs, they logically do so via 835 // relative URLs. If this field is specified, it supplies the base 836 // URL to use for resolving these relative URLs. The normative 837 // algorithm used is defined by RFC 1808, "Relative Uniform Resource 838 // Locators". 839 // 840 // If not specified, the default value is "http://www.googleapis.com/" 841 BaseUrl string `protobuf:"bytes,1,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"` 842 // Whether to send work progress updates to the service. 843 ReportingEnabled bool `protobuf:"varint,2,opt,name=reporting_enabled,json=reportingEnabled,proto3" json:"reporting_enabled,omitempty"` 844 // The Cloud Dataflow service path relative to the root URL, for example, 845 // "dataflow/v1b3/projects". 846 ServicePath string `protobuf:"bytes,3,opt,name=service_path,json=servicePath,proto3" json:"service_path,omitempty"` 847 // The Shuffle service path relative to the root URL, for example, 848 // "shuffle/v1beta1". 849 ShuffleServicePath string `protobuf:"bytes,4,opt,name=shuffle_service_path,json=shuffleServicePath,proto3" json:"shuffle_service_path,omitempty"` 850 // The ID of the worker running this pipeline. 851 WorkerId string `protobuf:"bytes,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` 852 // The prefix of the resources the system should use for temporary 853 // storage. 854 // 855 // The supported resource type is: 856 // 857 // Google Cloud Storage: 858 // 859 // storage.googleapis.com/{bucket}/{object} 860 // bucket.storage.googleapis.com/{object} 861 TempStoragePrefix string `protobuf:"bytes,6,opt,name=temp_storage_prefix,json=tempStoragePrefix,proto3" json:"temp_storage_prefix,omitempty"` 862} 863 864func (x *WorkerSettings) Reset() { 865 *x = WorkerSettings{} 866 if protoimpl.UnsafeEnabled { 867 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[3] 868 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 869 ms.StoreMessageInfo(mi) 870 } 871} 872 873func (x *WorkerSettings) String() string { 874 return protoimpl.X.MessageStringOf(x) 875} 876 877func (*WorkerSettings) ProtoMessage() {} 878 879func (x *WorkerSettings) ProtoReflect() protoreflect.Message { 880 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[3] 881 if protoimpl.UnsafeEnabled && x != nil { 882 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 883 if ms.LoadMessageInfo() == nil { 884 ms.StoreMessageInfo(mi) 885 } 886 return ms 887 } 888 return mi.MessageOf(x) 889} 890 891// Deprecated: Use WorkerSettings.ProtoReflect.Descriptor instead. 892func (*WorkerSettings) Descriptor() ([]byte, []int) { 893 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{3} 894} 895 896func (x *WorkerSettings) GetBaseUrl() string { 897 if x != nil { 898 return x.BaseUrl 899 } 900 return "" 901} 902 903func (x *WorkerSettings) GetReportingEnabled() bool { 904 if x != nil { 905 return x.ReportingEnabled 906 } 907 return false 908} 909 910func (x *WorkerSettings) GetServicePath() string { 911 if x != nil { 912 return x.ServicePath 913 } 914 return "" 915} 916 917func (x *WorkerSettings) GetShuffleServicePath() string { 918 if x != nil { 919 return x.ShuffleServicePath 920 } 921 return "" 922} 923 924func (x *WorkerSettings) GetWorkerId() string { 925 if x != nil { 926 return x.WorkerId 927 } 928 return "" 929} 930 931func (x *WorkerSettings) GetTempStoragePrefix() string { 932 if x != nil { 933 return x.TempStoragePrefix 934 } 935 return "" 936} 937 938// Taskrunner configuration settings. 939type TaskRunnerSettings struct { 940 state protoimpl.MessageState 941 sizeCache protoimpl.SizeCache 942 unknownFields protoimpl.UnknownFields 943 944 // The UNIX user ID on the worker VM to use for tasks launched by 945 // taskrunner; e.g. "root". 946 TaskUser string `protobuf:"bytes,1,opt,name=task_user,json=taskUser,proto3" json:"task_user,omitempty"` 947 // The UNIX group ID on the worker VM to use for tasks launched by 948 // taskrunner; e.g. "wheel". 949 TaskGroup string `protobuf:"bytes,2,opt,name=task_group,json=taskGroup,proto3" json:"task_group,omitempty"` 950 // The OAuth2 scopes to be requested by the taskrunner in order to 951 // access the Cloud Dataflow API. 952 OauthScopes []string `protobuf:"bytes,3,rep,name=oauth_scopes,json=oauthScopes,proto3" json:"oauth_scopes,omitempty"` 953 // The base URL for the taskrunner to use when accessing Google Cloud APIs. 954 // 955 // When workers access Google Cloud APIs, they logically do so via 956 // relative URLs. If this field is specified, it supplies the base 957 // URL to use for resolving these relative URLs. The normative 958 // algorithm used is defined by RFC 1808, "Relative Uniform Resource 959 // Locators". 960 // 961 // If not specified, the default value is "http://www.googleapis.com/" 962 BaseUrl string `protobuf:"bytes,4,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"` 963 // The API version of endpoint, e.g. "v1b3" 964 DataflowApiVersion string `protobuf:"bytes,5,opt,name=dataflow_api_version,json=dataflowApiVersion,proto3" json:"dataflow_api_version,omitempty"` 965 // The settings to pass to the parallel worker harness. 966 ParallelWorkerSettings *WorkerSettings `protobuf:"bytes,6,opt,name=parallel_worker_settings,json=parallelWorkerSettings,proto3" json:"parallel_worker_settings,omitempty"` 967 // The location on the worker for task-specific subdirectories. 968 BaseTaskDir string `protobuf:"bytes,7,opt,name=base_task_dir,json=baseTaskDir,proto3" json:"base_task_dir,omitempty"` 969 // Whether to continue taskrunner if an exception is hit. 970 ContinueOnException bool `protobuf:"varint,8,opt,name=continue_on_exception,json=continueOnException,proto3" json:"continue_on_exception,omitempty"` 971 // Whether to send taskrunner log info to Google Compute Engine VM serial 972 // console. 973 LogToSerialconsole bool `protobuf:"varint,9,opt,name=log_to_serialconsole,json=logToSerialconsole,proto3" json:"log_to_serialconsole,omitempty"` 974 // Whether to also send taskrunner log info to stderr. 975 Alsologtostderr bool `protobuf:"varint,10,opt,name=alsologtostderr,proto3" json:"alsologtostderr,omitempty"` 976 // Indicates where to put logs. If this is not specified, the logs 977 // will not be uploaded. 978 // 979 // The supported resource type is: 980 // 981 // Google Cloud Storage: 982 // storage.googleapis.com/{bucket}/{object} 983 // bucket.storage.googleapis.com/{object} 984 LogUploadLocation string `protobuf:"bytes,11,opt,name=log_upload_location,json=logUploadLocation,proto3" json:"log_upload_location,omitempty"` 985 // The directory on the VM to store logs. 986 LogDir string `protobuf:"bytes,12,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"` 987 // The prefix of the resources the taskrunner should use for 988 // temporary storage. 989 // 990 // The supported resource type is: 991 // 992 // Google Cloud Storage: 993 // storage.googleapis.com/{bucket}/{object} 994 // bucket.storage.googleapis.com/{object} 995 TempStoragePrefix string `protobuf:"bytes,13,opt,name=temp_storage_prefix,json=tempStoragePrefix,proto3" json:"temp_storage_prefix,omitempty"` 996 // The command to launch the worker harness. 997 HarnessCommand string `protobuf:"bytes,14,opt,name=harness_command,json=harnessCommand,proto3" json:"harness_command,omitempty"` 998 // The file to store the workflow in. 999 WorkflowFileName string `protobuf:"bytes,15,opt,name=workflow_file_name,json=workflowFileName,proto3" json:"workflow_file_name,omitempty"` 1000 // The file to store preprocessing commands in. 1001 CommandlinesFileName string `protobuf:"bytes,16,opt,name=commandlines_file_name,json=commandlinesFileName,proto3" json:"commandlines_file_name,omitempty"` 1002 // The ID string of the VM. 1003 VmId string `protobuf:"bytes,17,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` 1004 // The suggested backend language. 1005 LanguageHint string `protobuf:"bytes,18,opt,name=language_hint,json=languageHint,proto3" json:"language_hint,omitempty"` 1006 // The streaming worker main class name. 1007 StreamingWorkerMainClass string `protobuf:"bytes,19,opt,name=streaming_worker_main_class,json=streamingWorkerMainClass,proto3" json:"streaming_worker_main_class,omitempty"` 1008} 1009 1010func (x *TaskRunnerSettings) Reset() { 1011 *x = TaskRunnerSettings{} 1012 if protoimpl.UnsafeEnabled { 1013 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[4] 1014 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1015 ms.StoreMessageInfo(mi) 1016 } 1017} 1018 1019func (x *TaskRunnerSettings) String() string { 1020 return protoimpl.X.MessageStringOf(x) 1021} 1022 1023func (*TaskRunnerSettings) ProtoMessage() {} 1024 1025func (x *TaskRunnerSettings) ProtoReflect() protoreflect.Message { 1026 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[4] 1027 if protoimpl.UnsafeEnabled && x != nil { 1028 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1029 if ms.LoadMessageInfo() == nil { 1030 ms.StoreMessageInfo(mi) 1031 } 1032 return ms 1033 } 1034 return mi.MessageOf(x) 1035} 1036 1037// Deprecated: Use TaskRunnerSettings.ProtoReflect.Descriptor instead. 1038func (*TaskRunnerSettings) Descriptor() ([]byte, []int) { 1039 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{4} 1040} 1041 1042func (x *TaskRunnerSettings) GetTaskUser() string { 1043 if x != nil { 1044 return x.TaskUser 1045 } 1046 return "" 1047} 1048 1049func (x *TaskRunnerSettings) GetTaskGroup() string { 1050 if x != nil { 1051 return x.TaskGroup 1052 } 1053 return "" 1054} 1055 1056func (x *TaskRunnerSettings) GetOauthScopes() []string { 1057 if x != nil { 1058 return x.OauthScopes 1059 } 1060 return nil 1061} 1062 1063func (x *TaskRunnerSettings) GetBaseUrl() string { 1064 if x != nil { 1065 return x.BaseUrl 1066 } 1067 return "" 1068} 1069 1070func (x *TaskRunnerSettings) GetDataflowApiVersion() string { 1071 if x != nil { 1072 return x.DataflowApiVersion 1073 } 1074 return "" 1075} 1076 1077func (x *TaskRunnerSettings) GetParallelWorkerSettings() *WorkerSettings { 1078 if x != nil { 1079 return x.ParallelWorkerSettings 1080 } 1081 return nil 1082} 1083 1084func (x *TaskRunnerSettings) GetBaseTaskDir() string { 1085 if x != nil { 1086 return x.BaseTaskDir 1087 } 1088 return "" 1089} 1090 1091func (x *TaskRunnerSettings) GetContinueOnException() bool { 1092 if x != nil { 1093 return x.ContinueOnException 1094 } 1095 return false 1096} 1097 1098func (x *TaskRunnerSettings) GetLogToSerialconsole() bool { 1099 if x != nil { 1100 return x.LogToSerialconsole 1101 } 1102 return false 1103} 1104 1105func (x *TaskRunnerSettings) GetAlsologtostderr() bool { 1106 if x != nil { 1107 return x.Alsologtostderr 1108 } 1109 return false 1110} 1111 1112func (x *TaskRunnerSettings) GetLogUploadLocation() string { 1113 if x != nil { 1114 return x.LogUploadLocation 1115 } 1116 return "" 1117} 1118 1119func (x *TaskRunnerSettings) GetLogDir() string { 1120 if x != nil { 1121 return x.LogDir 1122 } 1123 return "" 1124} 1125 1126func (x *TaskRunnerSettings) GetTempStoragePrefix() string { 1127 if x != nil { 1128 return x.TempStoragePrefix 1129 } 1130 return "" 1131} 1132 1133func (x *TaskRunnerSettings) GetHarnessCommand() string { 1134 if x != nil { 1135 return x.HarnessCommand 1136 } 1137 return "" 1138} 1139 1140func (x *TaskRunnerSettings) GetWorkflowFileName() string { 1141 if x != nil { 1142 return x.WorkflowFileName 1143 } 1144 return "" 1145} 1146 1147func (x *TaskRunnerSettings) GetCommandlinesFileName() string { 1148 if x != nil { 1149 return x.CommandlinesFileName 1150 } 1151 return "" 1152} 1153 1154func (x *TaskRunnerSettings) GetVmId() string { 1155 if x != nil { 1156 return x.VmId 1157 } 1158 return "" 1159} 1160 1161func (x *TaskRunnerSettings) GetLanguageHint() string { 1162 if x != nil { 1163 return x.LanguageHint 1164 } 1165 return "" 1166} 1167 1168func (x *TaskRunnerSettings) GetStreamingWorkerMainClass() string { 1169 if x != nil { 1170 return x.StreamingWorkerMainClass 1171 } 1172 return "" 1173} 1174 1175// Settings for WorkerPool autoscaling. 1176type AutoscalingSettings struct { 1177 state protoimpl.MessageState 1178 sizeCache protoimpl.SizeCache 1179 unknownFields protoimpl.UnknownFields 1180 1181 // The algorithm to use for autoscaling. 1182 Algorithm AutoscalingAlgorithm `protobuf:"varint,1,opt,name=algorithm,proto3,enum=google.dataflow.v1beta3.AutoscalingAlgorithm" json:"algorithm,omitempty"` 1183 // The maximum number of workers to cap scaling at. 1184 MaxNumWorkers int32 `protobuf:"varint,2,opt,name=max_num_workers,json=maxNumWorkers,proto3" json:"max_num_workers,omitempty"` 1185} 1186 1187func (x *AutoscalingSettings) Reset() { 1188 *x = AutoscalingSettings{} 1189 if protoimpl.UnsafeEnabled { 1190 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[5] 1191 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1192 ms.StoreMessageInfo(mi) 1193 } 1194} 1195 1196func (x *AutoscalingSettings) String() string { 1197 return protoimpl.X.MessageStringOf(x) 1198} 1199 1200func (*AutoscalingSettings) ProtoMessage() {} 1201 1202func (x *AutoscalingSettings) ProtoReflect() protoreflect.Message { 1203 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[5] 1204 if protoimpl.UnsafeEnabled && x != nil { 1205 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1206 if ms.LoadMessageInfo() == nil { 1207 ms.StoreMessageInfo(mi) 1208 } 1209 return ms 1210 } 1211 return mi.MessageOf(x) 1212} 1213 1214// Deprecated: Use AutoscalingSettings.ProtoReflect.Descriptor instead. 1215func (*AutoscalingSettings) Descriptor() ([]byte, []int) { 1216 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{5} 1217} 1218 1219func (x *AutoscalingSettings) GetAlgorithm() AutoscalingAlgorithm { 1220 if x != nil { 1221 return x.Algorithm 1222 } 1223 return AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN 1224} 1225 1226func (x *AutoscalingSettings) GetMaxNumWorkers() int32 { 1227 if x != nil { 1228 return x.MaxNumWorkers 1229 } 1230 return 0 1231} 1232 1233// Defines a SDK harness container for executing Dataflow pipelines. 1234type SdkHarnessContainerImage struct { 1235 state protoimpl.MessageState 1236 sizeCache protoimpl.SizeCache 1237 unknownFields protoimpl.UnknownFields 1238 1239 // A docker container image that resides in Google Container Registry. 1240 ContainerImage string `protobuf:"bytes,1,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"` 1241 // If true, recommends the Dataflow service to use only one core per SDK 1242 // container instance with this image. If false (or unset) recommends using 1243 // more than one core per SDK container instance with this image for 1244 // efficiency. Note that Dataflow service may choose to override this property 1245 // if needed. 1246 UseSingleCorePerContainer bool `protobuf:"varint,2,opt,name=use_single_core_per_container,json=useSingleCorePerContainer,proto3" json:"use_single_core_per_container,omitempty"` 1247 // Environment ID for the Beam runner API proto Environment that corresponds 1248 // to the current SDK Harness. 1249 EnvironmentId string `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"` 1250} 1251 1252func (x *SdkHarnessContainerImage) Reset() { 1253 *x = SdkHarnessContainerImage{} 1254 if protoimpl.UnsafeEnabled { 1255 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[6] 1256 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1257 ms.StoreMessageInfo(mi) 1258 } 1259} 1260 1261func (x *SdkHarnessContainerImage) String() string { 1262 return protoimpl.X.MessageStringOf(x) 1263} 1264 1265func (*SdkHarnessContainerImage) ProtoMessage() {} 1266 1267func (x *SdkHarnessContainerImage) ProtoReflect() protoreflect.Message { 1268 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[6] 1269 if protoimpl.UnsafeEnabled && x != nil { 1270 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1271 if ms.LoadMessageInfo() == nil { 1272 ms.StoreMessageInfo(mi) 1273 } 1274 return ms 1275 } 1276 return mi.MessageOf(x) 1277} 1278 1279// Deprecated: Use SdkHarnessContainerImage.ProtoReflect.Descriptor instead. 1280func (*SdkHarnessContainerImage) Descriptor() ([]byte, []int) { 1281 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{6} 1282} 1283 1284func (x *SdkHarnessContainerImage) GetContainerImage() string { 1285 if x != nil { 1286 return x.ContainerImage 1287 } 1288 return "" 1289} 1290 1291func (x *SdkHarnessContainerImage) GetUseSingleCorePerContainer() bool { 1292 if x != nil { 1293 return x.UseSingleCorePerContainer 1294 } 1295 return false 1296} 1297 1298func (x *SdkHarnessContainerImage) GetEnvironmentId() string { 1299 if x != nil { 1300 return x.EnvironmentId 1301 } 1302 return "" 1303} 1304 1305// Describes one particular pool of Cloud Dataflow workers to be 1306// instantiated by the Cloud Dataflow service in order to perform the 1307// computations required by a job. Note that a workflow job may use 1308// multiple pools, in order to match the various computational 1309// requirements of the various stages of the job. 1310type WorkerPool struct { 1311 state protoimpl.MessageState 1312 sizeCache protoimpl.SizeCache 1313 unknownFields protoimpl.UnknownFields 1314 1315 // The kind of the worker pool; currently only `harness` and `shuffle` 1316 // are supported. 1317 Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` 1318 // Number of Google Compute Engine workers in this pool needed to 1319 // execute the job. If zero or unspecified, the service will 1320 // attempt to choose a reasonable default. 1321 NumWorkers int32 `protobuf:"varint,2,opt,name=num_workers,json=numWorkers,proto3" json:"num_workers,omitempty"` 1322 // Packages to be installed on workers. 1323 Packages []*Package `protobuf:"bytes,3,rep,name=packages,proto3" json:"packages,omitempty"` 1324 // The default package set to install. This allows the service to 1325 // select a default set of packages which are useful to worker 1326 // harnesses written in a particular language. 1327 DefaultPackageSet DefaultPackageSet `protobuf:"varint,4,opt,name=default_package_set,json=defaultPackageSet,proto3,enum=google.dataflow.v1beta3.DefaultPackageSet" json:"default_package_set,omitempty"` 1328 // Machine type (e.g. "n1-standard-1"). If empty or unspecified, the 1329 // service will attempt to choose a reasonable default. 1330 MachineType string `protobuf:"bytes,5,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` 1331 // Sets the policy for determining when to turndown worker pool. 1332 // Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and 1333 // `TEARDOWN_NEVER`. 1334 // `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether 1335 // the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down 1336 // if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn 1337 // down. 1338 // 1339 // If the workers are not torn down by the service, they will 1340 // continue to run and use Google Compute Engine VM resources in the 1341 // user's project until they are explicitly terminated by the user. 1342 // Because of this, Google recommends using the `TEARDOWN_ALWAYS` 1343 // policy except for small, manually supervised test jobs. 1344 // 1345 // If unknown or unspecified, the service will attempt to choose a reasonable 1346 // default. 1347 TeardownPolicy TeardownPolicy `protobuf:"varint,6,opt,name=teardown_policy,json=teardownPolicy,proto3,enum=google.dataflow.v1beta3.TeardownPolicy" json:"teardown_policy,omitempty"` 1348 // Size of root disk for VMs, in GB. If zero or unspecified, the service will 1349 // attempt to choose a reasonable default. 1350 DiskSizeGb int32 `protobuf:"varint,7,opt,name=disk_size_gb,json=diskSizeGb,proto3" json:"disk_size_gb,omitempty"` 1351 // Type of root disk for VMs. If empty or unspecified, the service will 1352 // attempt to choose a reasonable default. 1353 DiskType string `protobuf:"bytes,16,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` 1354 // Fully qualified source image for disks. 1355 DiskSourceImage string `protobuf:"bytes,8,opt,name=disk_source_image,json=diskSourceImage,proto3" json:"disk_source_image,omitempty"` 1356 // Zone to run the worker pools in. If empty or unspecified, the service 1357 // will attempt to choose a reasonable default. 1358 Zone string `protobuf:"bytes,9,opt,name=zone,proto3" json:"zone,omitempty"` 1359 // Settings passed through to Google Compute Engine workers when 1360 // using the standard Dataflow task runner. Users should ignore 1361 // this field. 1362 TaskrunnerSettings *TaskRunnerSettings `protobuf:"bytes,10,opt,name=taskrunner_settings,json=taskrunnerSettings,proto3" json:"taskrunner_settings,omitempty"` 1363 // The action to take on host maintenance, as defined by the Google 1364 // Compute Engine API. 1365 OnHostMaintenance string `protobuf:"bytes,11,opt,name=on_host_maintenance,json=onHostMaintenance,proto3" json:"on_host_maintenance,omitempty"` 1366 // Data disks that are used by a VM in this workflow. 1367 DataDisks []*Disk `protobuf:"bytes,12,rep,name=data_disks,json=dataDisks,proto3" json:"data_disks,omitempty"` 1368 // Metadata to set on the Google Compute Engine VMs. 1369 Metadata map[string]string `protobuf:"bytes,13,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1370 // Settings for autoscaling of this WorkerPool. 1371 AutoscalingSettings *AutoscalingSettings `protobuf:"bytes,14,opt,name=autoscaling_settings,json=autoscalingSettings,proto3" json:"autoscaling_settings,omitempty"` 1372 // Extra arguments for this worker pool. 1373 PoolArgs *anypb.Any `protobuf:"bytes,15,opt,name=pool_args,json=poolArgs,proto3" json:"pool_args,omitempty"` 1374 // Network to which VMs will be assigned. If empty or unspecified, 1375 // the service will use the network "default". 1376 Network string `protobuf:"bytes,17,opt,name=network,proto3" json:"network,omitempty"` 1377 // Subnetwork to which VMs will be assigned, if desired. Expected to be of 1378 // the form "regions/REGION/subnetworks/SUBNETWORK". 1379 Subnetwork string `protobuf:"bytes,19,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"` 1380 // Required. Docker container image that executes the Cloud Dataflow worker 1381 // harness, residing in Google Container Registry. 1382 // 1383 // Deprecated for the Fn API path. Use sdk_harness_container_images instead. 1384 WorkerHarnessContainerImage string `protobuf:"bytes,18,opt,name=worker_harness_container_image,json=workerHarnessContainerImage,proto3" json:"worker_harness_container_image,omitempty"` 1385 // The number of threads per worker harness. If empty or unspecified, the 1386 // service will choose a number of threads (according to the number of cores 1387 // on the selected machine type for batch, or 1 by convention for streaming). 1388 NumThreadsPerWorker int32 `protobuf:"varint,20,opt,name=num_threads_per_worker,json=numThreadsPerWorker,proto3" json:"num_threads_per_worker,omitempty"` 1389 // Configuration for VM IPs. 1390 IpConfiguration WorkerIPAddressConfiguration `protobuf:"varint,21,opt,name=ip_configuration,json=ipConfiguration,proto3,enum=google.dataflow.v1beta3.WorkerIPAddressConfiguration" json:"ip_configuration,omitempty"` 1391 // Set of SDK harness containers needed to execute this pipeline. This will 1392 // only be set in the Fn API path. For non-cross-language pipelines this 1393 // should have only one entry. Cross-language pipelines will have two or more 1394 // entries. 1395 SdkHarnessContainerImages []*SdkHarnessContainerImage `protobuf:"bytes,22,rep,name=sdk_harness_container_images,json=sdkHarnessContainerImages,proto3" json:"sdk_harness_container_images,omitempty"` 1396} 1397 1398func (x *WorkerPool) Reset() { 1399 *x = WorkerPool{} 1400 if protoimpl.UnsafeEnabled { 1401 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[7] 1402 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1403 ms.StoreMessageInfo(mi) 1404 } 1405} 1406 1407func (x *WorkerPool) String() string { 1408 return protoimpl.X.MessageStringOf(x) 1409} 1410 1411func (*WorkerPool) ProtoMessage() {} 1412 1413func (x *WorkerPool) ProtoReflect() protoreflect.Message { 1414 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[7] 1415 if protoimpl.UnsafeEnabled && x != nil { 1416 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1417 if ms.LoadMessageInfo() == nil { 1418 ms.StoreMessageInfo(mi) 1419 } 1420 return ms 1421 } 1422 return mi.MessageOf(x) 1423} 1424 1425// Deprecated: Use WorkerPool.ProtoReflect.Descriptor instead. 1426func (*WorkerPool) Descriptor() ([]byte, []int) { 1427 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{7} 1428} 1429 1430func (x *WorkerPool) GetKind() string { 1431 if x != nil { 1432 return x.Kind 1433 } 1434 return "" 1435} 1436 1437func (x *WorkerPool) GetNumWorkers() int32 { 1438 if x != nil { 1439 return x.NumWorkers 1440 } 1441 return 0 1442} 1443 1444func (x *WorkerPool) GetPackages() []*Package { 1445 if x != nil { 1446 return x.Packages 1447 } 1448 return nil 1449} 1450 1451func (x *WorkerPool) GetDefaultPackageSet() DefaultPackageSet { 1452 if x != nil { 1453 return x.DefaultPackageSet 1454 } 1455 return DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN 1456} 1457 1458func (x *WorkerPool) GetMachineType() string { 1459 if x != nil { 1460 return x.MachineType 1461 } 1462 return "" 1463} 1464 1465func (x *WorkerPool) GetTeardownPolicy() TeardownPolicy { 1466 if x != nil { 1467 return x.TeardownPolicy 1468 } 1469 return TeardownPolicy_TEARDOWN_POLICY_UNKNOWN 1470} 1471 1472func (x *WorkerPool) GetDiskSizeGb() int32 { 1473 if x != nil { 1474 return x.DiskSizeGb 1475 } 1476 return 0 1477} 1478 1479func (x *WorkerPool) GetDiskType() string { 1480 if x != nil { 1481 return x.DiskType 1482 } 1483 return "" 1484} 1485 1486func (x *WorkerPool) GetDiskSourceImage() string { 1487 if x != nil { 1488 return x.DiskSourceImage 1489 } 1490 return "" 1491} 1492 1493func (x *WorkerPool) GetZone() string { 1494 if x != nil { 1495 return x.Zone 1496 } 1497 return "" 1498} 1499 1500func (x *WorkerPool) GetTaskrunnerSettings() *TaskRunnerSettings { 1501 if x != nil { 1502 return x.TaskrunnerSettings 1503 } 1504 return nil 1505} 1506 1507func (x *WorkerPool) GetOnHostMaintenance() string { 1508 if x != nil { 1509 return x.OnHostMaintenance 1510 } 1511 return "" 1512} 1513 1514func (x *WorkerPool) GetDataDisks() []*Disk { 1515 if x != nil { 1516 return x.DataDisks 1517 } 1518 return nil 1519} 1520 1521func (x *WorkerPool) GetMetadata() map[string]string { 1522 if x != nil { 1523 return x.Metadata 1524 } 1525 return nil 1526} 1527 1528func (x *WorkerPool) GetAutoscalingSettings() *AutoscalingSettings { 1529 if x != nil { 1530 return x.AutoscalingSettings 1531 } 1532 return nil 1533} 1534 1535func (x *WorkerPool) GetPoolArgs() *anypb.Any { 1536 if x != nil { 1537 return x.PoolArgs 1538 } 1539 return nil 1540} 1541 1542func (x *WorkerPool) GetNetwork() string { 1543 if x != nil { 1544 return x.Network 1545 } 1546 return "" 1547} 1548 1549func (x *WorkerPool) GetSubnetwork() string { 1550 if x != nil { 1551 return x.Subnetwork 1552 } 1553 return "" 1554} 1555 1556func (x *WorkerPool) GetWorkerHarnessContainerImage() string { 1557 if x != nil { 1558 return x.WorkerHarnessContainerImage 1559 } 1560 return "" 1561} 1562 1563func (x *WorkerPool) GetNumThreadsPerWorker() int32 { 1564 if x != nil { 1565 return x.NumThreadsPerWorker 1566 } 1567 return 0 1568} 1569 1570func (x *WorkerPool) GetIpConfiguration() WorkerIPAddressConfiguration { 1571 if x != nil { 1572 return x.IpConfiguration 1573 } 1574 return WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED 1575} 1576 1577func (x *WorkerPool) GetSdkHarnessContainerImages() []*SdkHarnessContainerImage { 1578 if x != nil { 1579 return x.SdkHarnessContainerImages 1580 } 1581 return nil 1582} 1583 1584// Describes any options that have an effect on the debugging of pipelines. 1585type DebugOptions struct { 1586 state protoimpl.MessageState 1587 sizeCache protoimpl.SizeCache 1588 unknownFields protoimpl.UnknownFields 1589 1590 // When true, enables the logging of the literal hot key to the user's Cloud 1591 // Logging. 1592 EnableHotKeyLogging bool `protobuf:"varint,1,opt,name=enable_hot_key_logging,json=enableHotKeyLogging,proto3" json:"enable_hot_key_logging,omitempty"` 1593} 1594 1595func (x *DebugOptions) Reset() { 1596 *x = DebugOptions{} 1597 if protoimpl.UnsafeEnabled { 1598 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[8] 1599 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1600 ms.StoreMessageInfo(mi) 1601 } 1602} 1603 1604func (x *DebugOptions) String() string { 1605 return protoimpl.X.MessageStringOf(x) 1606} 1607 1608func (*DebugOptions) ProtoMessage() {} 1609 1610func (x *DebugOptions) ProtoReflect() protoreflect.Message { 1611 mi := &file_google_dataflow_v1beta3_environment_proto_msgTypes[8] 1612 if protoimpl.UnsafeEnabled && x != nil { 1613 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1614 if ms.LoadMessageInfo() == nil { 1615 ms.StoreMessageInfo(mi) 1616 } 1617 return ms 1618 } 1619 return mi.MessageOf(x) 1620} 1621 1622// Deprecated: Use DebugOptions.ProtoReflect.Descriptor instead. 1623func (*DebugOptions) Descriptor() ([]byte, []int) { 1624 return file_google_dataflow_v1beta3_environment_proto_rawDescGZIP(), []int{8} 1625} 1626 1627func (x *DebugOptions) GetEnableHotKeyLogging() bool { 1628 if x != nil { 1629 return x.EnableHotKeyLogging 1630 } 1631 return false 1632} 1633 1634var File_google_dataflow_v1beta3_environment_proto protoreflect.FileDescriptor 1635 1636var file_google_dataflow_v1beta3_environment_proto_rawDesc = []byte{ 1637 0x0a, 0x29, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 1638 0x77, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x65, 0x6e, 0x76, 0x69, 0x72, 0x6f, 1639 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x17, 0x67, 0x6f, 0x6f, 1640 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 1641 0x65, 0x74, 0x61, 0x33, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 1642 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 1643 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 1644 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x61, 0x6e, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 1645 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 1646 0x66, 0x2f, 0x73, 0x74, 0x72, 0x75, 0x63, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xe5, 1647 0x07, 0x0a, 0x0b, 0x45, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x2e, 1648 0x0a, 0x13, 0x74, 0x65, 0x6d, 0x70, 0x5f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x70, 1649 0x72, 0x65, 0x66, 0x69, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x74, 0x65, 0x6d, 1650 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x12, 0x3d, 1651 0x0a, 0x1b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 1652 0x72, 0x5f, 0x61, 0x70, 0x69, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x18, 0x02, 0x20, 1653 0x01, 0x28, 0x09, 0x52, 0x18, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x61, 0x6e, 0x61, 1654 0x67, 0x65, 0x72, 0x41, 0x70, 0x69, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x20, 0x0a, 1655 0x0b, 0x65, 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 1656 0x28, 0x09, 0x52, 0x0b, 0x65, 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x12, 1657 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 1658 0x6e, 0x73, 0x18, 0x10, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 1659 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x2f, 0x0a, 0x14, 0x73, 0x65, 0x72, 0x76, 1660 0x69, 0x63, 0x65, 0x5f, 0x6b, 0x6d, 0x73, 0x5f, 0x6b, 0x65, 0x79, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 1661 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4b, 1662 0x6d, 0x73, 0x4b, 0x65, 0x79, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x46, 0x0a, 0x0c, 0x77, 0x6f, 0x72, 1663 0x6b, 0x65, 0x72, 0x5f, 0x70, 0x6f, 0x6f, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 1664 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 1665 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 1666 0x50, 0x6f, 0x6f, 0x6c, 0x52, 0x0b, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x50, 0x6f, 0x6f, 0x6c, 1667 0x73, 0x12, 0x36, 0x0a, 0x0a, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x18, 1668 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 1669 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x09, 1670 0x75, 0x73, 0x65, 0x72, 0x41, 0x67, 0x65, 0x6e, 0x74, 0x12, 0x31, 0x0a, 0x07, 0x76, 0x65, 0x72, 1671 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x6f, 0x6f, 1672 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53, 0x74, 0x72, 1673 0x75, 0x63, 0x74, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 1674 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x64, 1675 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x12, 0x49, 0x0a, 0x14, 0x73, 0x64, 0x6b, 0x5f, 0x70, 0x69, 1676 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x08, 1677 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 1678 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x12, 0x73, 1679 0x64, 0x6b, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 1680 0x73, 0x12, 0x47, 0x0a, 0x14, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x5f, 0x65, 0x78, 1681 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 1682 0x14, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 1683 0x66, 0x2e, 0x41, 0x6e, 0x79, 0x52, 0x13, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x45, 1684 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x32, 0x0a, 0x15, 0x73, 0x65, 1685 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x65, 0x6d, 1686 0x61, 0x69, 0x6c, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x13, 0x73, 0x65, 0x72, 0x76, 0x69, 1687 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x45, 0x6d, 0x61, 0x69, 0x6c, 0x12, 0x76, 1688 0x0a, 0x1d, 0x66, 0x6c, 0x65, 0x78, 0x5f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 1689 0x73, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x69, 0x6e, 0x67, 0x5f, 0x67, 0x6f, 0x61, 0x6c, 0x18, 1690 0x0b, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 1691 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 1692 0x46, 0x6c, 0x65, 0x78, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x53, 0x63, 0x68, 0x65, 1693 0x64, 0x75, 0x6c, 0x69, 0x6e, 0x67, 0x47, 0x6f, 0x61, 0x6c, 0x52, 0x1a, 0x66, 0x6c, 0x65, 0x78, 1694 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x53, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x69, 1695 0x6e, 0x67, 0x47, 0x6f, 0x61, 0x6c, 0x12, 0x23, 0x0a, 0x0d, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 1696 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x77, 1697 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x77, 1698 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x7a, 0x6f, 0x6e, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 1699 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5a, 0x6f, 0x6e, 0x65, 0x12, 0x4c, 0x0a, 0x0c, 1700 0x73, 0x68, 0x75, 0x66, 0x66, 0x6c, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x0f, 0x20, 0x01, 1701 0x28, 0x0e, 0x32, 0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 1702 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x53, 0x68, 0x75, 1703 0x66, 0x66, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0b, 0x73, 1704 0x68, 0x75, 0x66, 0x66, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x4a, 0x0a, 0x0d, 0x64, 0x65, 1705 0x62, 0x75, 0x67, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x11, 0x20, 0x01, 0x28, 1706 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 1707 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x44, 0x65, 0x62, 0x75, 1708 0x67, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0c, 0x64, 0x65, 0x62, 0x75, 0x67, 0x4f, 1709 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x39, 0x0a, 0x07, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67, 1710 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 1711 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 1712 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 1713 0x6e, 0x22, 0x5d, 0x0a, 0x04, 0x44, 0x69, 0x73, 0x6b, 0x12, 0x17, 0x0a, 0x07, 0x73, 0x69, 0x7a, 1714 0x65, 0x5f, 0x67, 0x62, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x73, 0x69, 0x7a, 0x65, 1715 0x47, 0x62, 0x12, 0x1b, 0x0a, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 1716 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x69, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 1717 0x1f, 0x0a, 0x0b, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x03, 1718 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x50, 0x6f, 0x69, 0x6e, 0x74, 1719 0x22, 0xfa, 0x01, 0x0a, 0x0e, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 0x69, 1720 0x6e, 0x67, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x75, 0x72, 0x6c, 0x18, 1721 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x62, 0x61, 0x73, 0x65, 0x55, 0x72, 0x6c, 0x12, 0x2b, 1722 0x0a, 0x11, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x5f, 0x65, 0x6e, 0x61, 0x62, 1723 0x6c, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x72, 0x65, 0x70, 0x6f, 0x72, 1724 0x74, 0x69, 0x6e, 0x67, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x73, 1725 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28, 1726 0x09, 0x52, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x61, 0x74, 0x68, 0x12, 0x30, 1727 0x0a, 0x14, 0x73, 0x68, 0x75, 0x66, 0x66, 0x6c, 0x65, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 1728 0x65, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x12, 0x73, 0x68, 1729 0x75, 0x66, 0x66, 0x6c, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x61, 0x74, 0x68, 1730 0x12, 0x1b, 0x0a, 0x09, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 1731 0x01, 0x28, 0x09, 0x52, 0x08, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x49, 0x64, 0x12, 0x2e, 0x0a, 1732 0x13, 0x74, 0x65, 0x6d, 0x70, 0x5f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x70, 0x72, 1733 0x65, 0x66, 0x69, 0x78, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x74, 0x65, 0x6d, 0x70, 1734 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x22, 0xd6, 0x06, 1735 0x0a, 0x12, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 1736 0x69, 0x6e, 0x67, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x75, 0x73, 0x65, 1737 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x61, 0x73, 0x6b, 0x55, 0x73, 0x65, 1738 0x72, 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x18, 1739 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x61, 0x73, 0x6b, 0x47, 0x72, 0x6f, 0x75, 0x70, 1740 0x12, 0x21, 0x0a, 0x0c, 0x6f, 0x61, 0x75, 0x74, 0x68, 0x5f, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x73, 1741 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x6f, 0x61, 0x75, 0x74, 0x68, 0x53, 0x63, 0x6f, 1742 0x70, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x75, 0x72, 0x6c, 0x18, 1743 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x62, 0x61, 0x73, 0x65, 0x55, 0x72, 0x6c, 0x12, 0x30, 1744 0x0a, 0x14, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x61, 0x70, 0x69, 0x5f, 0x76, 1745 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x12, 0x64, 0x61, 1746 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x41, 0x70, 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 1747 0x12, 0x61, 0x0a, 0x18, 0x70, 0x61, 0x72, 0x61, 0x6c, 0x6c, 0x65, 0x6c, 0x5f, 0x77, 0x6f, 0x72, 1748 0x6b, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x18, 0x06, 0x20, 0x01, 1749 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 1750 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x57, 0x6f, 0x72, 1751 0x6b, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x52, 0x16, 0x70, 0x61, 0x72, 1752 0x61, 0x6c, 0x6c, 0x65, 0x6c, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 0x69, 1753 0x6e, 0x67, 0x73, 0x12, 0x22, 0x0a, 0x0d, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 1754 0x5f, 0x64, 0x69, 0x72, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x62, 0x61, 0x73, 0x65, 1755 0x54, 0x61, 0x73, 0x6b, 0x44, 0x69, 0x72, 0x12, 0x32, 0x0a, 0x15, 0x63, 0x6f, 0x6e, 0x74, 0x69, 1756 0x6e, 0x75, 0x65, 0x5f, 0x6f, 0x6e, 0x5f, 0x65, 0x78, 0x63, 0x65, 0x70, 0x74, 0x69, 0x6f, 0x6e, 1757 0x18, 0x08, 0x20, 0x01, 0x28, 0x08, 0x52, 0x13, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x65, 1758 0x4f, 0x6e, 0x45, 0x78, 0x63, 0x65, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x30, 0x0a, 0x14, 0x6c, 1759 0x6f, 0x67, 0x5f, 0x74, 0x6f, 0x5f, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x63, 0x6f, 0x6e, 0x73, 1760 0x6f, 0x6c, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x08, 0x52, 0x12, 0x6c, 0x6f, 0x67, 0x54, 0x6f, 1761 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x63, 0x6f, 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x12, 0x28, 0x0a, 1762 0x0f, 0x61, 0x6c, 0x73, 0x6f, 0x6c, 0x6f, 0x67, 0x74, 0x6f, 0x73, 0x74, 0x64, 0x65, 0x72, 0x72, 1763 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0f, 0x61, 0x6c, 0x73, 0x6f, 0x6c, 0x6f, 0x67, 0x74, 1764 0x6f, 0x73, 0x74, 0x64, 0x65, 0x72, 0x72, 0x12, 0x2e, 0x0a, 0x13, 0x6c, 0x6f, 0x67, 0x5f, 0x75, 1765 0x70, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x0b, 1766 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x6c, 0x6f, 0x67, 0x55, 0x70, 0x6c, 0x6f, 0x61, 0x64, 0x4c, 1767 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x17, 0x0a, 0x07, 0x6c, 0x6f, 0x67, 0x5f, 0x64, 1768 0x69, 0x72, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6c, 0x6f, 0x67, 0x44, 0x69, 0x72, 1769 0x12, 0x2e, 0x0a, 0x13, 0x74, 0x65, 0x6d, 0x70, 0x5f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 1770 0x5f, 0x70, 0x72, 0x65, 0x66, 0x69, 0x78, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x74, 1771 0x65, 0x6d, 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 1772 0x12, 0x27, 0x0a, 0x0f, 0x68, 0x61, 0x72, 0x6e, 0x65, 0x73, 0x73, 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 1773 0x61, 0x6e, 0x64, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x68, 0x61, 0x72, 0x6e, 0x65, 1774 0x73, 0x73, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x2c, 0x0a, 0x12, 0x77, 0x6f, 0x72, 1775 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x66, 0x69, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 1776 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x46, 1777 0x69, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x34, 0x0a, 0x16, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 1778 0x6e, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x5f, 0x66, 0x69, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 1779 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52, 0x14, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 1780 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x46, 0x69, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x13, 0x0a, 1781 0x05, 0x76, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x11, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x76, 0x6d, 1782 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x6c, 0x61, 0x6e, 0x67, 0x75, 0x61, 0x67, 0x65, 0x5f, 0x68, 1783 0x69, 0x6e, 0x74, 0x18, 0x12, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6c, 0x61, 0x6e, 0x67, 0x75, 1784 0x61, 0x67, 0x65, 0x48, 0x69, 0x6e, 0x74, 0x12, 0x3d, 0x0a, 0x1b, 0x73, 0x74, 0x72, 0x65, 0x61, 1785 0x6d, 0x69, 0x6e, 0x67, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x6d, 0x61, 0x69, 0x6e, 1786 0x5f, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x18, 0x13, 0x20, 0x01, 0x28, 0x09, 0x52, 0x18, 0x73, 0x74, 1787 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x4d, 0x61, 0x69, 1788 0x6e, 0x43, 0x6c, 0x61, 0x73, 0x73, 0x22, 0x8a, 0x01, 0x0a, 0x13, 0x41, 0x75, 0x74, 0x6f, 0x73, 1789 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x12, 0x4b, 1790 0x0a, 0x09, 0x61, 0x6c, 0x67, 0x6f, 0x72, 0x69, 0x74, 0x68, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 1791 0x0e, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 1792 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x75, 0x74, 0x6f, 1793 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x41, 0x6c, 0x67, 0x6f, 0x72, 0x69, 0x74, 0x68, 0x6d, 1794 0x52, 0x09, 0x61, 0x6c, 0x67, 0x6f, 0x72, 0x69, 0x74, 0x68, 0x6d, 0x12, 0x26, 0x0a, 0x0f, 0x6d, 1795 0x61, 0x78, 0x5f, 0x6e, 0x75, 0x6d, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x73, 0x18, 0x02, 1796 0x20, 0x01, 0x28, 0x05, 0x52, 0x0d, 0x6d, 0x61, 0x78, 0x4e, 0x75, 0x6d, 0x57, 0x6f, 0x72, 0x6b, 1797 0x65, 0x72, 0x73, 0x22, 0xac, 0x01, 0x0a, 0x18, 0x53, 0x64, 0x6b, 0x48, 0x61, 0x72, 0x6e, 0x65, 1798 0x73, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 1799 0x12, 0x27, 0x0a, 0x0f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x6d, 1800 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 1801 0x69, 0x6e, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x12, 0x40, 0x0a, 0x1d, 0x75, 0x73, 0x65, 1802 0x5f, 0x73, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x5f, 0x70, 0x65, 0x72, 1803 0x5f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 1804 0x52, 0x19, 0x75, 0x73, 0x65, 0x53, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x43, 0x6f, 0x72, 0x65, 0x50, 1805 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x12, 0x25, 0x0a, 0x0e, 0x65, 1806 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 1807 0x01, 0x28, 0x09, 0x52, 0x0d, 0x65, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 1808 0x49, 0x64, 0x22, 0xc5, 0x0a, 0x0a, 0x0a, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x50, 0x6f, 0x6f, 1809 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 1810 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x6e, 0x75, 0x6d, 0x5f, 0x77, 0x6f, 0x72, 1811 0x6b, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x6e, 0x75, 0x6d, 0x57, 1812 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x73, 0x12, 0x3c, 0x0a, 0x08, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 1813 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1814 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 1815 0x61, 0x33, 0x2e, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x52, 0x08, 0x70, 0x61, 0x63, 0x6b, 1816 0x61, 0x67, 0x65, 0x73, 0x12, 0x5a, 0x0a, 0x13, 0x64, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x5f, 1817 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 1818 0x0e, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 1819 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x44, 0x65, 0x66, 0x61, 1820 0x75, 0x6c, 0x74, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x53, 0x65, 0x74, 0x52, 0x11, 0x64, 1821 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x53, 0x65, 0x74, 1822 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 1823 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 1824 0x79, 0x70, 0x65, 0x12, 0x50, 0x0a, 0x0f, 0x74, 0x65, 0x61, 0x72, 0x64, 0x6f, 0x77, 0x6e, 0x5f, 1825 0x70, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x27, 0x2e, 0x67, 1826 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 1827 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x65, 0x61, 0x72, 0x64, 0x6f, 0x77, 0x6e, 0x50, 1828 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x52, 0x0e, 0x74, 0x65, 0x61, 0x72, 0x64, 0x6f, 0x77, 0x6e, 0x50, 1829 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0x20, 0x0a, 0x0c, 0x64, 0x69, 0x73, 0x6b, 0x5f, 0x73, 0x69, 1830 0x7a, 0x65, 0x5f, 0x67, 0x62, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x64, 0x69, 0x73, 1831 0x6b, 0x53, 0x69, 0x7a, 0x65, 0x47, 0x62, 0x12, 0x1b, 0x0a, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x5f, 1832 0x74, 0x79, 0x70, 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x69, 0x73, 0x6b, 1833 0x54, 0x79, 0x70, 0x65, 0x12, 0x2a, 0x0a, 0x11, 0x64, 0x69, 0x73, 0x6b, 0x5f, 0x73, 0x6f, 0x75, 1834 0x72, 0x63, 0x65, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 1835 0x0f, 0x64, 0x69, 0x73, 0x6b, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x49, 0x6d, 0x61, 0x67, 0x65, 1836 0x12, 0x12, 0x0a, 0x04, 0x7a, 0x6f, 0x6e, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 1837 0x7a, 0x6f, 0x6e, 0x65, 0x12, 0x5c, 0x0a, 0x13, 0x74, 0x61, 0x73, 0x6b, 0x72, 0x75, 0x6e, 0x6e, 1838 0x65, 0x72, 0x5f, 0x73, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x18, 0x0a, 0x20, 0x01, 0x28, 1839 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 1840 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 1841 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x52, 0x12, 1842 0x74, 0x61, 0x73, 0x6b, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 1843 0x67, 0x73, 0x12, 0x2e, 0x0a, 0x13, 0x6f, 0x6e, 0x5f, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x6d, 0x61, 1844 0x69, 0x6e, 0x74, 0x65, 0x6e, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 1845 0x11, 0x6f, 0x6e, 0x48, 0x6f, 0x73, 0x74, 0x4d, 0x61, 0x69, 0x6e, 0x74, 0x65, 0x6e, 0x61, 0x6e, 1846 0x63, 0x65, 0x12, 0x3c, 0x0a, 0x0a, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x64, 0x69, 0x73, 0x6b, 0x73, 1847 0x18, 0x0c, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1848 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 1849 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x52, 0x09, 0x64, 0x61, 0x74, 0x61, 0x44, 0x69, 0x73, 0x6b, 0x73, 1850 0x12, 0x4d, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x0d, 0x20, 0x03, 1851 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 1852 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x57, 0x6f, 0x72, 1853 0x6b, 0x65, 0x72, 0x50, 0x6f, 0x6f, 0x6c, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 1854 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 1855 0x5f, 0x0a, 0x14, 0x61, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x5f, 0x73, 1856 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 1857 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 1858 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 1859 0x69, 0x6e, 0x67, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 0x52, 0x13, 0x61, 0x75, 0x74, 1860 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x74, 0x74, 0x69, 0x6e, 0x67, 0x73, 1861 0x12, 0x31, 0x0a, 0x09, 0x70, 0x6f, 0x6f, 0x6c, 0x5f, 0x61, 0x72, 0x67, 0x73, 0x18, 0x0f, 0x20, 1862 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 1863 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x41, 0x6e, 0x79, 0x52, 0x08, 0x70, 0x6f, 0x6f, 0x6c, 0x41, 1864 0x72, 0x67, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x18, 0x11, 1865 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x12, 0x1e, 0x0a, 1866 0x0a, 0x73, 0x75, 0x62, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x18, 0x13, 0x20, 0x01, 0x28, 1867 0x09, 0x52, 0x0a, 0x73, 0x75, 0x62, 0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x12, 0x43, 0x0a, 1868 0x1e, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x68, 0x61, 0x72, 0x6e, 0x65, 0x73, 0x73, 0x5f, 1869 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x18, 1870 0x12, 0x20, 0x01, 0x28, 0x09, 0x52, 0x1b, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x48, 0x61, 0x72, 1871 0x6e, 0x65, 0x73, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x6d, 0x61, 1872 0x67, 0x65, 0x12, 0x33, 0x0a, 0x16, 0x6e, 0x75, 0x6d, 0x5f, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 1873 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x18, 0x14, 0x20, 0x01, 1874 0x28, 0x05, 0x52, 0x13, 0x6e, 0x75, 0x6d, 0x54, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x50, 0x65, 1875 0x72, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x12, 0x60, 0x0a, 0x10, 0x69, 0x70, 0x5f, 0x63, 0x6f, 1876 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x15, 0x20, 0x01, 0x28, 1877 0x0e, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 1878 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 1879 0x65, 0x72, 0x49, 0x50, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 1880 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0f, 0x69, 0x70, 0x43, 0x6f, 0x6e, 0x66, 1881 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x72, 0x0a, 0x1c, 0x73, 0x64, 0x6b, 1882 0x5f, 0x68, 0x61, 0x72, 0x6e, 0x65, 0x73, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 1883 0x65, 0x72, 0x5f, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x18, 0x16, 0x20, 0x03, 0x28, 0x0b, 0x32, 1884 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 1885 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x53, 0x64, 0x6b, 0x48, 0x61, 0x72, 1886 0x6e, 0x65, 0x73, 0x73, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x6d, 0x61, 1887 0x67, 0x65, 0x52, 0x19, 0x73, 0x64, 0x6b, 0x48, 0x61, 0x72, 0x6e, 0x65, 0x73, 0x73, 0x43, 0x6f, 1888 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x1a, 0x3b, 0x0a, 1889 0x0d, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 1890 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 1891 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 1892 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x43, 0x0a, 0x0c, 0x44, 0x65, 1893 0x62, 0x75, 0x67, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x33, 0x0a, 0x16, 0x65, 0x6e, 1894 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x68, 0x6f, 0x74, 0x5f, 0x6b, 0x65, 0x79, 0x5f, 0x6c, 0x6f, 0x67, 1895 0x67, 0x69, 0x6e, 0x67, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x13, 0x65, 0x6e, 0x61, 0x62, 1896 0x6c, 0x65, 0x48, 0x6f, 0x74, 0x4b, 0x65, 0x79, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2a, 1897 0x4b, 0x0a, 0x07, 0x4a, 0x6f, 0x62, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x4a, 0x4f, 1898 0x42, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 1899 0x12, 0x12, 0x0a, 0x0e, 0x4a, 0x4f, 0x42, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x42, 0x41, 0x54, 1900 0x43, 0x48, 0x10, 0x01, 0x12, 0x16, 0x0a, 0x12, 0x4a, 0x4f, 0x42, 0x5f, 0x54, 0x59, 0x50, 0x45, 1901 0x5f, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x2a, 0x6b, 0x0a, 0x1a, 1902 0x46, 0x6c, 0x65, 0x78, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x53, 0x63, 0x68, 0x65, 1903 0x64, 0x75, 0x6c, 0x69, 0x6e, 0x67, 0x47, 0x6f, 0x61, 0x6c, 0x12, 0x16, 0x0a, 0x12, 0x46, 0x4c, 1904 0x45, 0x58, 0x52, 0x53, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 1905 0x10, 0x00, 0x12, 0x1a, 0x0a, 0x16, 0x46, 0x4c, 0x45, 0x58, 0x52, 0x53, 0x5f, 0x53, 0x50, 0x45, 1906 0x45, 0x44, 0x5f, 0x4f, 0x50, 0x54, 0x49, 0x4d, 0x49, 0x5a, 0x45, 0x44, 0x10, 0x01, 0x12, 0x19, 1907 0x0a, 0x15, 0x46, 0x4c, 0x45, 0x58, 0x52, 0x53, 0x5f, 0x43, 0x4f, 0x53, 0x54, 0x5f, 0x4f, 0x50, 1908 0x54, 0x49, 0x4d, 0x49, 0x5a, 0x45, 0x44, 0x10, 0x02, 0x2a, 0x6f, 0x0a, 0x0e, 0x54, 0x65, 0x61, 1909 0x72, 0x64, 0x6f, 0x77, 0x6e, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0x1b, 0x0a, 0x17, 0x54, 1910 0x45, 0x41, 0x52, 0x44, 0x4f, 0x57, 0x4e, 0x5f, 0x50, 0x4f, 0x4c, 0x49, 0x43, 0x59, 0x5f, 0x55, 1911 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x54, 0x45, 0x41, 0x52, 1912 0x44, 0x4f, 0x57, 0x4e, 0x5f, 0x41, 0x4c, 0x57, 0x41, 0x59, 0x53, 0x10, 0x01, 0x12, 0x17, 0x0a, 1913 0x13, 0x54, 0x45, 0x41, 0x52, 0x44, 0x4f, 0x57, 0x4e, 0x5f, 0x4f, 0x4e, 0x5f, 0x53, 0x55, 0x43, 1914 0x43, 0x45, 0x53, 0x53, 0x10, 0x02, 0x12, 0x12, 0x0a, 0x0e, 0x54, 0x45, 0x41, 0x52, 0x44, 0x4f, 1915 0x57, 0x4e, 0x5f, 0x4e, 0x45, 0x56, 0x45, 0x52, 0x10, 0x03, 0x2a, 0x90, 0x01, 0x0a, 0x11, 0x44, 1916 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x53, 0x65, 0x74, 1917 0x12, 0x1f, 0x0a, 0x1b, 0x44, 0x45, 0x46, 0x41, 0x55, 0x4c, 0x54, 0x5f, 0x50, 0x41, 0x43, 0x4b, 1918 0x41, 0x47, 0x45, 0x5f, 0x53, 0x45, 0x54, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 1919 0x00, 0x12, 0x1c, 0x0a, 0x18, 0x44, 0x45, 0x46, 0x41, 0x55, 0x4c, 0x54, 0x5f, 0x50, 0x41, 0x43, 1920 0x4b, 0x41, 0x47, 0x45, 0x5f, 0x53, 0x45, 0x54, 0x5f, 0x4e, 0x4f, 0x4e, 0x45, 0x10, 0x01, 0x12, 1921 0x1c, 0x0a, 0x18, 0x44, 0x45, 0x46, 0x41, 0x55, 0x4c, 0x54, 0x5f, 0x50, 0x41, 0x43, 0x4b, 0x41, 1922 0x47, 0x45, 0x5f, 0x53, 0x45, 0x54, 0x5f, 0x4a, 0x41, 0x56, 0x41, 0x10, 0x02, 0x12, 0x1e, 0x0a, 1923 0x1a, 0x44, 0x45, 0x46, 0x41, 0x55, 0x4c, 0x54, 0x5f, 0x50, 0x41, 0x43, 0x4b, 0x41, 0x47, 0x45, 1924 0x5f, 0x53, 0x45, 0x54, 0x5f, 0x50, 0x59, 0x54, 0x48, 0x4f, 0x4e, 0x10, 0x03, 0x2a, 0x7a, 0x0a, 1925 0x14, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x41, 0x6c, 0x67, 0x6f, 1926 0x72, 0x69, 0x74, 0x68, 0x6d, 0x12, 0x21, 0x0a, 0x1d, 0x41, 0x55, 0x54, 0x4f, 0x53, 0x43, 0x41, 1927 0x4c, 0x49, 0x4e, 0x47, 0x5f, 0x41, 0x4c, 0x47, 0x4f, 0x52, 0x49, 0x54, 0x48, 0x4d, 0x5f, 0x55, 1928 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x1e, 0x0a, 0x1a, 0x41, 0x55, 0x54, 0x4f, 1929 0x53, 0x43, 0x41, 0x4c, 0x49, 0x4e, 0x47, 0x5f, 0x41, 0x4c, 0x47, 0x4f, 0x52, 0x49, 0x54, 0x48, 1930 0x4d, 0x5f, 0x4e, 0x4f, 0x4e, 0x45, 0x10, 0x01, 0x12, 0x1f, 0x0a, 0x1b, 0x41, 0x55, 0x54, 0x4f, 1931 0x53, 0x43, 0x41, 0x4c, 0x49, 0x4e, 0x47, 0x5f, 0x41, 0x4c, 0x47, 0x4f, 0x52, 0x49, 0x54, 0x48, 1932 0x4d, 0x5f, 0x42, 0x41, 0x53, 0x49, 0x43, 0x10, 0x02, 0x2a, 0x66, 0x0a, 0x1c, 0x57, 0x6f, 0x72, 1933 0x6b, 0x65, 0x72, 0x49, 0x50, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x43, 0x6f, 0x6e, 0x66, 1934 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x19, 0x0a, 0x15, 0x57, 0x4f, 0x52, 1935 0x4b, 0x45, 0x52, 0x5f, 0x49, 0x50, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 1936 0x45, 0x44, 0x10, 0x00, 0x12, 0x14, 0x0a, 0x10, 0x57, 0x4f, 0x52, 0x4b, 0x45, 0x52, 0x5f, 0x49, 1937 0x50, 0x5f, 0x50, 0x55, 0x42, 0x4c, 0x49, 0x43, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x57, 0x4f, 1938 0x52, 0x4b, 0x45, 0x52, 0x5f, 0x49, 0x50, 0x5f, 0x50, 0x52, 0x49, 0x56, 0x41, 0x54, 0x45, 0x10, 1939 0x02, 0x2a, 0x4c, 0x0a, 0x0b, 0x53, 0x68, 0x75, 0x66, 0x66, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x65, 1940 0x12, 0x1c, 0x0a, 0x18, 0x53, 0x48, 0x55, 0x46, 0x46, 0x4c, 0x45, 0x5f, 0x4d, 0x4f, 0x44, 0x45, 1941 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0c, 1942 0x0a, 0x08, 0x56, 0x4d, 0x5f, 0x42, 0x41, 0x53, 0x45, 0x44, 0x10, 0x01, 0x12, 0x11, 0x0a, 0x0d, 1943 0x53, 0x45, 0x52, 0x56, 0x49, 0x43, 0x45, 0x5f, 0x42, 0x41, 0x53, 0x45, 0x44, 0x10, 0x02, 0x42, 1944 0xd5, 0x01, 0x0a, 0x1b, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 1945 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 1946 0x10, 0x45, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x50, 0x72, 0x6f, 0x74, 1947 0x6f, 0x50, 0x01, 0x5a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 1948 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 1949 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x66, 1950 0x6c, 0x6f, 0x77, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x3b, 0x64, 0x61, 0x74, 0x61, 1951 0x66, 0x6c, 0x6f, 0x77, 0xaa, 0x02, 0x1d, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 1952 0x6f, 0x75, 0x64, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x56, 0x31, 0x42, 1953 0x65, 0x74, 0x61, 0x33, 0xca, 0x02, 0x1d, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 1954 0x6f, 0x75, 0x64, 0x5c, 0x44, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x5c, 0x56, 0x31, 0x62, 1955 0x65, 0x74, 0x61, 0x33, 0xea, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 1956 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, 0x44, 0x61, 0x74, 0x61, 0x66, 0x6c, 0x6f, 0x77, 0x3a, 0x3a, 1957 0x56, 0x31, 0x62, 0x65, 0x74, 0x61, 0x33, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 1958} 1959 1960var ( 1961 file_google_dataflow_v1beta3_environment_proto_rawDescOnce sync.Once 1962 file_google_dataflow_v1beta3_environment_proto_rawDescData = file_google_dataflow_v1beta3_environment_proto_rawDesc 1963) 1964 1965func file_google_dataflow_v1beta3_environment_proto_rawDescGZIP() []byte { 1966 file_google_dataflow_v1beta3_environment_proto_rawDescOnce.Do(func() { 1967 file_google_dataflow_v1beta3_environment_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_dataflow_v1beta3_environment_proto_rawDescData) 1968 }) 1969 return file_google_dataflow_v1beta3_environment_proto_rawDescData 1970} 1971 1972var file_google_dataflow_v1beta3_environment_proto_enumTypes = make([]protoimpl.EnumInfo, 7) 1973var file_google_dataflow_v1beta3_environment_proto_msgTypes = make([]protoimpl.MessageInfo, 10) 1974var file_google_dataflow_v1beta3_environment_proto_goTypes = []interface{}{ 1975 (JobType)(0), // 0: google.dataflow.v1beta3.JobType 1976 (FlexResourceSchedulingGoal)(0), // 1: google.dataflow.v1beta3.FlexResourceSchedulingGoal 1977 (TeardownPolicy)(0), // 2: google.dataflow.v1beta3.TeardownPolicy 1978 (DefaultPackageSet)(0), // 3: google.dataflow.v1beta3.DefaultPackageSet 1979 (AutoscalingAlgorithm)(0), // 4: google.dataflow.v1beta3.AutoscalingAlgorithm 1980 (WorkerIPAddressConfiguration)(0), // 5: google.dataflow.v1beta3.WorkerIPAddressConfiguration 1981 (ShuffleMode)(0), // 6: google.dataflow.v1beta3.ShuffleMode 1982 (*Environment)(nil), // 7: google.dataflow.v1beta3.Environment 1983 (*Package)(nil), // 8: google.dataflow.v1beta3.Package 1984 (*Disk)(nil), // 9: google.dataflow.v1beta3.Disk 1985 (*WorkerSettings)(nil), // 10: google.dataflow.v1beta3.WorkerSettings 1986 (*TaskRunnerSettings)(nil), // 11: google.dataflow.v1beta3.TaskRunnerSettings 1987 (*AutoscalingSettings)(nil), // 12: google.dataflow.v1beta3.AutoscalingSettings 1988 (*SdkHarnessContainerImage)(nil), // 13: google.dataflow.v1beta3.SdkHarnessContainerImage 1989 (*WorkerPool)(nil), // 14: google.dataflow.v1beta3.WorkerPool 1990 (*DebugOptions)(nil), // 15: google.dataflow.v1beta3.DebugOptions 1991 nil, // 16: google.dataflow.v1beta3.WorkerPool.MetadataEntry 1992 (*structpb.Struct)(nil), // 17: google.protobuf.Struct 1993 (*anypb.Any)(nil), // 18: google.protobuf.Any 1994} 1995var file_google_dataflow_v1beta3_environment_proto_depIdxs = []int32{ 1996 14, // 0: google.dataflow.v1beta3.Environment.worker_pools:type_name -> google.dataflow.v1beta3.WorkerPool 1997 17, // 1: google.dataflow.v1beta3.Environment.user_agent:type_name -> google.protobuf.Struct 1998 17, // 2: google.dataflow.v1beta3.Environment.version:type_name -> google.protobuf.Struct 1999 17, // 3: google.dataflow.v1beta3.Environment.sdk_pipeline_options:type_name -> google.protobuf.Struct 2000 18, // 4: google.dataflow.v1beta3.Environment.internal_experiments:type_name -> google.protobuf.Any 2001 1, // 5: google.dataflow.v1beta3.Environment.flex_resource_scheduling_goal:type_name -> google.dataflow.v1beta3.FlexResourceSchedulingGoal 2002 6, // 6: google.dataflow.v1beta3.Environment.shuffle_mode:type_name -> google.dataflow.v1beta3.ShuffleMode 2003 15, // 7: google.dataflow.v1beta3.Environment.debug_options:type_name -> google.dataflow.v1beta3.DebugOptions 2004 10, // 8: google.dataflow.v1beta3.TaskRunnerSettings.parallel_worker_settings:type_name -> google.dataflow.v1beta3.WorkerSettings 2005 4, // 9: google.dataflow.v1beta3.AutoscalingSettings.algorithm:type_name -> google.dataflow.v1beta3.AutoscalingAlgorithm 2006 8, // 10: google.dataflow.v1beta3.WorkerPool.packages:type_name -> google.dataflow.v1beta3.Package 2007 3, // 11: google.dataflow.v1beta3.WorkerPool.default_package_set:type_name -> google.dataflow.v1beta3.DefaultPackageSet 2008 2, // 12: google.dataflow.v1beta3.WorkerPool.teardown_policy:type_name -> google.dataflow.v1beta3.TeardownPolicy 2009 11, // 13: google.dataflow.v1beta3.WorkerPool.taskrunner_settings:type_name -> google.dataflow.v1beta3.TaskRunnerSettings 2010 9, // 14: google.dataflow.v1beta3.WorkerPool.data_disks:type_name -> google.dataflow.v1beta3.Disk 2011 16, // 15: google.dataflow.v1beta3.WorkerPool.metadata:type_name -> google.dataflow.v1beta3.WorkerPool.MetadataEntry 2012 12, // 16: google.dataflow.v1beta3.WorkerPool.autoscaling_settings:type_name -> google.dataflow.v1beta3.AutoscalingSettings 2013 18, // 17: google.dataflow.v1beta3.WorkerPool.pool_args:type_name -> google.protobuf.Any 2014 5, // 18: google.dataflow.v1beta3.WorkerPool.ip_configuration:type_name -> google.dataflow.v1beta3.WorkerIPAddressConfiguration 2015 13, // 19: google.dataflow.v1beta3.WorkerPool.sdk_harness_container_images:type_name -> google.dataflow.v1beta3.SdkHarnessContainerImage 2016 20, // [20:20] is the sub-list for method output_type 2017 20, // [20:20] is the sub-list for method input_type 2018 20, // [20:20] is the sub-list for extension type_name 2019 20, // [20:20] is the sub-list for extension extendee 2020 0, // [0:20] is the sub-list for field type_name 2021} 2022 2023func init() { file_google_dataflow_v1beta3_environment_proto_init() } 2024func file_google_dataflow_v1beta3_environment_proto_init() { 2025 if File_google_dataflow_v1beta3_environment_proto != nil { 2026 return 2027 } 2028 if !protoimpl.UnsafeEnabled { 2029 file_google_dataflow_v1beta3_environment_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 2030 switch v := v.(*Environment); i { 2031 case 0: 2032 return &v.state 2033 case 1: 2034 return &v.sizeCache 2035 case 2: 2036 return &v.unknownFields 2037 default: 2038 return nil 2039 } 2040 } 2041 file_google_dataflow_v1beta3_environment_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 2042 switch v := v.(*Package); i { 2043 case 0: 2044 return &v.state 2045 case 1: 2046 return &v.sizeCache 2047 case 2: 2048 return &v.unknownFields 2049 default: 2050 return nil 2051 } 2052 } 2053 file_google_dataflow_v1beta3_environment_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 2054 switch v := v.(*Disk); i { 2055 case 0: 2056 return &v.state 2057 case 1: 2058 return &v.sizeCache 2059 case 2: 2060 return &v.unknownFields 2061 default: 2062 return nil 2063 } 2064 } 2065 file_google_dataflow_v1beta3_environment_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 2066 switch v := v.(*WorkerSettings); i { 2067 case 0: 2068 return &v.state 2069 case 1: 2070 return &v.sizeCache 2071 case 2: 2072 return &v.unknownFields 2073 default: 2074 return nil 2075 } 2076 } 2077 file_google_dataflow_v1beta3_environment_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 2078 switch v := v.(*TaskRunnerSettings); i { 2079 case 0: 2080 return &v.state 2081 case 1: 2082 return &v.sizeCache 2083 case 2: 2084 return &v.unknownFields 2085 default: 2086 return nil 2087 } 2088 } 2089 file_google_dataflow_v1beta3_environment_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 2090 switch v := v.(*AutoscalingSettings); i { 2091 case 0: 2092 return &v.state 2093 case 1: 2094 return &v.sizeCache 2095 case 2: 2096 return &v.unknownFields 2097 default: 2098 return nil 2099 } 2100 } 2101 file_google_dataflow_v1beta3_environment_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 2102 switch v := v.(*SdkHarnessContainerImage); i { 2103 case 0: 2104 return &v.state 2105 case 1: 2106 return &v.sizeCache 2107 case 2: 2108 return &v.unknownFields 2109 default: 2110 return nil 2111 } 2112 } 2113 file_google_dataflow_v1beta3_environment_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 2114 switch v := v.(*WorkerPool); i { 2115 case 0: 2116 return &v.state 2117 case 1: 2118 return &v.sizeCache 2119 case 2: 2120 return &v.unknownFields 2121 default: 2122 return nil 2123 } 2124 } 2125 file_google_dataflow_v1beta3_environment_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 2126 switch v := v.(*DebugOptions); i { 2127 case 0: 2128 return &v.state 2129 case 1: 2130 return &v.sizeCache 2131 case 2: 2132 return &v.unknownFields 2133 default: 2134 return nil 2135 } 2136 } 2137 } 2138 type x struct{} 2139 out := protoimpl.TypeBuilder{ 2140 File: protoimpl.DescBuilder{ 2141 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 2142 RawDescriptor: file_google_dataflow_v1beta3_environment_proto_rawDesc, 2143 NumEnums: 7, 2144 NumMessages: 10, 2145 NumExtensions: 0, 2146 NumServices: 0, 2147 }, 2148 GoTypes: file_google_dataflow_v1beta3_environment_proto_goTypes, 2149 DependencyIndexes: file_google_dataflow_v1beta3_environment_proto_depIdxs, 2150 EnumInfos: file_google_dataflow_v1beta3_environment_proto_enumTypes, 2151 MessageInfos: file_google_dataflow_v1beta3_environment_proto_msgTypes, 2152 }.Build() 2153 File_google_dataflow_v1beta3_environment_proto = out.File 2154 file_google_dataflow_v1beta3_environment_proto_rawDesc = nil 2155 file_google_dataflow_v1beta3_environment_proto_goTypes = nil 2156 file_google_dataflow_v1beta3_environment_proto_depIdxs = nil 2157} 2158