// Copyright 2022 Google LLC // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // Code generated by aliasgen. DO NOT EDIT. // Package dataflow aliases all exported identifiers in package // "cloud.google.com/go/dataflow/apiv1beta3/dataflowpb". // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb. // Please read https://github.com/googleapis/google-cloud-go/blob/main/migration.md // for more details. package dataflow import ( src "cloud.google.com/go/dataflow/apiv1beta3/dataflowpb" grpc "google.golang.org/grpc" ) // Deprecated: Please use consts in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb const ( AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN AutoscalingEvent_ACTUATION_FAILURE = src.AutoscalingEvent_ACTUATION_FAILURE AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED = src.AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED AutoscalingEvent_NO_CHANGE = src.AutoscalingEvent_NO_CHANGE AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED = src.AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED AutoscalingEvent_TYPE_UNKNOWN = src.AutoscalingEvent_TYPE_UNKNOWN DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN ExecutionState_EXECUTION_STATE_CANCELLED = src.ExecutionState_EXECUTION_STATE_CANCELLED ExecutionState_EXECUTION_STATE_FAILED = src.ExecutionState_EXECUTION_STATE_FAILED ExecutionState_EXECUTION_STATE_NOT_STARTED = src.ExecutionState_EXECUTION_STATE_NOT_STARTED ExecutionState_EXECUTION_STATE_RUNNING = src.ExecutionState_EXECUTION_STATE_RUNNING ExecutionState_EXECUTION_STATE_SUCCEEDED = src.ExecutionState_EXECUTION_STATE_SUCCEEDED ExecutionState_EXECUTION_STATE_UNKNOWN = src.ExecutionState_EXECUTION_STATE_UNKNOWN FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED = src.FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED = src.FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED = src.FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED GetTemplateRequest_METADATA_ONLY = src.GetTemplateRequest_METADATA_ONLY GetTemplateResponse_FLEX = src.GetTemplateResponse_FLEX GetTemplateResponse_LEGACY = src.GetTemplateResponse_LEGACY GetTemplateResponse_UNKNOWN = src.GetTemplateResponse_UNKNOWN JobMessageImportance_JOB_MESSAGE_BASIC = src.JobMessageImportance_JOB_MESSAGE_BASIC JobMessageImportance_JOB_MESSAGE_DEBUG = src.JobMessageImportance_JOB_MESSAGE_DEBUG JobMessageImportance_JOB_MESSAGE_DETAILED = src.JobMessageImportance_JOB_MESSAGE_DETAILED JobMessageImportance_JOB_MESSAGE_ERROR = src.JobMessageImportance_JOB_MESSAGE_ERROR JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN = src.JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN JobMessageImportance_JOB_MESSAGE_WARNING = src.JobMessageImportance_JOB_MESSAGE_WARNING JobState_JOB_STATE_CANCELLED = src.JobState_JOB_STATE_CANCELLED JobState_JOB_STATE_CANCELLING = src.JobState_JOB_STATE_CANCELLING JobState_JOB_STATE_DONE = src.JobState_JOB_STATE_DONE JobState_JOB_STATE_DRAINED = src.JobState_JOB_STATE_DRAINED JobState_JOB_STATE_DRAINING = src.JobState_JOB_STATE_DRAINING JobState_JOB_STATE_FAILED = src.JobState_JOB_STATE_FAILED JobState_JOB_STATE_PENDING = src.JobState_JOB_STATE_PENDING JobState_JOB_STATE_QUEUED = src.JobState_JOB_STATE_QUEUED JobState_JOB_STATE_RESOURCE_CLEANING_UP = src.JobState_JOB_STATE_RESOURCE_CLEANING_UP JobState_JOB_STATE_RUNNING = src.JobState_JOB_STATE_RUNNING JobState_JOB_STATE_STOPPED = src.JobState_JOB_STATE_STOPPED JobState_JOB_STATE_UNKNOWN = src.JobState_JOB_STATE_UNKNOWN JobState_JOB_STATE_UPDATED = src.JobState_JOB_STATE_UPDATED JobType_JOB_TYPE_BATCH = src.JobType_JOB_TYPE_BATCH JobType_JOB_TYPE_STREAMING = src.JobType_JOB_TYPE_STREAMING JobType_JOB_TYPE_UNKNOWN = src.JobType_JOB_TYPE_UNKNOWN JobView_JOB_VIEW_ALL = src.JobView_JOB_VIEW_ALL JobView_JOB_VIEW_DESCRIPTION = src.JobView_JOB_VIEW_DESCRIPTION JobView_JOB_VIEW_SUMMARY = src.JobView_JOB_VIEW_SUMMARY JobView_JOB_VIEW_UNKNOWN = src.JobView_JOB_VIEW_UNKNOWN KindType_CONSTANT_KIND = src.KindType_CONSTANT_KIND KindType_FLATTEN_KIND = src.KindType_FLATTEN_KIND KindType_GROUP_BY_KEY_KIND = src.KindType_GROUP_BY_KEY_KIND KindType_PAR_DO_KIND = src.KindType_PAR_DO_KIND KindType_READ_KIND = src.KindType_READ_KIND KindType_SHUFFLE_KIND = src.KindType_SHUFFLE_KIND KindType_SINGLETON_KIND = src.KindType_SINGLETON_KIND KindType_UNKNOWN_KIND = src.KindType_UNKNOWN_KIND KindType_WRITE_KIND = src.KindType_WRITE_KIND ListJobsRequest_ACTIVE = src.ListJobsRequest_ACTIVE ListJobsRequest_ALL = src.ListJobsRequest_ALL ListJobsRequest_TERMINATED = src.ListJobsRequest_TERMINATED ListJobsRequest_UNKNOWN = src.ListJobsRequest_UNKNOWN ParameterType_DEFAULT = src.ParameterType_DEFAULT ParameterType_GCS_READ_BUCKET = src.ParameterType_GCS_READ_BUCKET ParameterType_GCS_READ_FILE = src.ParameterType_GCS_READ_FILE ParameterType_GCS_READ_FOLDER = src.ParameterType_GCS_READ_FOLDER ParameterType_GCS_WRITE_BUCKET = src.ParameterType_GCS_WRITE_BUCKET ParameterType_GCS_WRITE_FILE = src.ParameterType_GCS_WRITE_FILE ParameterType_GCS_WRITE_FOLDER = src.ParameterType_GCS_WRITE_FOLDER ParameterType_PUBSUB_SUBSCRIPTION = src.ParameterType_PUBSUB_SUBSCRIPTION ParameterType_PUBSUB_TOPIC = src.ParameterType_PUBSUB_TOPIC ParameterType_TEXT = src.ParameterType_TEXT SDKInfo_JAVA = src.SDKInfo_JAVA SDKInfo_PYTHON = src.SDKInfo_PYTHON SDKInfo_UNKNOWN = src.SDKInfo_UNKNOWN SdkVersion_DEPRECATED = src.SdkVersion_DEPRECATED SdkVersion_STALE = src.SdkVersion_STALE SdkVersion_SUPPORTED = src.SdkVersion_SUPPORTED SdkVersion_UNKNOWN = src.SdkVersion_UNKNOWN SdkVersion_UNSUPPORTED = src.SdkVersion_UNSUPPORTED ShuffleMode_SERVICE_BASED = src.ShuffleMode_SERVICE_BASED ShuffleMode_SHUFFLE_MODE_UNSPECIFIED = src.ShuffleMode_SHUFFLE_MODE_UNSPECIFIED ShuffleMode_VM_BASED = src.ShuffleMode_VM_BASED SnapshotState_DELETED = src.SnapshotState_DELETED SnapshotState_FAILED = src.SnapshotState_FAILED SnapshotState_PENDING = src.SnapshotState_PENDING SnapshotState_READY = src.SnapshotState_READY SnapshotState_RUNNING = src.SnapshotState_RUNNING SnapshotState_UNKNOWN_SNAPSHOT_STATE = src.SnapshotState_UNKNOWN_SNAPSHOT_STATE TeardownPolicy_TEARDOWN_ALWAYS = src.TeardownPolicy_TEARDOWN_ALWAYS TeardownPolicy_TEARDOWN_NEVER = src.TeardownPolicy_TEARDOWN_NEVER TeardownPolicy_TEARDOWN_ON_SUCCESS = src.TeardownPolicy_TEARDOWN_ON_SUCCESS TeardownPolicy_TEARDOWN_POLICY_UNKNOWN = src.TeardownPolicy_TEARDOWN_POLICY_UNKNOWN WorkerIPAddressConfiguration_WORKER_IP_PRIVATE = src.WorkerIPAddressConfiguration_WORKER_IP_PRIVATE WorkerIPAddressConfiguration_WORKER_IP_PUBLIC = src.WorkerIPAddressConfiguration_WORKER_IP_PUBLIC WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED = src.WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED ) // Deprecated: Please use vars in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb var ( AutoscalingAlgorithm_name = src.AutoscalingAlgorithm_name AutoscalingAlgorithm_value = src.AutoscalingAlgorithm_value AutoscalingEvent_AutoscalingEventType_name = src.AutoscalingEvent_AutoscalingEventType_name AutoscalingEvent_AutoscalingEventType_value = src.AutoscalingEvent_AutoscalingEventType_value DefaultPackageSet_name = src.DefaultPackageSet_name DefaultPackageSet_value = src.DefaultPackageSet_value ExecutionState_name = src.ExecutionState_name ExecutionState_value = src.ExecutionState_value File_google_dataflow_v1beta3_environment_proto = src.File_google_dataflow_v1beta3_environment_proto File_google_dataflow_v1beta3_jobs_proto = src.File_google_dataflow_v1beta3_jobs_proto File_google_dataflow_v1beta3_messages_proto = src.File_google_dataflow_v1beta3_messages_proto File_google_dataflow_v1beta3_metrics_proto = src.File_google_dataflow_v1beta3_metrics_proto File_google_dataflow_v1beta3_snapshots_proto = src.File_google_dataflow_v1beta3_snapshots_proto File_google_dataflow_v1beta3_streaming_proto = src.File_google_dataflow_v1beta3_streaming_proto File_google_dataflow_v1beta3_templates_proto = src.File_google_dataflow_v1beta3_templates_proto FlexResourceSchedulingGoal_name = src.FlexResourceSchedulingGoal_name FlexResourceSchedulingGoal_value = src.FlexResourceSchedulingGoal_value GetTemplateRequest_TemplateView_name = src.GetTemplateRequest_TemplateView_name GetTemplateRequest_TemplateView_value = src.GetTemplateRequest_TemplateView_value GetTemplateResponse_TemplateType_name = src.GetTemplateResponse_TemplateType_name GetTemplateResponse_TemplateType_value = src.GetTemplateResponse_TemplateType_value JobMessageImportance_name = src.JobMessageImportance_name JobMessageImportance_value = src.JobMessageImportance_value JobState_name = src.JobState_name JobState_value = src.JobState_value JobType_name = src.JobType_name JobType_value = src.JobType_value JobView_name = src.JobView_name JobView_value = src.JobView_value KindType_name = src.KindType_name KindType_value = src.KindType_value ListJobsRequest_Filter_name = src.ListJobsRequest_Filter_name ListJobsRequest_Filter_value = src.ListJobsRequest_Filter_value ParameterType_name = src.ParameterType_name ParameterType_value = src.ParameterType_value SDKInfo_Language_name = src.SDKInfo_Language_name SDKInfo_Language_value = src.SDKInfo_Language_value SdkVersion_SdkSupportStatus_name = src.SdkVersion_SdkSupportStatus_name SdkVersion_SdkSupportStatus_value = src.SdkVersion_SdkSupportStatus_value ShuffleMode_name = src.ShuffleMode_name ShuffleMode_value = src.ShuffleMode_value SnapshotState_name = src.SnapshotState_name SnapshotState_value = src.SnapshotState_value TeardownPolicy_name = src.TeardownPolicy_name TeardownPolicy_value = src.TeardownPolicy_value WorkerIPAddressConfiguration_name = src.WorkerIPAddressConfiguration_name WorkerIPAddressConfiguration_value = src.WorkerIPAddressConfiguration_value ) // Specifies the algorithm used to determine the number of worker processes to // run at any given point in time, based on the amount of data left to process, // the number of workers, and how quickly existing workers are processing data. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type AutoscalingAlgorithm = src.AutoscalingAlgorithm // A structured message reporting an autoscaling decision made by the Dataflow // service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type AutoscalingEvent = src.AutoscalingEvent // Indicates the type of autoscaling event. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type AutoscalingEvent_AutoscalingEventType = src.AutoscalingEvent_AutoscalingEventType // Settings for WorkerPool autoscaling. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type AutoscalingSettings = src.AutoscalingSettings // Metadata for a BigQuery connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type BigQueryIODetails = src.BigQueryIODetails // Metadata for a Cloud Bigtable connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type BigTableIODetails = src.BigTableIODetails // Request to check is active jobs exists for a project // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type CheckActiveJobsRequest = src.CheckActiveJobsRequest // Response for CheckActiveJobsRequest. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type CheckActiveJobsResponse = src.CheckActiveJobsResponse // All configuration data for a particular Computation. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ComputationTopology = src.ComputationTopology // Container Spec. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ContainerSpec = src.ContainerSpec // A request to create a Cloud Dataflow job from a template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type CreateJobFromTemplateRequest = src.CreateJobFromTemplateRequest type CreateJobFromTemplateRequest_GcsPath = src.CreateJobFromTemplateRequest_GcsPath // Request to create a Cloud Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type CreateJobRequest = src.CreateJobRequest // Identifies the location of a custom souce. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type CustomSourceLocation = src.CustomSourceLocation // Data disk assignment for a given VM instance. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DataDiskAssignment = src.DataDiskAssignment // Metadata for a Datastore connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DatastoreIODetails = src.DatastoreIODetails // Describes any options that have an effect on the debugging of pipelines. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DebugOptions = src.DebugOptions // The default set of packages to be staged on a pool of workers. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DefaultPackageSet = src.DefaultPackageSet // Request to delete a snapshot. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DeleteSnapshotRequest = src.DeleteSnapshotRequest // Response from deleting a snapshot. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DeleteSnapshotResponse = src.DeleteSnapshotResponse // Describes the data disk used by a workflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Disk = src.Disk // Data provided with a pipeline or transform to provide descriptive info. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DisplayData = src.DisplayData type DisplayData_BoolValue = src.DisplayData_BoolValue type DisplayData_DurationValue = src.DisplayData_DurationValue type DisplayData_FloatValue = src.DisplayData_FloatValue type DisplayData_Int64Value = src.DisplayData_Int64Value type DisplayData_JavaClassValue = src.DisplayData_JavaClassValue type DisplayData_StrValue = src.DisplayData_StrValue type DisplayData_TimestampValue = src.DisplayData_TimestampValue // Params which should be passed when launching a dynamic template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type DynamicTemplateLaunchParams = src.DynamicTemplateLaunchParams // Describes the environment in which a Dataflow Job runs. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Environment = src.Environment // A message describing the state of a particular execution stage. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionStageState = src.ExecutionStageState // Description of the composing transforms, names/ids, and input/outputs of a // stage of execution. Some composing transforms and sources may have been // generated by the Dataflow service during execution planning. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionStageSummary = src.ExecutionStageSummary // Description of an interstitial value between transforms in an execution // stage. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionStageSummary_ComponentSource = src.ExecutionStageSummary_ComponentSource // Description of a transform executed as part of an execution stage. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionStageSummary_ComponentTransform = src.ExecutionStageSummary_ComponentTransform // Description of an input or output of an execution stage. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionStageSummary_StageSource = src.ExecutionStageSummary_StageSource // The state of some component of job execution. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ExecutionState = src.ExecutionState // Indicates which [regional endpoint] // (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) failed // to respond to a request for data. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FailedLocation = src.FailedLocation // Metadata for a File connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FileIODetails = src.FileIODetails // Specifies the resource to optimize for in Flexible Resource Scheduling. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FlexResourceSchedulingGoal = src.FlexResourceSchedulingGoal // The environment values to be set at runtime for flex template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FlexTemplateRuntimeEnvironment = src.FlexTemplateRuntimeEnvironment // FlexTemplatesServiceClient is the client API for FlexTemplatesService // service. For semantics around ctx use and closing/ending streaming RPCs, // please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FlexTemplatesServiceClient = src.FlexTemplatesServiceClient // FlexTemplatesServiceServer is the server API for FlexTemplatesService // service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type FlexTemplatesServiceServer = src.FlexTemplatesServiceServer // Request to get job execution details. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetJobExecutionDetailsRequest = src.GetJobExecutionDetailsRequest // Request to get job metrics. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetJobMetricsRequest = src.GetJobMetricsRequest // Request to get the state of a Cloud Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetJobRequest = src.GetJobRequest // Request to get information about a snapshot // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetSnapshotRequest = src.GetSnapshotRequest // Request to get information about a particular execution stage of a job. // Currently only tracked for Batch jobs. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetStageExecutionDetailsRequest = src.GetStageExecutionDetailsRequest // A request to retrieve a Cloud Dataflow job template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetTemplateRequest = src.GetTemplateRequest type GetTemplateRequest_GcsPath = src.GetTemplateRequest_GcsPath // The various views of a template that may be retrieved. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetTemplateRequest_TemplateView = src.GetTemplateRequest_TemplateView // The response to a GetTemplate request. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetTemplateResponse = src.GetTemplateResponse // Template Type. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type GetTemplateResponse_TemplateType = src.GetTemplateResponse_TemplateType // Used in the error_details field of a google.rpc.Status message, this // indicates problems with the template parameter. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type InvalidTemplateParameters = src.InvalidTemplateParameters // A specific template-parameter violation. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type InvalidTemplateParameters_ParameterViolation = src.InvalidTemplateParameters_ParameterViolation // Defines a job to be run by the Cloud Dataflow service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Job = src.Job // Information about the execution of a job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobExecutionDetails = src.JobExecutionDetails // Additional information about how a Cloud Dataflow job will be executed that // isn't contained in the submitted job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobExecutionInfo = src.JobExecutionInfo // Contains information about how a particular // [google.dataflow.v1beta3.Step][google.dataflow.v1beta3.Step] will be // executed. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobExecutionStageInfo = src.JobExecutionStageInfo // A particular message pertaining to a Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobMessage = src.JobMessage // Indicates the importance of the message. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobMessageImportance = src.JobMessageImportance // Metadata available primarily for filtering jobs. Will be included in the // ListJob response and Job SUMMARY view. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobMetadata = src.JobMetadata // JobMetrics contains a collection of metrics describing the detailed // progress of a Dataflow job. Metrics correspond to user-defined and // system-defined metrics in the job. This resource captures only the most // recent values of each metric; time-series data can be queried for them // (under the same metric names) from Cloud Monitoring. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobMetrics = src.JobMetrics // Describes the overall state of a // [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job]. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobState = src.JobState // Specifies the processing model used by a [google.dataflow.v1beta3.Job], // which determines the way the Job is managed by the Cloud Dataflow service // (how workers are scheduled, how inputs are sharded, etc). // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobType = src.JobType // Selector for how much information is returned in Job responses. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobView = src.JobView // JobsV1Beta3Client is the client API for JobsV1Beta3 service. For semantics // around ctx use and closing/ending streaming RPCs, please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobsV1Beta3Client = src.JobsV1Beta3Client // JobsV1Beta3Server is the server API for JobsV1Beta3 service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type JobsV1Beta3Server = src.JobsV1Beta3Server // Data disk assignment information for a specific key-range of a sharded // computation. Currently we only support UTF-8 character splits to simplify // encoding into JSON. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type KeyRangeDataDiskAssignment = src.KeyRangeDataDiskAssignment // Location information for a specific key-range of a sharded computation. // Currently we only support UTF-8 character splits to simplify encoding into // JSON. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type KeyRangeLocation = src.KeyRangeLocation // Type of transform or stage operation. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type KindType = src.KindType // Launch FlexTemplate Parameter. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchFlexTemplateParameter = src.LaunchFlexTemplateParameter type LaunchFlexTemplateParameter_ContainerSpec = src.LaunchFlexTemplateParameter_ContainerSpec type LaunchFlexTemplateParameter_ContainerSpecGcsPath = src.LaunchFlexTemplateParameter_ContainerSpecGcsPath // A request to launch a Cloud Dataflow job from a FlexTemplate. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchFlexTemplateRequest = src.LaunchFlexTemplateRequest // Response to the request to launch a job from Flex Template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchFlexTemplateResponse = src.LaunchFlexTemplateResponse // Parameters to provide to the template being launched. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchTemplateParameters = src.LaunchTemplateParameters // A request to launch a template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchTemplateRequest = src.LaunchTemplateRequest type LaunchTemplateRequest_DynamicTemplate = src.LaunchTemplateRequest_DynamicTemplate type LaunchTemplateRequest_GcsPath = src.LaunchTemplateRequest_GcsPath // Response to the request to launch a template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type LaunchTemplateResponse = src.LaunchTemplateResponse // Request to list job messages. Up to max_results messages will be returned // in the time range specified starting with the oldest messages first. If no // time range is specified the results with start with the oldest message. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListJobMessagesRequest = src.ListJobMessagesRequest // Response to a request to list job messages. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListJobMessagesResponse = src.ListJobMessagesResponse // Request to list Cloud Dataflow jobs. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListJobsRequest = src.ListJobsRequest // This field filters out and returns jobs in the specified job state. The // order of data returned is determined by the filter used, and is subject to // change. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListJobsRequest_Filter = src.ListJobsRequest_Filter // Response to a request to list Cloud Dataflow jobs in a project. This might // be a partial response, depending on the page size in the ListJobsRequest. // However, if the project does not have any jobs, an instance of // ListJobsResponse is not returned and the requests's response body is empty // {}. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListJobsResponse = src.ListJobsResponse // Request to list snapshots. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListSnapshotsRequest = src.ListSnapshotsRequest // List of snapshots. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ListSnapshotsResponse = src.ListSnapshotsResponse // MessagesV1Beta3Client is the client API for MessagesV1Beta3 service. For // semantics around ctx use and closing/ending streaming RPCs, please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MessagesV1Beta3Client = src.MessagesV1Beta3Client // MessagesV1Beta3Server is the server API for MessagesV1Beta3 service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MessagesV1Beta3Server = src.MessagesV1Beta3Server // Identifies a metric, by describing the source which generated the metric. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MetricStructuredName = src.MetricStructuredName // Describes the state of a metric. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MetricUpdate = src.MetricUpdate // MetricsV1Beta3Client is the client API for MetricsV1Beta3 service. For // semantics around ctx use and closing/ending streaming RPCs, please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MetricsV1Beta3Client = src.MetricsV1Beta3Client // MetricsV1Beta3Server is the server API for MetricsV1Beta3 service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MetricsV1Beta3Server = src.MetricsV1Beta3Server // Describes mounted data disk. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type MountedDataDisk = src.MountedDataDisk // The packages that must be installed in order for a worker to run the steps // of the Cloud Dataflow job that will be assigned to its worker pool. This is // the mechanism by which the Cloud Dataflow SDK causes code to be loaded onto // the workers. For example, the Cloud Dataflow Java SDK might use this to // install jars containing the user's code and all of the various dependencies // (libraries, data files, etc.) required in order for that code to run. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Package = src.Package // Metadata for a specific parameter. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ParameterMetadata = src.ParameterMetadata // ParameterType specifies what kind of input we need for this parameter. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ParameterType = src.ParameterType // A descriptive representation of submitted pipeline as well as the executed // form. This data is provided by the Dataflow service for ease of visualizing // the pipeline and interpreting Dataflow provided metrics. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type PipelineDescription = src.PipelineDescription // Information about the progress of some component of job execution. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ProgressTimeseries = src.ProgressTimeseries // A point in the timeseries. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ProgressTimeseries_Point = src.ProgressTimeseries_Point // Metadata for a Pub/Sub connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type PubSubIODetails = src.PubSubIODetails // Identifies a pubsub location to use for transferring data into or out of a // streaming Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type PubsubLocation = src.PubsubLocation // Represents a Pubsub snapshot. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type PubsubSnapshotMetadata = src.PubsubSnapshotMetadata // The environment values to set at runtime. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type RuntimeEnvironment = src.RuntimeEnvironment // RuntimeMetadata describing a runtime environment. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type RuntimeMetadata = src.RuntimeMetadata // SDK Information. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SDKInfo = src.SDKInfo // SDK Language. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SDKInfo_Language = src.SDKInfo_Language // Defines a SDK harness container for executing Dataflow pipelines. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SdkHarnessContainerImage = src.SdkHarnessContainerImage // The version of the SDK used to run the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SdkVersion = src.SdkVersion // The support status of the SDK used to run the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SdkVersion_SdkSupportStatus = src.SdkVersion_SdkSupportStatus // Specifies the shuffle mode used by a [google.dataflow.v1beta3.Job], which // determines the approach data is shuffled during processing. More details in: // https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-shuffle // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type ShuffleMode = src.ShuffleMode // Represents a snapshot of a job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Snapshot = src.Snapshot // Request to create a snapshot of a job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SnapshotJobRequest = src.SnapshotJobRequest // Snapshot state. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SnapshotState = src.SnapshotState // SnapshotsV1Beta3Client is the client API for SnapshotsV1Beta3 service. For // semantics around ctx use and closing/ending streaming RPCs, please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SnapshotsV1Beta3Client = src.SnapshotsV1Beta3Client // SnapshotsV1Beta3Server is the server API for SnapshotsV1Beta3 service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SnapshotsV1Beta3Server = src.SnapshotsV1Beta3Server // Metadata for a Spanner connector used by the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type SpannerIODetails = src.SpannerIODetails // Information about the workers and work items within a stage. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StageExecutionDetails = src.StageExecutionDetails // Information about a particular execution stage of a job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StageSummary = src.StageSummary // State family configuration. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StateFamilyConfig = src.StateFamilyConfig // Defines a particular step within a Cloud Dataflow job. A job consists of // multiple steps, each of which performs some specific operation as part of // the overall job. Data is typically passed from one step to another as part // of the job. Here's an example of a sequence of steps which together // implement a Map-Reduce job: - Read a collection of data from some source, // parsing the collection's elements. - Validate the elements. - Apply a // user-defined function to map each element to some value and extract an // element-specific key value. - Group elements with the same key into a single // element with that key, transforming a multiply-keyed collection into a // uniquely-keyed collection. - Write the elements out to some data sink. Note // that the Cloud Dataflow service may be used to run many different types of // jobs, not just Map-Reduce. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type Step = src.Step // Describes a stream of data, either as input to be processed or as output of // a streaming Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StreamLocation = src.StreamLocation type StreamLocation_CustomSourceLocation = src.StreamLocation_CustomSourceLocation type StreamLocation_PubsubLocation = src.StreamLocation_PubsubLocation type StreamLocation_SideInputLocation = src.StreamLocation_SideInputLocation type StreamLocation_StreamingStageLocation = src.StreamLocation_StreamingStageLocation // Streaming appliance snapshot configuration. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StreamingApplianceSnapshotConfig = src.StreamingApplianceSnapshotConfig // Describes full or partial data disk assignment information of the // computation ranges. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StreamingComputationRanges = src.StreamingComputationRanges // Identifies the location of a streaming side input. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StreamingSideInputLocation = src.StreamingSideInputLocation // Identifies the location of a streaming computation stage, for // stage-to-stage communication. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StreamingStageLocation = src.StreamingStageLocation // A rich message format, including a human readable string, a key for // identifying the message, and structured data associated with the message for // programmatic consumption. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StructuredMessage = src.StructuredMessage // Structured data associated with this message. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type StructuredMessage_Parameter = src.StructuredMessage_Parameter // Taskrunner configuration settings. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TaskRunnerSettings = src.TaskRunnerSettings // Specifies what happens to a resource when a Cloud Dataflow // [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job] has completed. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TeardownPolicy = src.TeardownPolicy // Metadata describing a template. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TemplateMetadata = src.TemplateMetadata // TemplatesServiceClient is the client API for TemplatesService service. For // semantics around ctx use and closing/ending streaming RPCs, please refer to // https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TemplatesServiceClient = src.TemplatesServiceClient // TemplatesServiceServer is the server API for TemplatesService service. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TemplatesServiceServer = src.TemplatesServiceServer // Global topology of the streaming Dataflow job, including all computations // and their sharded locations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TopologyConfig = src.TopologyConfig // Description of the type, names/ids, and input/outputs for a transform. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type TransformSummary = src.TransformSummary // UnimplementedFlexTemplatesServiceServer can be embedded to have forward // compatible implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedFlexTemplatesServiceServer = src.UnimplementedFlexTemplatesServiceServer // UnimplementedJobsV1Beta3Server can be embedded to have forward compatible // implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedJobsV1Beta3Server = src.UnimplementedJobsV1Beta3Server // UnimplementedMessagesV1Beta3Server can be embedded to have forward // compatible implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedMessagesV1Beta3Server = src.UnimplementedMessagesV1Beta3Server // UnimplementedMetricsV1Beta3Server can be embedded to have forward // compatible implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedMetricsV1Beta3Server = src.UnimplementedMetricsV1Beta3Server // UnimplementedSnapshotsV1Beta3Server can be embedded to have forward // compatible implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedSnapshotsV1Beta3Server = src.UnimplementedSnapshotsV1Beta3Server // UnimplementedTemplatesServiceServer can be embedded to have forward // compatible implementations. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UnimplementedTemplatesServiceServer = src.UnimplementedTemplatesServiceServer // Request to update a Cloud Dataflow job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type UpdateJobRequest = src.UpdateJobRequest // Information about an individual work item execution. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type WorkItemDetails = src.WorkItemDetails // Information about a worker // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type WorkerDetails = src.WorkerDetails // Specifies how IP addresses should be allocated to the worker machines. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type WorkerIPAddressConfiguration = src.WorkerIPAddressConfiguration // Describes one particular pool of Cloud Dataflow workers to be instantiated // by the Cloud Dataflow service in order to perform the computations required // by a job. Note that a workflow job may use multiple pools, in order to match // the various computational requirements of the various stages of the job. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type WorkerPool = src.WorkerPool // Provides data to pass through to the worker harness. // // Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb type WorkerSettings = src.WorkerSettings // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewFlexTemplatesServiceClient(cc grpc.ClientConnInterface) FlexTemplatesServiceClient { return src.NewFlexTemplatesServiceClient(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewJobsV1Beta3Client(cc grpc.ClientConnInterface) JobsV1Beta3Client { return src.NewJobsV1Beta3Client(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewMessagesV1Beta3Client(cc grpc.ClientConnInterface) MessagesV1Beta3Client { return src.NewMessagesV1Beta3Client(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewMetricsV1Beta3Client(cc grpc.ClientConnInterface) MetricsV1Beta3Client { return src.NewMetricsV1Beta3Client(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewSnapshotsV1Beta3Client(cc grpc.ClientConnInterface) SnapshotsV1Beta3Client { return src.NewSnapshotsV1Beta3Client(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func NewTemplatesServiceClient(cc grpc.ClientConnInterface) TemplatesServiceClient { return src.NewTemplatesServiceClient(cc) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterFlexTemplatesServiceServer(s *grpc.Server, srv FlexTemplatesServiceServer) { src.RegisterFlexTemplatesServiceServer(s, srv) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterJobsV1Beta3Server(s *grpc.Server, srv JobsV1Beta3Server) { src.RegisterJobsV1Beta3Server(s, srv) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterMessagesV1Beta3Server(s *grpc.Server, srv MessagesV1Beta3Server) { src.RegisterMessagesV1Beta3Server(s, srv) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterMetricsV1Beta3Server(s *grpc.Server, srv MetricsV1Beta3Server) { src.RegisterMetricsV1Beta3Server(s, srv) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterSnapshotsV1Beta3Server(s *grpc.Server, srv SnapshotsV1Beta3Server) { src.RegisterSnapshotsV1Beta3Server(s, srv) } // Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb func RegisterTemplatesServiceServer(s *grpc.Server, srv TemplatesServiceServer) { src.RegisterTemplatesServiceServer(s, srv) }