Skip to content

Commit 16461cb

Browse files
feat: added sync APIs for the CRUD operations of Data Agent (#32297)
feat: add LookerGoldenQuery to Context PiperOrigin-RevId: 845792138 Source-Link: googleapis/googleapis@80509f2 Source-Link: googleapis/googleapis-gen@59b52c2 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLWdlbWluaV9kYXRhX2FuYWx5dGljcy12MWJldGEvLk93bEJvdC55YW1sIiwiaCI6IjU5YjUyYzJkYjBjYzY3MWM0MTA4NWVhMzYxNjJmYTI5YThiNDU5OGYifQ== * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md feat: add custom prompt config in the request and return prompt in the response feat: update min_speaker_count and max_speaker_count to be optional docs: Clarify that min_speaker_count and max_speaker_count in SpeakerDiarizationConfig are not currently used docs: Update guidance on how to enable speaker diarization; to enable, set the diarization_config field to an empty SpeakerDiarizationConfig message PiperOrigin-RevId: 852383212 Source-Link: googleapis/googleapis@1a14153 Source-Link: googleapis/googleapis-gen@c84243c Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLWdlbWluaV9kYXRhX2FuYWx5dGljcy12MWJldGEvLk93bEJvdC55YW1sIiwiaCI6ImM4NDI0M2NhYTExYzdmYzg5MDU2ZTBiZDA3YjRjNGM2YWVhMDUxMGIifQ== * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: added sync APIs for the CRUD operations of Data Agent PiperOrigin-RevId: 855534426 Source-Link: googleapis/googleapis@fbda01e Source-Link: googleapis/googleapis-gen@b5a77c8 Copy-Tag: eyJwIjoiZ29vZ2xlLWNsb3VkLWdlbWluaV9kYXRhX2FuYWx5dGljcy12MWJldGEvLk93bEJvdC55YW1sIiwiaCI6ImI1YTc3Yzg3ODEyOWRhYjc5OTg4NzQ4YjZiMjNhNWEwMGY3YWQ0NWUifQ== * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 72ad125 commit 16461cb

File tree

17 files changed

+1530
-43
lines changed

17 files changed

+1530
-43
lines changed

google-cloud-gemini_data_analytics-v1beta/.owlbot-manifest.json

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,13 +75,16 @@
7575
"proto_docs/google/type/expr.rb",
7676
"snippets/Gemfile",
7777
"snippets/data_agent_service/create_data_agent.rb",
78+
"snippets/data_agent_service/create_data_agent_sync.rb",
7879
"snippets/data_agent_service/delete_data_agent.rb",
80+
"snippets/data_agent_service/delete_data_agent_sync.rb",
7981
"snippets/data_agent_service/get_data_agent.rb",
8082
"snippets/data_agent_service/get_iam_policy.rb",
8183
"snippets/data_agent_service/list_accessible_data_agents.rb",
8284
"snippets/data_agent_service/list_data_agents.rb",
8385
"snippets/data_agent_service/set_iam_policy.rb",
8486
"snippets/data_agent_service/update_data_agent.rb",
87+
"snippets/data_agent_service/update_data_agent_sync.rb",
8588
"snippets/data_chat_service/chat.rb",
8689
"snippets/data_chat_service/create_conversation.rb",
8790
"snippets/data_chat_service/delete_conversation.rb",

google-cloud-gemini_data_analytics-v1beta/gapic_metadata.json

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,16 +30,31 @@
3030
"create_data_agent"
3131
]
3232
},
33+
"CreateDataAgentSync": {
34+
"methods": [
35+
"create_data_agent_sync"
36+
]
37+
},
3338
"UpdateDataAgent": {
3439
"methods": [
3540
"update_data_agent"
3641
]
3742
},
43+
"UpdateDataAgentSync": {
44+
"methods": [
45+
"update_data_agent_sync"
46+
]
47+
},
3848
"DeleteDataAgent": {
3949
"methods": [
4050
"delete_data_agent"
4151
]
4252
},
53+
"DeleteDataAgentSync": {
54+
"methods": [
55+
"delete_data_agent_sync"
56+
]
57+
},
4358
"GetIamPolicy": {
4459
"methods": [
4560
"get_iam_policy"

google-cloud-gemini_data_analytics-v1beta/lib/google/cloud/gemini_data_analytics/v1beta/data_agent_service/client.rb

Lines changed: 332 additions & 0 deletions
Large diffs are not rendered by default.

google-cloud-gemini_data_analytics-v1beta/lib/google/cloud/gemini_data_analytics/v1beta/data_agent_service/rest/client.rb

Lines changed: 311 additions & 0 deletions
Large diffs are not rendered by default.

google-cloud-gemini_data_analytics-v1beta/lib/google/cloud/gemini_data_analytics/v1beta/data_agent_service/rest/service_stub.rb

Lines changed: 185 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,46 @@ def create_data_agent request_pb, options = nil
233233
end
234234
end
235235

236+
##
237+
# Baseline implementation for the create_data_agent_sync REST call
238+
#
239+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::CreateDataAgentRequest]
240+
# A request object representing the call parameters. Required.
241+
# @param options [::Gapic::CallOptions]
242+
# Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
243+
#
244+
# @yield [result, operation] Access the result along with the TransportOperation object
245+
# @yieldparam result [::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent]
246+
# @yieldparam operation [::Gapic::Rest::TransportOperation]
247+
#
248+
# @return [::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent]
249+
# A result object deserialized from the server's reply
250+
def create_data_agent_sync request_pb, options = nil
251+
raise ::ArgumentError, "request must be provided" if request_pb.nil?
252+
253+
verb, uri, query_string_params, body = ServiceStub.transcode_create_data_agent_sync_request request_pb
254+
query_string_params = if query_string_params.any?
255+
query_string_params.to_h { |p| p.split "=", 2 }
256+
else
257+
{}
258+
end
259+
260+
response = @client_stub.make_http_request(
261+
verb,
262+
uri: uri,
263+
body: body || "",
264+
params: query_string_params,
265+
method_name: "create_data_agent_sync",
266+
options: options
267+
)
268+
operation = ::Gapic::Rest::TransportOperation.new response
269+
result = ::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent.decode_json response.body, ignore_unknown_fields: true
270+
catch :response do
271+
yield result, operation if block_given?
272+
result
273+
end
274+
end
275+
236276
##
237277
# Baseline implementation for the update_data_agent REST call
238278
#
@@ -273,6 +313,46 @@ def update_data_agent request_pb, options = nil
273313
end
274314
end
275315

316+
##
317+
# Baseline implementation for the update_data_agent_sync REST call
318+
#
319+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::UpdateDataAgentRequest]
320+
# A request object representing the call parameters. Required.
321+
# @param options [::Gapic::CallOptions]
322+
# Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
323+
#
324+
# @yield [result, operation] Access the result along with the TransportOperation object
325+
# @yieldparam result [::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent]
326+
# @yieldparam operation [::Gapic::Rest::TransportOperation]
327+
#
328+
# @return [::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent]
329+
# A result object deserialized from the server's reply
330+
def update_data_agent_sync request_pb, options = nil
331+
raise ::ArgumentError, "request must be provided" if request_pb.nil?
332+
333+
verb, uri, query_string_params, body = ServiceStub.transcode_update_data_agent_sync_request request_pb
334+
query_string_params = if query_string_params.any?
335+
query_string_params.to_h { |p| p.split "=", 2 }
336+
else
337+
{}
338+
end
339+
340+
response = @client_stub.make_http_request(
341+
verb,
342+
uri: uri,
343+
body: body || "",
344+
params: query_string_params,
345+
method_name: "update_data_agent_sync",
346+
options: options
347+
)
348+
operation = ::Gapic::Rest::TransportOperation.new response
349+
result = ::Google::Cloud::GeminiDataAnalytics::V1beta::DataAgent.decode_json response.body, ignore_unknown_fields: true
350+
catch :response do
351+
yield result, operation if block_given?
352+
result
353+
end
354+
end
355+
276356
##
277357
# Baseline implementation for the delete_data_agent REST call
278358
#
@@ -313,6 +393,46 @@ def delete_data_agent request_pb, options = nil
313393
end
314394
end
315395

396+
##
397+
# Baseline implementation for the delete_data_agent_sync REST call
398+
#
399+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::DeleteDataAgentRequest]
400+
# A request object representing the call parameters. Required.
401+
# @param options [::Gapic::CallOptions]
402+
# Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
403+
#
404+
# @yield [result, operation] Access the result along with the TransportOperation object
405+
# @yieldparam result [::Google::Protobuf::Empty]
406+
# @yieldparam operation [::Gapic::Rest::TransportOperation]
407+
#
408+
# @return [::Google::Protobuf::Empty]
409+
# A result object deserialized from the server's reply
410+
def delete_data_agent_sync request_pb, options = nil
411+
raise ::ArgumentError, "request must be provided" if request_pb.nil?
412+
413+
verb, uri, query_string_params, body = ServiceStub.transcode_delete_data_agent_sync_request request_pb
414+
query_string_params = if query_string_params.any?
415+
query_string_params.to_h { |p| p.split "=", 2 }
416+
else
417+
{}
418+
end
419+
420+
response = @client_stub.make_http_request(
421+
verb,
422+
uri: uri,
423+
body: body || "",
424+
params: query_string_params,
425+
method_name: "delete_data_agent_sync",
426+
options: options
427+
)
428+
operation = ::Gapic::Rest::TransportOperation.new response
429+
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
430+
catch :response do
431+
yield result, operation if block_given?
432+
result
433+
end
434+
end
435+
316436
##
317437
# Baseline implementation for the get_iam_policy REST call
318438
#
@@ -478,6 +598,28 @@ def self.transcode_create_data_agent_request request_pb
478598
transcoder.transcode request_pb
479599
end
480600

601+
##
602+
# @private
603+
#
604+
# GRPC transcoding helper method for the create_data_agent_sync REST call
605+
#
606+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::CreateDataAgentRequest]
607+
# A request object representing the call parameters. Required.
608+
# @return [Array(String, [String, nil], Hash{String => String})]
609+
# Uri, Body, Query string parameters
610+
def self.transcode_create_data_agent_sync_request request_pb
611+
transcoder = Gapic::Rest::GrpcTranscoder.new
612+
.with_bindings(
613+
uri_method: :post,
614+
uri_template: "/v1beta/{parent}/dataAgents:createSync",
615+
body: "data_agent",
616+
matches: [
617+
["parent", %r{^projects/[^/]+/locations/[^/]+/?$}, false]
618+
]
619+
)
620+
transcoder.transcode request_pb
621+
end
622+
481623
##
482624
# @private
483625
#
@@ -500,6 +642,28 @@ def self.transcode_update_data_agent_request request_pb
500642
transcoder.transcode request_pb
501643
end
502644

645+
##
646+
# @private
647+
#
648+
# GRPC transcoding helper method for the update_data_agent_sync REST call
649+
#
650+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::UpdateDataAgentRequest]
651+
# A request object representing the call parameters. Required.
652+
# @return [Array(String, [String, nil], Hash{String => String})]
653+
# Uri, Body, Query string parameters
654+
def self.transcode_update_data_agent_sync_request request_pb
655+
transcoder = Gapic::Rest::GrpcTranscoder.new
656+
.with_bindings(
657+
uri_method: :patch,
658+
uri_template: "/v1beta/{data_agent.name}:updateSync",
659+
body: "data_agent",
660+
matches: [
661+
["data_agent.name", %r{^projects/[^/]+/locations/[^/]+/dataAgents/[^/]+/?$}, false]
662+
]
663+
)
664+
transcoder.transcode request_pb
665+
end
666+
503667
##
504668
# @private
505669
#
@@ -521,6 +685,27 @@ def self.transcode_delete_data_agent_request request_pb
521685
transcoder.transcode request_pb
522686
end
523687

688+
##
689+
# @private
690+
#
691+
# GRPC transcoding helper method for the delete_data_agent_sync REST call
692+
#
693+
# @param request_pb [::Google::Cloud::GeminiDataAnalytics::V1beta::DeleteDataAgentRequest]
694+
# A request object representing the call parameters. Required.
695+
# @return [Array(String, [String, nil], Hash{String => String})]
696+
# Uri, Body, Query string parameters
697+
def self.transcode_delete_data_agent_sync_request request_pb
698+
transcoder = Gapic::Rest::GrpcTranscoder.new
699+
.with_bindings(
700+
uri_method: :delete,
701+
uri_template: "/v1beta/{name}:deleteSync",
702+
matches: [
703+
["name", %r{^projects/[^/]+/locations/[^/]+/dataAgents/[^/]+/?$}, false]
704+
]
705+
)
706+
transcoder.transcode request_pb
707+
end
708+
524709
##
525710
# @private
526711
#

0 commit comments

Comments
 (0)