Skip to content

Commit

Permalink
feat: increase timeout of RPC methods to 20s for v2
Browse files Browse the repository at this point in the history
feat: add YAML config for GetLocation and ListLocation for v2
feat: add UploadQueueYaml, BufferTask RPC method for CloudTasks service for v2beta2
feat: set deadline for GetLocation, ListLocations and UploadQueueYaml RPCs for v2beta2
feat: add BufferTask RPC method for CloudTasks service for v2beta3
feat: add YAML config for GetLocation and ListLocations for v2beta3

PiperOrigin-RevId: 548738528

Source-Link: googleapis/googleapis@4d98ffc

Source-Link: googleapis/googleapis-gen@183d6bc
Copy-Tag: eyJwIjoiYXBpcy9Hb29nbGUuQ2xvdWQuVGFza3MuVjIvLk93bEJvdC55YW1sIiwiaCI6IjE4M2Q2YmM0ZWUzYzE4OTBiMWQyNGY5ZGM4NTUwNDFmNDk3ZDVkNWIifQ==
  • Loading branch information
gcf-owl-bot[bot] authored and amanda-tarafa committed Jul 17, 2023
1 parent 36504a4 commit f2145a6
Show file tree
Hide file tree
Showing 10 changed files with 739 additions and 591 deletions.
845 changes: 468 additions & 377 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/CloudTasksClient.g.cs

Large diffs are not rendered by default.

132 changes: 73 additions & 59 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/Cloudtasks.g.cs

Large diffs are not rendered by default.

298 changes: 161 additions & 137 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/CloudtasksGrpc.g.cs

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
<PackageReference Include="ConfigureAwaitChecker.Analyzer" Version="5.0.0" PrivateAssets="All" />
<PackageReference Include="Google.Api.Gax.Grpc" Version="[4.4.0, 5.0.0)" />
<PackageReference Include="Google.Cloud.Iam.V1" Version="[3.0.0, 4.0.0)" />
<PackageReference Include="Google.Cloud.Location" Version="[2.0.0, 3.0.0)" />
<PackageReference Include="Grpc.Core" Version="[2.46.6, 3.0.0)" PrivateAssets="None" Condition="'$(TargetFramework)'=='net462'" />
</ItemGroup>
</Project>
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,8 @@

#pragma warning disable CS8981
using gaxgrpc = Google.Api.Gax.Grpc;
using gcl = Google.Cloud.Location;
using proto = Google.Protobuf;
using gpr = Google.Protobuf.Reflection;
using scg = System.Collections.Generic;

Expand All @@ -26,10 +28,24 @@ internal static class PackageApiMetadata
{
/// <summary>The <see cref="gaxgrpc::ApiMetadata"/> for services in this package.</summary>
internal static gaxgrpc::ApiMetadata ApiMetadata { get; } = new gaxgrpc::ApiMetadata("Google.Cloud.Tasks.V2", GetFileDescriptors)
.WithRequestNumericEnumJsonEncoding(true);
.WithRequestNumericEnumJsonEncoding(true)
.WithHttpRuleOverrides(new scg::Dictionary<string, proto::ByteString>
{
{
"google.cloud.location.Locations.GetLocation",
// { "get": "/v2/{name=projects/*/locations/*}" }
proto::ByteString.FromBase64("EiEvdjIve25hbWU9cHJvamVjdHMvKi9sb2NhdGlvbnMvKn0=")
},
{
"google.cloud.location.Locations.ListLocations",
// { "get": "/v2/{name=projects/*}/locations" }
proto::ByteString.FromBase64("Eh8vdjIve25hbWU9cHJvamVjdHMvKn0vbG9jYXRpb25z")
},
});

private static scg::IEnumerable<gpr::FileDescriptor> GetFileDescriptors()
{
yield return gcl::LocationsReflection.Descriptor;
yield return CloudtasksReflection.Descriptor;
yield return QueueReflection.Descriptor;
yield return TargetReflection.Descriptor;
Expand Down
4 changes: 2 additions & 2 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/Queue.g.cs
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,7 @@ public string Name {
/// <summary>
/// Output only. The state of the queue.
///
/// `state` can only be changed by called
/// `state` can only be changed by calling
/// [PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue],
/// [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue], or uploading
/// [queue.yaml/xml](https://cloud.google.com/appengine/docs/python/config/queueref).
Expand Down Expand Up @@ -1197,7 +1197,7 @@ public int MaxAttempts {
/// A task's retry interval starts at
/// [min_backoff][google.cloud.tasks.v2.RetryConfig.min_backoff], then doubles
/// `max_doublings` times, then increases linearly, and finally
/// retries retries at intervals of
/// retries at intervals of
/// [max_backoff][google.cloud.tasks.v2.RetryConfig.max_backoff] up to
/// [max_attempts][google.cloud.tasks.v2.RetryConfig.max_attempts] times.
///
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,9 @@

#pragma warning disable CS8981
using gaxgrpc = Google.Api.Gax.Grpc;
using gcl = Google.Cloud.Location;
using gctv = Google.Cloud.Tasks.V2;
using proto = Google.Protobuf;
using gpr = Google.Protobuf.Reflection;
using sys = System;
using scg = System.Collections.Generic;
Expand Down
25 changes: 12 additions & 13 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/Target.g.cs
Original file line number Diff line number Diff line change
Expand Up @@ -664,9 +664,10 @@ public void MergeFrom(pb::CodedInputStream input) {
/// or task-level:
///
/// * If [app_engine_routing_override is set on the
/// queue][Queue.app_engine_routing_override], this value is used for all
/// tasks in the queue, no matter what the setting is for the [task-level
/// app_engine_routing][AppEngineHttpRequest.app_engine_routing].
/// queue][google.cloud.tasks.v2.Queue.app_engine_routing_override], this value
/// is used for all tasks in the queue, no matter what the setting is for the
/// [task-level
/// app_engine_routing][google.cloud.tasks.v2.AppEngineHttpRequest.app_engine_routing].
///
/// The `url` that the task will be sent to is:
///
Expand Down Expand Up @@ -751,14 +752,11 @@ public AppEngineHttpRequest Clone() {
/// The HTTP method to use for the request. The default is POST.
///
/// The app's request handler for the task's target URL must be able to handle
/// HTTP requests with this http_method, otherwise the task attempt will fail
/// with error code 405 (Method Not Allowed). See
/// [Writing a push task request
/// HTTP requests with this http_method, otherwise the task attempt fails with
/// error code 405 (Method Not Allowed). See [Writing a push task request
/// handler](https://cloud.google.com/appengine/docs/java/taskqueue/push/creating-handlers#writing_a_push_task_request_handler)
/// and the documentation for the request handlers in the language your app is
/// written in e.g.
/// [Python Request
/// Handler](https://cloud.google.com/appengine/docs/python/tools/webapp/requesthandlerclass).
/// and the App Engine documentation for your runtime on [How Requests are
/// Handled](https://cloud.google.com/appengine/docs/standard/python3/how-requests-are-handled).
/// </summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
Expand All @@ -776,9 +774,10 @@ public AppEngineHttpRequest Clone() {
/// Task-level setting for App Engine routing.
///
/// * If [app_engine_routing_override is set on the
/// queue][Queue.app_engine_routing_override], this value is used for all
/// tasks in the queue, no matter what the setting is for the [task-level
/// app_engine_routing][AppEngineHttpRequest.app_engine_routing].
/// queue][google.cloud.tasks.v2.Queue.app_engine_routing_override], this
/// value is used for all tasks in the queue, no matter what the setting is
/// for the [task-level
/// app_engine_routing][google.cloud.tasks.v2.AppEngineHttpRequest.app_engine_routing].
/// </summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
Expand Down
4 changes: 2 additions & 2 deletions apis/Google.Cloud.Tasks.V2/Google.Cloud.Tasks.V2/Task.g.cs
Original file line number Diff line number Diff line change
Expand Up @@ -241,8 +241,8 @@ public string Name {
/// is marked as a `DEADLINE_EXCEEDED` failure. Cloud Tasks will retry the
/// task according to the [RetryConfig][google.cloud.tasks.v2.RetryConfig].
///
/// Note that when the request is cancelled, Cloud Tasks will stop listing for
/// the response, but whether the worker stops processing depends on the
/// Note that when the request is cancelled, Cloud Tasks will stop listening
/// for the response, but whether the worker stops processing depends on the
/// worker. For example, if the worker is stuck, it may not react to cancelled
/// requests.
///
Expand Down
1 change: 1 addition & 0 deletions apis/apis.json
Original file line number Diff line number Diff line change
Expand Up @@ -4420,6 +4420,7 @@
"dependencies": {
"Google.Api.Gax.Grpc": "4.4.0",
"Google.Cloud.Iam.V1": "3.0.0",
"Google.Cloud.Location": "2.0.0",
"Grpc.Core": "2.46.6"
},
"shortName": "cloudtasks",
Expand Down

0 comments on commit f2145a6

Please sign in to comment.