lib/google/cloud/dataform/v1beta1/dataform/rest/service_stub.rb in google-cloud-dataform-v1beta1-0.4.0 vs lib/google/cloud/dataform/v1beta1/dataform/rest/service_stub.rb in google-cloud-dataform-v1beta1-0.5.0
- old
+ new
@@ -229,10 +229,200 @@
yield result, operation if block_given?
result
end
##
+ # Baseline implementation for the commit_repository_changes REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CommitRepositoryChangesRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Protobuf::Empty]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Protobuf::Empty]
+ # A result object deserialized from the server's reply
+ def commit_repository_changes request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_commit_repository_changes_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the read_repository_file REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileResponse]
+ # A result object deserialized from the server's reply
+ def read_repository_file request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_read_repository_file_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the query_repository_directory_contents REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsResponse]
+ # A result object deserialized from the server's reply
+ def query_repository_directory_contents request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_query_repository_directory_contents_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the fetch_repository_history REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryResponse]
+ # A result object deserialized from the server's reply
+ def fetch_repository_history request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_fetch_repository_history_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the compute_repository_access_token_status REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusResponse]
+ # A result object deserialized from the server's reply
+ def compute_repository_access_token_status request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_compute_repository_access_token_status_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
# Baseline implementation for the fetch_remote_branches REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::FetchRemoteBranchesRequest]
# A request object representing the call parameters. Required.
# @param options [::Gapic::CallOptions]
@@ -1027,10 +1217,200 @@
yield result, operation if block_given?
result
end
##
+ # Baseline implementation for the list_release_configs REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsResponse]
+ # A result object deserialized from the server's reply
+ def list_release_configs request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_list_release_configs_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the get_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::GetReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # A result object deserialized from the server's reply
+ def get_release_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_get_release_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the create_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CreateReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # A result object deserialized from the server's reply
+ def create_release_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_create_release_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the update_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::UpdateReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ReleaseConfig]
+ # A result object deserialized from the server's reply
+ def update_release_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_update_release_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the delete_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::DeleteReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Protobuf::Empty]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Protobuf::Empty]
+ # A result object deserialized from the server's reply
+ def delete_release_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_delete_release_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
# Baseline implementation for the list_compilation_results REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::ListCompilationResultsRequest]
# A request object representing the call parameters. Required.
# @param options [::Gapic::CallOptions]
@@ -1179,10 +1559,200 @@
yield result, operation if block_given?
result
end
##
+ # Baseline implementation for the list_workflow_configs REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsResponse]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsResponse]
+ # A result object deserialized from the server's reply
+ def list_workflow_configs request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_list_workflow_configs_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsResponse.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the get_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::GetWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # A result object deserialized from the server's reply
+ def get_workflow_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_get_workflow_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the create_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CreateWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # A result object deserialized from the server's reply
+ def create_workflow_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_create_workflow_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the update_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::UpdateWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Cloud::Dataform::V1beta1::WorkflowConfig]
+ # A result object deserialized from the server's reply
+ def update_workflow_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_update_workflow_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
+ # Baseline implementation for the delete_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::DeleteWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @param options [::Gapic::CallOptions]
+ # Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
+ #
+ # @yield [result, operation] Access the result along with the TransportOperation object
+ # @yieldparam result [::Google::Protobuf::Empty]
+ # @yieldparam operation [::Gapic::Rest::TransportOperation]
+ #
+ # @return [::Google::Protobuf::Empty]
+ # A result object deserialized from the server's reply
+ def delete_workflow_config request_pb, options = nil
+ raise ::ArgumentError, "request must be provided" if request_pb.nil?
+
+ verb, uri, query_string_params, body = ServiceStub.transcode_delete_workflow_config_request request_pb
+ query_string_params = if query_string_params.any?
+ query_string_params.to_h { |p| p.split "=", 2 }
+ else
+ {}
+ end
+
+ response = @client_stub.make_http_request(
+ verb,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ options: options
+ )
+ operation = ::Gapic::Rest::TransportOperation.new response
+ result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
+
+ yield result, operation if block_given?
+ result
+ end
+
+ ##
# Baseline implementation for the list_workflow_invocations REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::ListWorkflowInvocationsRequest]
# A request object representing the call parameters. Required.
# @param options [::Gapic::CallOptions]
@@ -1516,10 +2086,116 @@
end
##
# @private
#
+ # GRPC transcoding helper method for the commit_repository_changes REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CommitRepositoryChangesRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_commit_repository_changes_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :post,
+ uri_template: "/v1beta1/{name}:commit",
+ body: "*",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the read_repository_file REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_read_repository_file_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}:readFile",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the query_repository_directory_contents REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_query_repository_directory_contents_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}:queryDirectoryContents",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the fetch_repository_history REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_fetch_repository_history_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}:fetchHistory",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the compute_repository_access_token_status REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_compute_repository_access_token_status_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}:computeAccessTokenStatus",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
# GRPC transcoding helper method for the fetch_remote_branches REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::FetchRemoteBranchesRequest]
# A request object representing the call parameters. Required.
# @return [Array(String, [String, nil], Hash{String => String})]
@@ -1969,10 +2645,117 @@
end
##
# @private
#
+ # GRPC transcoding helper method for the list_release_configs REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_list_release_configs_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{parent}/releaseConfigs",
+ matches: [
+ ["parent", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the get_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::GetReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_get_release_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/releaseConfigs/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the create_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CreateReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_create_release_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :post,
+ uri_template: "/v1beta1/{parent}/releaseConfigs",
+ body: "release_config",
+ matches: [
+ ["parent", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the update_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::UpdateReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_update_release_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :patch,
+ uri_template: "/v1beta1/{release_config.name}",
+ body: "release_config",
+ matches: [
+ ["release_config.name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/releaseConfigs/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the delete_release_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::DeleteReleaseConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_delete_release_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :delete,
+ uri_template: "/v1beta1/{name}",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/releaseConfigs/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
# GRPC transcoding helper method for the list_compilation_results REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::ListCompilationResultsRequest]
# A request object representing the call parameters. Required.
# @return [Array(String, [String, nil], Hash{String => String})]
@@ -2046,9 +2829,116 @@
.with_bindings(
uri_method: :get,
uri_template: "/v1beta1/{name}:query",
matches: [
["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/compilationResults/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the list_workflow_configs REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_list_workflow_configs_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{parent}/workflowConfigs",
+ matches: [
+ ["parent", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the get_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::GetWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_get_workflow_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :get,
+ uri_template: "/v1beta1/{name}",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/workflowConfigs/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the create_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::CreateWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_create_workflow_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :post,
+ uri_template: "/v1beta1/{parent}/workflowConfigs",
+ body: "workflow_config",
+ matches: [
+ ["parent", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the update_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::UpdateWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_update_workflow_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :patch,
+ uri_template: "/v1beta1/{workflow_config.name}",
+ body: "workflow_config",
+ matches: [
+ ["workflow_config.name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/workflowConfigs/[^/]+/?$}, false]
+ ]
+ )
+ transcoder.transcode request_pb
+ end
+
+ ##
+ # @private
+ #
+ # GRPC transcoding helper method for the delete_workflow_config REST call
+ #
+ # @param request_pb [::Google::Cloud::Dataform::V1beta1::DeleteWorkflowConfigRequest]
+ # A request object representing the call parameters. Required.
+ # @return [Array(String, [String, nil], Hash{String => String})]
+ # Uri, Body, Query string parameters
+ def self.transcode_delete_workflow_config_request request_pb
+ transcoder = Gapic::Rest::GrpcTranscoder.new
+ .with_bindings(
+ uri_method: :delete,
+ uri_template: "/v1beta1/{name}",
+ matches: [
+ ["name", %r{^projects/[^/]+/locations/[^/]+/repositories/[^/]+/workflowConfigs/[^/]+/?$}, false]
]
)
transcoder.transcode request_pb
end