1 // Copyright 2022 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 aliasgen. DO NOT EDIT. 16 17 // Package dataflow aliases all exported identifiers in package 18 // "cloud.google.com/go/dataflow/apiv1beta3/dataflowpb". 19 // 20 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb. 21 // Please read https://github.com/googleapis/google-cloud-go/blob/main/migration.md 22 // for more details. 23 package dataflow 24 25 import ( 26 src "cloud.google.com/go/dataflow/apiv1beta3/dataflowpb" 27 grpc "google.golang.org/grpc" 28 ) 29 30 // Deprecated: Please use consts in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 31 const ( 32 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC 33 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE 34 AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN 35 AutoscalingEvent_ACTUATION_FAILURE = src.AutoscalingEvent_ACTUATION_FAILURE 36 AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED = src.AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED 37 AutoscalingEvent_NO_CHANGE = src.AutoscalingEvent_NO_CHANGE 38 AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED = src.AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED 39 AutoscalingEvent_TYPE_UNKNOWN = src.AutoscalingEvent_TYPE_UNKNOWN 40 DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA 41 DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE 42 DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON 43 DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN 44 ExecutionState_EXECUTION_STATE_CANCELLED = src.ExecutionState_EXECUTION_STATE_CANCELLED 45 ExecutionState_EXECUTION_STATE_FAILED = src.ExecutionState_EXECUTION_STATE_FAILED 46 ExecutionState_EXECUTION_STATE_NOT_STARTED = src.ExecutionState_EXECUTION_STATE_NOT_STARTED 47 ExecutionState_EXECUTION_STATE_RUNNING = src.ExecutionState_EXECUTION_STATE_RUNNING 48 ExecutionState_EXECUTION_STATE_SUCCEEDED = src.ExecutionState_EXECUTION_STATE_SUCCEEDED 49 ExecutionState_EXECUTION_STATE_UNKNOWN = src.ExecutionState_EXECUTION_STATE_UNKNOWN 50 FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED = src.FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED 51 FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED = src.FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED 52 FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED = src.FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED 53 GetTemplateRequest_METADATA_ONLY = src.GetTemplateRequest_METADATA_ONLY 54 GetTemplateResponse_FLEX = src.GetTemplateResponse_FLEX 55 GetTemplateResponse_LEGACY = src.GetTemplateResponse_LEGACY 56 GetTemplateResponse_UNKNOWN = src.GetTemplateResponse_UNKNOWN 57 JobMessageImportance_JOB_MESSAGE_BASIC = src.JobMessageImportance_JOB_MESSAGE_BASIC 58 JobMessageImportance_JOB_MESSAGE_DEBUG = src.JobMessageImportance_JOB_MESSAGE_DEBUG 59 JobMessageImportance_JOB_MESSAGE_DETAILED = src.JobMessageImportance_JOB_MESSAGE_DETAILED 60 JobMessageImportance_JOB_MESSAGE_ERROR = src.JobMessageImportance_JOB_MESSAGE_ERROR 61 JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN = src.JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN 62 JobMessageImportance_JOB_MESSAGE_WARNING = src.JobMessageImportance_JOB_MESSAGE_WARNING 63 JobState_JOB_STATE_CANCELLED = src.JobState_JOB_STATE_CANCELLED 64 JobState_JOB_STATE_CANCELLING = src.JobState_JOB_STATE_CANCELLING 65 JobState_JOB_STATE_DONE = src.JobState_JOB_STATE_DONE 66 JobState_JOB_STATE_DRAINED = src.JobState_JOB_STATE_DRAINED 67 JobState_JOB_STATE_DRAINING = src.JobState_JOB_STATE_DRAINING 68 JobState_JOB_STATE_FAILED = src.JobState_JOB_STATE_FAILED 69 JobState_JOB_STATE_PENDING = src.JobState_JOB_STATE_PENDING 70 JobState_JOB_STATE_QUEUED = src.JobState_JOB_STATE_QUEUED 71 JobState_JOB_STATE_RESOURCE_CLEANING_UP = src.JobState_JOB_STATE_RESOURCE_CLEANING_UP 72 JobState_JOB_STATE_RUNNING = src.JobState_JOB_STATE_RUNNING 73 JobState_JOB_STATE_STOPPED = src.JobState_JOB_STATE_STOPPED 74 JobState_JOB_STATE_UNKNOWN = src.JobState_JOB_STATE_UNKNOWN 75 JobState_JOB_STATE_UPDATED = src.JobState_JOB_STATE_UPDATED 76 JobType_JOB_TYPE_BATCH = src.JobType_JOB_TYPE_BATCH 77 JobType_JOB_TYPE_STREAMING = src.JobType_JOB_TYPE_STREAMING 78 JobType_JOB_TYPE_UNKNOWN = src.JobType_JOB_TYPE_UNKNOWN 79 JobView_JOB_VIEW_ALL = src.JobView_JOB_VIEW_ALL 80 JobView_JOB_VIEW_DESCRIPTION = src.JobView_JOB_VIEW_DESCRIPTION 81 JobView_JOB_VIEW_SUMMARY = src.JobView_JOB_VIEW_SUMMARY 82 JobView_JOB_VIEW_UNKNOWN = src.JobView_JOB_VIEW_UNKNOWN 83 KindType_CONSTANT_KIND = src.KindType_CONSTANT_KIND 84 KindType_FLATTEN_KIND = src.KindType_FLATTEN_KIND 85 KindType_GROUP_BY_KEY_KIND = src.KindType_GROUP_BY_KEY_KIND 86 KindType_PAR_DO_KIND = src.KindType_PAR_DO_KIND 87 KindType_READ_KIND = src.KindType_READ_KIND 88 KindType_SHUFFLE_KIND = src.KindType_SHUFFLE_KIND 89 KindType_SINGLETON_KIND = src.KindType_SINGLETON_KIND 90 KindType_UNKNOWN_KIND = src.KindType_UNKNOWN_KIND 91 KindType_WRITE_KIND = src.KindType_WRITE_KIND 92 ListJobsRequest_ACTIVE = src.ListJobsRequest_ACTIVE 93 ListJobsRequest_ALL = src.ListJobsRequest_ALL 94 ListJobsRequest_TERMINATED = src.ListJobsRequest_TERMINATED 95 ListJobsRequest_UNKNOWN = src.ListJobsRequest_UNKNOWN 96 ParameterType_DEFAULT = src.ParameterType_DEFAULT 97 ParameterType_GCS_READ_BUCKET = src.ParameterType_GCS_READ_BUCKET 98 ParameterType_GCS_READ_FILE = src.ParameterType_GCS_READ_FILE 99 ParameterType_GCS_READ_FOLDER = src.ParameterType_GCS_READ_FOLDER 100 ParameterType_GCS_WRITE_BUCKET = src.ParameterType_GCS_WRITE_BUCKET 101 ParameterType_GCS_WRITE_FILE = src.ParameterType_GCS_WRITE_FILE 102 ParameterType_GCS_WRITE_FOLDER = src.ParameterType_GCS_WRITE_FOLDER 103 ParameterType_PUBSUB_SUBSCRIPTION = src.ParameterType_PUBSUB_SUBSCRIPTION 104 ParameterType_PUBSUB_TOPIC = src.ParameterType_PUBSUB_TOPIC 105 ParameterType_TEXT = src.ParameterType_TEXT 106 SDKInfo_JAVA = src.SDKInfo_JAVA 107 SDKInfo_PYTHON = src.SDKInfo_PYTHON 108 SDKInfo_UNKNOWN = src.SDKInfo_UNKNOWN 109 SdkVersion_DEPRECATED = src.SdkVersion_DEPRECATED 110 SdkVersion_STALE = src.SdkVersion_STALE 111 SdkVersion_SUPPORTED = src.SdkVersion_SUPPORTED 112 SdkVersion_UNKNOWN = src.SdkVersion_UNKNOWN 113 SdkVersion_UNSUPPORTED = src.SdkVersion_UNSUPPORTED 114 ShuffleMode_SERVICE_BASED = src.ShuffleMode_SERVICE_BASED 115 ShuffleMode_SHUFFLE_MODE_UNSPECIFIED = src.ShuffleMode_SHUFFLE_MODE_UNSPECIFIED 116 ShuffleMode_VM_BASED = src.ShuffleMode_VM_BASED 117 SnapshotState_DELETED = src.SnapshotState_DELETED 118 SnapshotState_FAILED = src.SnapshotState_FAILED 119 SnapshotState_PENDING = src.SnapshotState_PENDING 120 SnapshotState_READY = src.SnapshotState_READY 121 SnapshotState_RUNNING = src.SnapshotState_RUNNING 122 SnapshotState_UNKNOWN_SNAPSHOT_STATE = src.SnapshotState_UNKNOWN_SNAPSHOT_STATE 123 TeardownPolicy_TEARDOWN_ALWAYS = src.TeardownPolicy_TEARDOWN_ALWAYS 124 TeardownPolicy_TEARDOWN_NEVER = src.TeardownPolicy_TEARDOWN_NEVER 125 TeardownPolicy_TEARDOWN_ON_SUCCESS = src.TeardownPolicy_TEARDOWN_ON_SUCCESS 126 TeardownPolicy_TEARDOWN_POLICY_UNKNOWN = src.TeardownPolicy_TEARDOWN_POLICY_UNKNOWN 127 WorkerIPAddressConfiguration_WORKER_IP_PRIVATE = src.WorkerIPAddressConfiguration_WORKER_IP_PRIVATE 128 WorkerIPAddressConfiguration_WORKER_IP_PUBLIC = src.WorkerIPAddressConfiguration_WORKER_IP_PUBLIC 129 WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED = src.WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED 130 ) 131 132 // Deprecated: Please use vars in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 133 var ( 134 AutoscalingAlgorithm_name = src.AutoscalingAlgorithm_name 135 AutoscalingAlgorithm_value = src.AutoscalingAlgorithm_value 136 AutoscalingEvent_AutoscalingEventType_name = src.AutoscalingEvent_AutoscalingEventType_name 137 AutoscalingEvent_AutoscalingEventType_value = src.AutoscalingEvent_AutoscalingEventType_value 138 DefaultPackageSet_name = src.DefaultPackageSet_name 139 DefaultPackageSet_value = src.DefaultPackageSet_value 140 ExecutionState_name = src.ExecutionState_name 141 ExecutionState_value = src.ExecutionState_value 142 File_google_dataflow_v1beta3_environment_proto = src.File_google_dataflow_v1beta3_environment_proto 143 File_google_dataflow_v1beta3_jobs_proto = src.File_google_dataflow_v1beta3_jobs_proto 144 File_google_dataflow_v1beta3_messages_proto = src.File_google_dataflow_v1beta3_messages_proto 145 File_google_dataflow_v1beta3_metrics_proto = src.File_google_dataflow_v1beta3_metrics_proto 146 File_google_dataflow_v1beta3_snapshots_proto = src.File_google_dataflow_v1beta3_snapshots_proto 147 File_google_dataflow_v1beta3_streaming_proto = src.File_google_dataflow_v1beta3_streaming_proto 148 File_google_dataflow_v1beta3_templates_proto = src.File_google_dataflow_v1beta3_templates_proto 149 FlexResourceSchedulingGoal_name = src.FlexResourceSchedulingGoal_name 150 FlexResourceSchedulingGoal_value = src.FlexResourceSchedulingGoal_value 151 GetTemplateRequest_TemplateView_name = src.GetTemplateRequest_TemplateView_name 152 GetTemplateRequest_TemplateView_value = src.GetTemplateRequest_TemplateView_value 153 GetTemplateResponse_TemplateType_name = src.GetTemplateResponse_TemplateType_name 154 GetTemplateResponse_TemplateType_value = src.GetTemplateResponse_TemplateType_value 155 JobMessageImportance_name = src.JobMessageImportance_name 156 JobMessageImportance_value = src.JobMessageImportance_value 157 JobState_name = src.JobState_name 158 JobState_value = src.JobState_value 159 JobType_name = src.JobType_name 160 JobType_value = src.JobType_value 161 JobView_name = src.JobView_name 162 JobView_value = src.JobView_value 163 KindType_name = src.KindType_name 164 KindType_value = src.KindType_value 165 ListJobsRequest_Filter_name = src.ListJobsRequest_Filter_name 166 ListJobsRequest_Filter_value = src.ListJobsRequest_Filter_value 167 ParameterType_name = src.ParameterType_name 168 ParameterType_value = src.ParameterType_value 169 SDKInfo_Language_name = src.SDKInfo_Language_name 170 SDKInfo_Language_value = src.SDKInfo_Language_value 171 SdkVersion_SdkSupportStatus_name = src.SdkVersion_SdkSupportStatus_name 172 SdkVersion_SdkSupportStatus_value = src.SdkVersion_SdkSupportStatus_value 173 ShuffleMode_name = src.ShuffleMode_name 174 ShuffleMode_value = src.ShuffleMode_value 175 SnapshotState_name = src.SnapshotState_name 176 SnapshotState_value = src.SnapshotState_value 177 TeardownPolicy_name = src.TeardownPolicy_name 178 TeardownPolicy_value = src.TeardownPolicy_value 179 WorkerIPAddressConfiguration_name = src.WorkerIPAddressConfiguration_name 180 WorkerIPAddressConfiguration_value = src.WorkerIPAddressConfiguration_value 181 ) 182 183 // Specifies the algorithm used to determine the number of worker processes to 184 // run at any given point in time, based on the amount of data left to process, 185 // the number of workers, and how quickly existing workers are processing data. 186 // 187 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 188 type AutoscalingAlgorithm = src.AutoscalingAlgorithm 189 190 // A structured message reporting an autoscaling decision made by the Dataflow 191 // service. 192 // 193 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 194 type AutoscalingEvent = src.AutoscalingEvent 195 196 // Indicates the type of autoscaling event. 197 // 198 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 199 type AutoscalingEvent_AutoscalingEventType = src.AutoscalingEvent_AutoscalingEventType 200 201 // Settings for WorkerPool autoscaling. 202 // 203 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 204 type AutoscalingSettings = src.AutoscalingSettings 205 206 // Metadata for a BigQuery connector used by the job. 207 // 208 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 209 type BigQueryIODetails = src.BigQueryIODetails 210 211 // Metadata for a Cloud Bigtable connector used by the job. 212 // 213 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 214 type BigTableIODetails = src.BigTableIODetails 215 216 // Request to check is active jobs exists for a project 217 // 218 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 219 type CheckActiveJobsRequest = src.CheckActiveJobsRequest 220 221 // Response for CheckActiveJobsRequest. 222 // 223 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 224 type CheckActiveJobsResponse = src.CheckActiveJobsResponse 225 226 // All configuration data for a particular Computation. 227 // 228 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 229 type ComputationTopology = src.ComputationTopology 230 231 // Container Spec. 232 // 233 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 234 type ContainerSpec = src.ContainerSpec 235 236 // A request to create a Cloud Dataflow job from a template. 237 // 238 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 239 type CreateJobFromTemplateRequest = src.CreateJobFromTemplateRequest 240 type CreateJobFromTemplateRequest_GcsPath = src.CreateJobFromTemplateRequest_GcsPath 241 242 // Request to create a Cloud Dataflow job. 243 // 244 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 245 type CreateJobRequest = src.CreateJobRequest 246 247 // Identifies the location of a custom souce. 248 // 249 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 250 type CustomSourceLocation = src.CustomSourceLocation 251 252 // Data disk assignment for a given VM instance. 253 // 254 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 255 type DataDiskAssignment = src.DataDiskAssignment 256 257 // Metadata for a Datastore connector used by the job. 258 // 259 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 260 type DatastoreIODetails = src.DatastoreIODetails 261 262 // Describes any options that have an effect on the debugging of pipelines. 263 // 264 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 265 type DebugOptions = src.DebugOptions 266 267 // The default set of packages to be staged on a pool of workers. 268 // 269 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 270 type DefaultPackageSet = src.DefaultPackageSet 271 272 // Request to delete a snapshot. 273 // 274 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 275 type DeleteSnapshotRequest = src.DeleteSnapshotRequest 276 277 // Response from deleting a snapshot. 278 // 279 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 280 type DeleteSnapshotResponse = src.DeleteSnapshotResponse 281 282 // Describes the data disk used by a workflow job. 283 // 284 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 285 type Disk = src.Disk 286 287 // Data provided with a pipeline or transform to provide descriptive info. 288 // 289 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 290 type DisplayData = src.DisplayData 291 type DisplayData_BoolValue = src.DisplayData_BoolValue 292 type DisplayData_DurationValue = src.DisplayData_DurationValue 293 type DisplayData_FloatValue = src.DisplayData_FloatValue 294 type DisplayData_Int64Value = src.DisplayData_Int64Value 295 type DisplayData_JavaClassValue = src.DisplayData_JavaClassValue 296 type DisplayData_StrValue = src.DisplayData_StrValue 297 type DisplayData_TimestampValue = src.DisplayData_TimestampValue 298 299 // Params which should be passed when launching a dynamic template. 300 // 301 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 302 type DynamicTemplateLaunchParams = src.DynamicTemplateLaunchParams 303 304 // Describes the environment in which a Dataflow Job runs. 305 // 306 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 307 type Environment = src.Environment 308 309 // A message describing the state of a particular execution stage. 310 // 311 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 312 type ExecutionStageState = src.ExecutionStageState 313 314 // Description of the composing transforms, names/ids, and input/outputs of a 315 // stage of execution. Some composing transforms and sources may have been 316 // generated by the Dataflow service during execution planning. 317 // 318 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 319 type ExecutionStageSummary = src.ExecutionStageSummary 320 321 // Description of an interstitial value between transforms in an execution 322 // stage. 323 // 324 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 325 type ExecutionStageSummary_ComponentSource = src.ExecutionStageSummary_ComponentSource 326 327 // Description of a transform executed as part of an execution stage. 328 // 329 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 330 type ExecutionStageSummary_ComponentTransform = src.ExecutionStageSummary_ComponentTransform 331 332 // Description of an input or output of an execution stage. 333 // 334 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 335 type ExecutionStageSummary_StageSource = src.ExecutionStageSummary_StageSource 336 337 // The state of some component of job execution. 338 // 339 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 340 type ExecutionState = src.ExecutionState 341 342 // Indicates which [regional endpoint] 343 // (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) failed 344 // to respond to a request for data. 345 // 346 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 347 type FailedLocation = src.FailedLocation 348 349 // Metadata for a File connector used by the job. 350 // 351 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 352 type FileIODetails = src.FileIODetails 353 354 // Specifies the resource to optimize for in Flexible Resource Scheduling. 355 // 356 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 357 type FlexResourceSchedulingGoal = src.FlexResourceSchedulingGoal 358 359 // The environment values to be set at runtime for flex template. 360 // 361 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 362 type FlexTemplateRuntimeEnvironment = src.FlexTemplateRuntimeEnvironment 363 364 // FlexTemplatesServiceClient is the client API for FlexTemplatesService 365 // service. For semantics around ctx use and closing/ending streaming RPCs, 366 // please refer to 367 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 368 // 369 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 370 type FlexTemplatesServiceClient = src.FlexTemplatesServiceClient 371 372 // FlexTemplatesServiceServer is the server API for FlexTemplatesService 373 // service. 374 // 375 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 376 type FlexTemplatesServiceServer = src.FlexTemplatesServiceServer 377 378 // Request to get job execution details. 379 // 380 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 381 type GetJobExecutionDetailsRequest = src.GetJobExecutionDetailsRequest 382 383 // Request to get job metrics. 384 // 385 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 386 type GetJobMetricsRequest = src.GetJobMetricsRequest 387 388 // Request to get the state of a Cloud Dataflow job. 389 // 390 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 391 type GetJobRequest = src.GetJobRequest 392 393 // Request to get information about a snapshot 394 // 395 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 396 type GetSnapshotRequest = src.GetSnapshotRequest 397 398 // Request to get information about a particular execution stage of a job. 399 // Currently only tracked for Batch jobs. 400 // 401 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 402 type GetStageExecutionDetailsRequest = src.GetStageExecutionDetailsRequest 403 404 // A request to retrieve a Cloud Dataflow job template. 405 // 406 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 407 type GetTemplateRequest = src.GetTemplateRequest 408 type GetTemplateRequest_GcsPath = src.GetTemplateRequest_GcsPath 409 410 // The various views of a template that may be retrieved. 411 // 412 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 413 type GetTemplateRequest_TemplateView = src.GetTemplateRequest_TemplateView 414 415 // The response to a GetTemplate request. 416 // 417 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 418 type GetTemplateResponse = src.GetTemplateResponse 419 420 // Template Type. 421 // 422 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 423 type GetTemplateResponse_TemplateType = src.GetTemplateResponse_TemplateType 424 425 // Used in the error_details field of a google.rpc.Status message, this 426 // indicates problems with the template parameter. 427 // 428 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 429 type InvalidTemplateParameters = src.InvalidTemplateParameters 430 431 // A specific template-parameter violation. 432 // 433 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 434 type InvalidTemplateParameters_ParameterViolation = src.InvalidTemplateParameters_ParameterViolation 435 436 // Defines a job to be run by the Cloud Dataflow service. 437 // 438 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 439 type Job = src.Job 440 441 // Information about the execution of a job. 442 // 443 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 444 type JobExecutionDetails = src.JobExecutionDetails 445 446 // Additional information about how a Cloud Dataflow job will be executed that 447 // isn't contained in the submitted job. 448 // 449 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 450 type JobExecutionInfo = src.JobExecutionInfo 451 452 // Contains information about how a particular 453 // [google.dataflow.v1beta3.Step][google.dataflow.v1beta3.Step] will be 454 // executed. 455 // 456 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 457 type JobExecutionStageInfo = src.JobExecutionStageInfo 458 459 // A particular message pertaining to a Dataflow job. 460 // 461 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 462 type JobMessage = src.JobMessage 463 464 // Indicates the importance of the message. 465 // 466 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 467 type JobMessageImportance = src.JobMessageImportance 468 469 // Metadata available primarily for filtering jobs. Will be included in the 470 // ListJob response and Job SUMMARY view. 471 // 472 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 473 type JobMetadata = src.JobMetadata 474 475 // JobMetrics contains a collection of metrics describing the detailed 476 // progress of a Dataflow job. Metrics correspond to user-defined and 477 // system-defined metrics in the job. This resource captures only the most 478 // recent values of each metric; time-series data can be queried for them 479 // (under the same metric names) from Cloud Monitoring. 480 // 481 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 482 type JobMetrics = src.JobMetrics 483 484 // Describes the overall state of a 485 // [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job]. 486 // 487 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 488 type JobState = src.JobState 489 490 // Specifies the processing model used by a [google.dataflow.v1beta3.Job], 491 // which determines the way the Job is managed by the Cloud Dataflow service 492 // (how workers are scheduled, how inputs are sharded, etc). 493 // 494 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 495 type JobType = src.JobType 496 497 // Selector for how much information is returned in Job responses. 498 // 499 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 500 type JobView = src.JobView 501 502 // JobsV1Beta3Client is the client API for JobsV1Beta3 service. For semantics 503 // around ctx use and closing/ending streaming RPCs, please refer to 504 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 505 // 506 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 507 type JobsV1Beta3Client = src.JobsV1Beta3Client 508 509 // JobsV1Beta3Server is the server API for JobsV1Beta3 service. 510 // 511 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 512 type JobsV1Beta3Server = src.JobsV1Beta3Server 513 514 // Data disk assignment information for a specific key-range of a sharded 515 // computation. Currently we only support UTF-8 character splits to simplify 516 // encoding into JSON. 517 // 518 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 519 type KeyRangeDataDiskAssignment = src.KeyRangeDataDiskAssignment 520 521 // Location information for a specific key-range of a sharded computation. 522 // Currently we only support UTF-8 character splits to simplify encoding into 523 // JSON. 524 // 525 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 526 type KeyRangeLocation = src.KeyRangeLocation 527 528 // Type of transform or stage operation. 529 // 530 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 531 type KindType = src.KindType 532 533 // Launch FlexTemplate Parameter. 534 // 535 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 536 type LaunchFlexTemplateParameter = src.LaunchFlexTemplateParameter 537 type LaunchFlexTemplateParameter_ContainerSpec = src.LaunchFlexTemplateParameter_ContainerSpec 538 type LaunchFlexTemplateParameter_ContainerSpecGcsPath = src.LaunchFlexTemplateParameter_ContainerSpecGcsPath 539 540 // A request to launch a Cloud Dataflow job from a FlexTemplate. 541 // 542 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 543 type LaunchFlexTemplateRequest = src.LaunchFlexTemplateRequest 544 545 // Response to the request to launch a job from Flex Template. 546 // 547 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 548 type LaunchFlexTemplateResponse = src.LaunchFlexTemplateResponse 549 550 // Parameters to provide to the template being launched. 551 // 552 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 553 type LaunchTemplateParameters = src.LaunchTemplateParameters 554 555 // A request to launch a template. 556 // 557 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 558 type LaunchTemplateRequest = src.LaunchTemplateRequest 559 type LaunchTemplateRequest_DynamicTemplate = src.LaunchTemplateRequest_DynamicTemplate 560 type LaunchTemplateRequest_GcsPath = src.LaunchTemplateRequest_GcsPath 561 562 // Response to the request to launch a template. 563 // 564 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 565 type LaunchTemplateResponse = src.LaunchTemplateResponse 566 567 // Request to list job messages. Up to max_results messages will be returned 568 // in the time range specified starting with the oldest messages first. If no 569 // time range is specified the results with start with the oldest message. 570 // 571 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 572 type ListJobMessagesRequest = src.ListJobMessagesRequest 573 574 // Response to a request to list job messages. 575 // 576 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 577 type ListJobMessagesResponse = src.ListJobMessagesResponse 578 579 // Request to list Cloud Dataflow jobs. 580 // 581 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 582 type ListJobsRequest = src.ListJobsRequest 583 584 // This field filters out and returns jobs in the specified job state. The 585 // order of data returned is determined by the filter used, and is subject to 586 // change. 587 // 588 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 589 type ListJobsRequest_Filter = src.ListJobsRequest_Filter 590 591 // Response to a request to list Cloud Dataflow jobs in a project. This might 592 // be a partial response, depending on the page size in the ListJobsRequest. 593 // However, if the project does not have any jobs, an instance of 594 // ListJobsResponse is not returned and the requests's response body is empty 595 // {}. 596 // 597 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 598 type ListJobsResponse = src.ListJobsResponse 599 600 // Request to list snapshots. 601 // 602 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 603 type ListSnapshotsRequest = src.ListSnapshotsRequest 604 605 // List of snapshots. 606 // 607 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 608 type ListSnapshotsResponse = src.ListSnapshotsResponse 609 610 // MessagesV1Beta3Client is the client API for MessagesV1Beta3 service. For 611 // semantics around ctx use and closing/ending streaming RPCs, please refer to 612 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 613 // 614 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 615 type MessagesV1Beta3Client = src.MessagesV1Beta3Client 616 617 // MessagesV1Beta3Server is the server API for MessagesV1Beta3 service. 618 // 619 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 620 type MessagesV1Beta3Server = src.MessagesV1Beta3Server 621 622 // Identifies a metric, by describing the source which generated the metric. 623 // 624 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 625 type MetricStructuredName = src.MetricStructuredName 626 627 // Describes the state of a metric. 628 // 629 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 630 type MetricUpdate = src.MetricUpdate 631 632 // MetricsV1Beta3Client is the client API for MetricsV1Beta3 service. For 633 // semantics around ctx use and closing/ending streaming RPCs, please refer to 634 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 635 // 636 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 637 type MetricsV1Beta3Client = src.MetricsV1Beta3Client 638 639 // MetricsV1Beta3Server is the server API for MetricsV1Beta3 service. 640 // 641 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 642 type MetricsV1Beta3Server = src.MetricsV1Beta3Server 643 644 // Describes mounted data disk. 645 // 646 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 647 type MountedDataDisk = src.MountedDataDisk 648 649 // The packages that must be installed in order for a worker to run the steps 650 // of the Cloud Dataflow job that will be assigned to its worker pool. This is 651 // the mechanism by which the Cloud Dataflow SDK causes code to be loaded onto 652 // the workers. For example, the Cloud Dataflow Java SDK might use this to 653 // install jars containing the user's code and all of the various dependencies 654 // (libraries, data files, etc.) required in order for that code to run. 655 // 656 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 657 type Package = src.Package 658 659 // Metadata for a specific parameter. 660 // 661 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 662 type ParameterMetadata = src.ParameterMetadata 663 664 // ParameterType specifies what kind of input we need for this parameter. 665 // 666 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 667 type ParameterType = src.ParameterType 668 669 // A descriptive representation of submitted pipeline as well as the executed 670 // form. This data is provided by the Dataflow service for ease of visualizing 671 // the pipeline and interpreting Dataflow provided metrics. 672 // 673 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 674 type PipelineDescription = src.PipelineDescription 675 676 // Information about the progress of some component of job execution. 677 // 678 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 679 type ProgressTimeseries = src.ProgressTimeseries 680 681 // A point in the timeseries. 682 // 683 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 684 type ProgressTimeseries_Point = src.ProgressTimeseries_Point 685 686 // Metadata for a Pub/Sub connector used by the job. 687 // 688 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 689 type PubSubIODetails = src.PubSubIODetails 690 691 // Identifies a pubsub location to use for transferring data into or out of a 692 // streaming Dataflow job. 693 // 694 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 695 type PubsubLocation = src.PubsubLocation 696 697 // Represents a Pubsub snapshot. 698 // 699 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 700 type PubsubSnapshotMetadata = src.PubsubSnapshotMetadata 701 702 // The environment values to set at runtime. 703 // 704 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 705 type RuntimeEnvironment = src.RuntimeEnvironment 706 707 // RuntimeMetadata describing a runtime environment. 708 // 709 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 710 type RuntimeMetadata = src.RuntimeMetadata 711 712 // SDK Information. 713 // 714 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 715 type SDKInfo = src.SDKInfo 716 717 // SDK Language. 718 // 719 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 720 type SDKInfo_Language = src.SDKInfo_Language 721 722 // Defines a SDK harness container for executing Dataflow pipelines. 723 // 724 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 725 type SdkHarnessContainerImage = src.SdkHarnessContainerImage 726 727 // The version of the SDK used to run the job. 728 // 729 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 730 type SdkVersion = src.SdkVersion 731 732 // The support status of the SDK used to run the job. 733 // 734 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 735 type SdkVersion_SdkSupportStatus = src.SdkVersion_SdkSupportStatus 736 737 // Specifies the shuffle mode used by a [google.dataflow.v1beta3.Job], which 738 // determines the approach data is shuffled during processing. More details in: 739 // https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-shuffle 740 // 741 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 742 type ShuffleMode = src.ShuffleMode 743 744 // Represents a snapshot of a job. 745 // 746 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 747 type Snapshot = src.Snapshot 748 749 // Request to create a snapshot of a job. 750 // 751 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 752 type SnapshotJobRequest = src.SnapshotJobRequest 753 754 // Snapshot state. 755 // 756 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 757 type SnapshotState = src.SnapshotState 758 759 // SnapshotsV1Beta3Client is the client API for SnapshotsV1Beta3 service. For 760 // semantics around ctx use and closing/ending streaming RPCs, please refer to 761 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 762 // 763 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 764 type SnapshotsV1Beta3Client = src.SnapshotsV1Beta3Client 765 766 // SnapshotsV1Beta3Server is the server API for SnapshotsV1Beta3 service. 767 // 768 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 769 type SnapshotsV1Beta3Server = src.SnapshotsV1Beta3Server 770 771 // Metadata for a Spanner connector used by the job. 772 // 773 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 774 type SpannerIODetails = src.SpannerIODetails 775 776 // Information about the workers and work items within a stage. 777 // 778 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 779 type StageExecutionDetails = src.StageExecutionDetails 780 781 // Information about a particular execution stage of a job. 782 // 783 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 784 type StageSummary = src.StageSummary 785 786 // State family configuration. 787 // 788 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 789 type StateFamilyConfig = src.StateFamilyConfig 790 791 // Defines a particular step within a Cloud Dataflow job. A job consists of 792 // multiple steps, each of which performs some specific operation as part of 793 // the overall job. Data is typically passed from one step to another as part 794 // of the job. Here's an example of a sequence of steps which together 795 // implement a Map-Reduce job: - Read a collection of data from some source, 796 // parsing the collection's elements. - Validate the elements. - Apply a 797 // user-defined function to map each element to some value and extract an 798 // element-specific key value. - Group elements with the same key into a single 799 // element with that key, transforming a multiply-keyed collection into a 800 // uniquely-keyed collection. - Write the elements out to some data sink. Note 801 // that the Cloud Dataflow service may be used to run many different types of 802 // jobs, not just Map-Reduce. 803 // 804 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 805 type Step = src.Step 806 807 // Describes a stream of data, either as input to be processed or as output of 808 // a streaming Dataflow job. 809 // 810 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 811 type StreamLocation = src.StreamLocation 812 type StreamLocation_CustomSourceLocation = src.StreamLocation_CustomSourceLocation 813 type StreamLocation_PubsubLocation = src.StreamLocation_PubsubLocation 814 type StreamLocation_SideInputLocation = src.StreamLocation_SideInputLocation 815 type StreamLocation_StreamingStageLocation = src.StreamLocation_StreamingStageLocation 816 817 // Streaming appliance snapshot configuration. 818 // 819 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 820 type StreamingApplianceSnapshotConfig = src.StreamingApplianceSnapshotConfig 821 822 // Describes full or partial data disk assignment information of the 823 // computation ranges. 824 // 825 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 826 type StreamingComputationRanges = src.StreamingComputationRanges 827 828 // Identifies the location of a streaming side input. 829 // 830 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 831 type StreamingSideInputLocation = src.StreamingSideInputLocation 832 833 // Identifies the location of a streaming computation stage, for 834 // stage-to-stage communication. 835 // 836 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 837 type StreamingStageLocation = src.StreamingStageLocation 838 839 // A rich message format, including a human readable string, a key for 840 // identifying the message, and structured data associated with the message for 841 // programmatic consumption. 842 // 843 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 844 type StructuredMessage = src.StructuredMessage 845 846 // Structured data associated with this message. 847 // 848 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 849 type StructuredMessage_Parameter = src.StructuredMessage_Parameter 850 851 // Taskrunner configuration settings. 852 // 853 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 854 type TaskRunnerSettings = src.TaskRunnerSettings 855 856 // Specifies what happens to a resource when a Cloud Dataflow 857 // [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job] has completed. 858 // 859 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 860 type TeardownPolicy = src.TeardownPolicy 861 862 // Metadata describing a template. 863 // 864 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 865 type TemplateMetadata = src.TemplateMetadata 866 867 // TemplatesServiceClient is the client API for TemplatesService service. For 868 // semantics around ctx use and closing/ending streaming RPCs, please refer to 869 // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 870 // 871 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 872 type TemplatesServiceClient = src.TemplatesServiceClient 873 874 // TemplatesServiceServer is the server API for TemplatesService service. 875 // 876 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 877 type TemplatesServiceServer = src.TemplatesServiceServer 878 879 // Global topology of the streaming Dataflow job, including all computations 880 // and their sharded locations. 881 // 882 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 883 type TopologyConfig = src.TopologyConfig 884 885 // Description of the type, names/ids, and input/outputs for a transform. 886 // 887 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 888 type TransformSummary = src.TransformSummary 889 890 // UnimplementedFlexTemplatesServiceServer can be embedded to have forward 891 // compatible implementations. 892 // 893 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 894 type UnimplementedFlexTemplatesServiceServer = src.UnimplementedFlexTemplatesServiceServer 895 896 // UnimplementedJobsV1Beta3Server can be embedded to have forward compatible 897 // implementations. 898 // 899 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 900 type UnimplementedJobsV1Beta3Server = src.UnimplementedJobsV1Beta3Server 901 902 // UnimplementedMessagesV1Beta3Server can be embedded to have forward 903 // compatible implementations. 904 // 905 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 906 type UnimplementedMessagesV1Beta3Server = src.UnimplementedMessagesV1Beta3Server 907 908 // UnimplementedMetricsV1Beta3Server can be embedded to have forward 909 // compatible implementations. 910 // 911 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 912 type UnimplementedMetricsV1Beta3Server = src.UnimplementedMetricsV1Beta3Server 913 914 // UnimplementedSnapshotsV1Beta3Server can be embedded to have forward 915 // compatible implementations. 916 // 917 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 918 type UnimplementedSnapshotsV1Beta3Server = src.UnimplementedSnapshotsV1Beta3Server 919 920 // UnimplementedTemplatesServiceServer can be embedded to have forward 921 // compatible implementations. 922 // 923 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 924 type UnimplementedTemplatesServiceServer = src.UnimplementedTemplatesServiceServer 925 926 // Request to update a Cloud Dataflow job. 927 // 928 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 929 type UpdateJobRequest = src.UpdateJobRequest 930 931 // Information about an individual work item execution. 932 // 933 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 934 type WorkItemDetails = src.WorkItemDetails 935 936 // Information about a worker 937 // 938 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 939 type WorkerDetails = src.WorkerDetails 940 941 // Specifies how IP addresses should be allocated to the worker machines. 942 // 943 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 944 type WorkerIPAddressConfiguration = src.WorkerIPAddressConfiguration 945 946 // Describes one particular pool of Cloud Dataflow workers to be instantiated 947 // by the Cloud Dataflow service in order to perform the computations required 948 // by a job. Note that a workflow job may use multiple pools, in order to match 949 // the various computational requirements of the various stages of the job. 950 // 951 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 952 type WorkerPool = src.WorkerPool 953 954 // Provides data to pass through to the worker harness. 955 // 956 // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 957 type WorkerSettings = src.WorkerSettings 958 959 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 960 func NewFlexTemplatesServiceClient(cc grpc.ClientConnInterface) FlexTemplatesServiceClient { 961 return src.NewFlexTemplatesServiceClient(cc) 962 } 963 964 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 965 func NewJobsV1Beta3Client(cc grpc.ClientConnInterface) JobsV1Beta3Client { 966 return src.NewJobsV1Beta3Client(cc) 967 } 968 969 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 970 func NewMessagesV1Beta3Client(cc grpc.ClientConnInterface) MessagesV1Beta3Client { 971 return src.NewMessagesV1Beta3Client(cc) 972 } 973 974 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 975 func NewMetricsV1Beta3Client(cc grpc.ClientConnInterface) MetricsV1Beta3Client { 976 return src.NewMetricsV1Beta3Client(cc) 977 } 978 979 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 980 func NewSnapshotsV1Beta3Client(cc grpc.ClientConnInterface) SnapshotsV1Beta3Client { 981 return src.NewSnapshotsV1Beta3Client(cc) 982 } 983 984 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 985 func NewTemplatesServiceClient(cc grpc.ClientConnInterface) TemplatesServiceClient { 986 return src.NewTemplatesServiceClient(cc) 987 } 988 989 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 990 func RegisterFlexTemplatesServiceServer(s *grpc.Server, srv FlexTemplatesServiceServer) { 991 src.RegisterFlexTemplatesServiceServer(s, srv) 992 } 993 994 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 995 func RegisterJobsV1Beta3Server(s *grpc.Server, srv JobsV1Beta3Server) { 996 src.RegisterJobsV1Beta3Server(s, srv) 997 } 998 999 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 1000 func RegisterMessagesV1Beta3Server(s *grpc.Server, srv MessagesV1Beta3Server) { 1001 src.RegisterMessagesV1Beta3Server(s, srv) 1002 } 1003 1004 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 1005 func RegisterMetricsV1Beta3Server(s *grpc.Server, srv MetricsV1Beta3Server) { 1006 src.RegisterMetricsV1Beta3Server(s, srv) 1007 } 1008 1009 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 1010 func RegisterSnapshotsV1Beta3Server(s *grpc.Server, srv SnapshotsV1Beta3Server) { 1011 src.RegisterSnapshotsV1Beta3Server(s, srv) 1012 } 1013 1014 // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb 1015 func RegisterTemplatesServiceServer(s *grpc.Server, srv TemplatesServiceServer) { 1016 src.RegisterTemplatesServiceServer(s, srv) 1017 } 1018