From 6ffce1dbf567758d23ac39aaf63dc17ced5e4db9 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Tue, 5 Apr 2022 16:07:46 -0700 Subject: [PATCH] chore(all): auto-regenerate gapics (#5854) This is an auto-generated regeneration of the gapic clients by cloud.google.com/go/internal/gapicgen. Once the corresponding genproto PR is submitted, genbot will update this PR with a newer dependency to the newer version of genproto and assign reviewers to this PR. If you have been assigned to review this PR, please: - Ensure that the version of genproto in go.mod has been updated. - Ensure that CI is passing. If it's failing, it requires your manual attention. - Approve and submit this PR if you believe it's ready to ship. Corresponding genproto PR: https://github.com/googleapis/go-genproto/pull/789 Changes: chore(speech): remove unused imports PiperOrigin-RevId: 439629269 Source-Link: https://github.com/googleapis/googleapis/commit/8d458c818cd057d196a6af9a8829ff0f0b15b810 docs(deploy):Cloud Deploy API Platform Logging documentation feat: Add support for Anthos worker pool. PiperOrigin-RevId: 439623824 Source-Link: https://github.com/googleapis/googleapis/commit/43184df871e92765241e32402d67fd970bc97773 chore(cloudtasks): remove unused imports PiperOrigin-RevId: 439598143 Source-Link: https://github.com/googleapis/googleapis/commit/63db84f1311b6e4d3509e68d66dceec329cd77c8 feat(storagetransfer): add support for Agent Pools feat: add support for transfers between file systems feat: add support for metadata preservation feat: add support for transferring a specific list of objects (manifest) feat: add support for Cloud Logging PiperOrigin-RevId: 439424192 Source-Link: https://github.com/googleapis/googleapis/commit/bf6982693e7f5f250199705c7cd99a4700cb3c0a feat(secretmanager): Added support for accessing secret versions by alias Clients can now associate custom strings with specified secret versions for later access. PiperOrigin-RevId: 439320490 Source-Link: https://github.com/googleapis/googleapis/commit/bbe5618e37535aa9b773acd9de1eb4aecb5a3f99 --- cloudtasks/go.mod | 2 +- cloudtasks/go.sum | 3 +- deploy/go.mod | 2 +- deploy/go.sum | 3 +- go.mod | 2 +- go.sum | 4 +- internal/generated/snippets/go.mod | 2 +- internal/generated/snippets/go.sum | 3 +- .../apiv1/Client/CreateAgentPool/main.go | 48 ++++ .../apiv1/Client/DeleteAgentPool/main.go | 46 ++++ .../apiv1/Client/GetAgentPool/main.go | 48 ++++ .../apiv1/Client/ListAgentPools/main.go | 55 ++++ .../apiv1/Client/UpdateAgentPool/main.go | 48 ++++ internal/godocfx/go.sum | 4 +- secretmanager/go.mod | 2 +- secretmanager/go.sum | 3 +- speech/go.mod | 2 +- speech/go.sum | 3 +- storagetransfer/apiv1/gapic_metadata.json | 25 ++ .../apiv1/storage_transfer_client.go | 238 +++++++++++++++++- .../storage_transfer_client_example_test.go | 104 ++++++++ storagetransfer/go.mod | 2 +- storagetransfer/go.sum | 3 +- 23 files changed, 624 insertions(+), 28 deletions(-) create mode 100644 internal/generated/snippets/storagetransfer/apiv1/Client/CreateAgentPool/main.go create mode 100644 internal/generated/snippets/storagetransfer/apiv1/Client/DeleteAgentPool/main.go create mode 100644 internal/generated/snippets/storagetransfer/apiv1/Client/GetAgentPool/main.go create mode 100644 internal/generated/snippets/storagetransfer/apiv1/Client/ListAgentPools/main.go create mode 100644 internal/generated/snippets/storagetransfer/apiv1/Client/UpdateAgentPool/main.go diff --git a/cloudtasks/go.mod b/cloudtasks/go.mod index 1c491788ea9..2a6e91bb7b7 100644 --- a/cloudtasks/go.mod +++ b/cloudtasks/go.mod @@ -6,7 +6,7 @@ require ( github.com/golang/protobuf v1.5.2 github.com/googleapis/gax-go/v2 v2.2.0 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/cloudtasks/go.sum b/cloudtasks/go.sum index 4379775bc6f..0c961fc692e 100644 --- a/cloudtasks/go.sum +++ b/cloudtasks/go.sum @@ -537,8 +537,9 @@ google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= -google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb h1:0m9wktIpOxGw+SSKmydXWB3Z3GTfcPP6+q75HCQa6HI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= diff --git a/deploy/go.mod b/deploy/go.mod index 9fff4ca9207..bdcb4559fb7 100644 --- a/deploy/go.mod +++ b/deploy/go.mod @@ -6,7 +6,7 @@ require ( cloud.google.com/go v0.100.2 github.com/googleapis/gax-go/v2 v2.2.0 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/deploy/go.sum b/deploy/go.sum index 4379775bc6f..0c961fc692e 100644 --- a/deploy/go.sum +++ b/deploy/go.sum @@ -537,8 +537,9 @@ google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= -google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb h1:0m9wktIpOxGw+SSKmydXWB3Z3GTfcPP6+q75HCQa6HI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= diff --git a/go.mod b/go.mod index 35b120f6d70..f591d70f0f0 100644 --- a/go.mod +++ b/go.mod @@ -14,7 +14,7 @@ require ( golang.org/x/oauth2 v0.0.0-20220309155454-6242fa91716a golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62 + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/go.sum b/go.sum index 01d4cd9940f..f6ecd9d2c59 100644 --- a/go.sum +++ b/go.sum @@ -558,8 +558,8 @@ google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= -google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62 h1:IPy3YJ7uYPB1sDNJRs/b7Dgs6KxwMyGYgtIgDnKgEyw= -google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= diff --git a/internal/generated/snippets/go.mod b/internal/generated/snippets/go.mod index a2f8820e281..c8c18bcf46a 100644 --- a/internal/generated/snippets/go.mod +++ b/internal/generated/snippets/go.mod @@ -114,7 +114,7 @@ require ( cloud.google.com/go/workflows v1.1.0 github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220401170504-314d38edb7de + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf ) replace cloud.google.com/go/storagetransfer => ../../../storagetransfer diff --git a/internal/generated/snippets/go.sum b/internal/generated/snippets/go.sum index 197ed31b312..0c11493bf5f 100644 --- a/internal/generated/snippets/go.sum +++ b/internal/generated/snippets/go.sum @@ -189,8 +189,9 @@ google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= google.golang.org/genproto v0.0.0-20220328180837-c47567c462d1/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= -google.golang.org/genproto v0.0.0-20220401170504-314d38edb7de h1:9Ti5SG2U4cAcluryUo/sFay3TQKoxiFMfaT0pbizU7k= google.golang.org/genproto v0.0.0-20220401170504-314d38edb7de/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= diff --git a/internal/generated/snippets/storagetransfer/apiv1/Client/CreateAgentPool/main.go b/internal/generated/snippets/storagetransfer/apiv1/Client/CreateAgentPool/main.go new file mode 100644 index 00000000000..1b9a7e2e605 --- /dev/null +++ b/internal/generated/snippets/storagetransfer/apiv1/Client/CreateAgentPool/main.go @@ -0,0 +1,48 @@ +// 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 cloud.google.com/go/internal/gapicgen/gensnippets. DO NOT EDIT. + +// [START storagetransfer_v1_generated_StorageTransferService_CreateAgentPool_sync] + +package main + +import ( + "context" + + storagetransfer "cloud.google.com/go/storagetransfer/apiv1" + storagetransferpb "google.golang.org/genproto/googleapis/storagetransfer/v1" +) + +func main() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.CreateAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#CreateAgentPoolRequest. + } + resp, err := c.CreateAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +// [END storagetransfer_v1_generated_StorageTransferService_CreateAgentPool_sync] diff --git a/internal/generated/snippets/storagetransfer/apiv1/Client/DeleteAgentPool/main.go b/internal/generated/snippets/storagetransfer/apiv1/Client/DeleteAgentPool/main.go new file mode 100644 index 00000000000..0cf5f1284c4 --- /dev/null +++ b/internal/generated/snippets/storagetransfer/apiv1/Client/DeleteAgentPool/main.go @@ -0,0 +1,46 @@ +// 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 cloud.google.com/go/internal/gapicgen/gensnippets. DO NOT EDIT. + +// [START storagetransfer_v1_generated_StorageTransferService_DeleteAgentPool_sync] + +package main + +import ( + "context" + + storagetransfer "cloud.google.com/go/storagetransfer/apiv1" + storagetransferpb "google.golang.org/genproto/googleapis/storagetransfer/v1" +) + +func main() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.DeleteAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#DeleteAgentPoolRequest. + } + err = c.DeleteAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } +} + +// [END storagetransfer_v1_generated_StorageTransferService_DeleteAgentPool_sync] diff --git a/internal/generated/snippets/storagetransfer/apiv1/Client/GetAgentPool/main.go b/internal/generated/snippets/storagetransfer/apiv1/Client/GetAgentPool/main.go new file mode 100644 index 00000000000..da8e49b5e4b --- /dev/null +++ b/internal/generated/snippets/storagetransfer/apiv1/Client/GetAgentPool/main.go @@ -0,0 +1,48 @@ +// 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 cloud.google.com/go/internal/gapicgen/gensnippets. DO NOT EDIT. + +// [START storagetransfer_v1_generated_StorageTransferService_GetAgentPool_sync] + +package main + +import ( + "context" + + storagetransfer "cloud.google.com/go/storagetransfer/apiv1" + storagetransferpb "google.golang.org/genproto/googleapis/storagetransfer/v1" +) + +func main() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.GetAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#GetAgentPoolRequest. + } + resp, err := c.GetAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +// [END storagetransfer_v1_generated_StorageTransferService_GetAgentPool_sync] diff --git a/internal/generated/snippets/storagetransfer/apiv1/Client/ListAgentPools/main.go b/internal/generated/snippets/storagetransfer/apiv1/Client/ListAgentPools/main.go new file mode 100644 index 00000000000..9167aee26ea --- /dev/null +++ b/internal/generated/snippets/storagetransfer/apiv1/Client/ListAgentPools/main.go @@ -0,0 +1,55 @@ +// 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 cloud.google.com/go/internal/gapicgen/gensnippets. DO NOT EDIT. + +// [START storagetransfer_v1_generated_StorageTransferService_ListAgentPools_sync] + +package main + +import ( + "context" + + storagetransfer "cloud.google.com/go/storagetransfer/apiv1" + "google.golang.org/api/iterator" + storagetransferpb "google.golang.org/genproto/googleapis/storagetransfer/v1" +) + +func main() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.ListAgentPoolsRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#ListAgentPoolsRequest. + } + it := c.ListAgentPools(ctx, req) + for { + resp, err := it.Next() + if err == iterator.Done { + break + } + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp + } +} + +// [END storagetransfer_v1_generated_StorageTransferService_ListAgentPools_sync] diff --git a/internal/generated/snippets/storagetransfer/apiv1/Client/UpdateAgentPool/main.go b/internal/generated/snippets/storagetransfer/apiv1/Client/UpdateAgentPool/main.go new file mode 100644 index 00000000000..db488ad4e2c --- /dev/null +++ b/internal/generated/snippets/storagetransfer/apiv1/Client/UpdateAgentPool/main.go @@ -0,0 +1,48 @@ +// 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 cloud.google.com/go/internal/gapicgen/gensnippets. DO NOT EDIT. + +// [START storagetransfer_v1_generated_StorageTransferService_UpdateAgentPool_sync] + +package main + +import ( + "context" + + storagetransfer "cloud.google.com/go/storagetransfer/apiv1" + storagetransferpb "google.golang.org/genproto/googleapis/storagetransfer/v1" +) + +func main() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.UpdateAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#UpdateAgentPoolRequest. + } + resp, err := c.UpdateAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +// [END storagetransfer_v1_generated_StorageTransferService_UpdateAgentPool_sync] diff --git a/internal/godocfx/go.sum b/internal/godocfx/go.sum index b790987afea..d81a6289f25 100644 --- a/internal/godocfx/go.sum +++ b/internal/godocfx/go.sum @@ -226,8 +226,8 @@ google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= -google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62 h1:IPy3YJ7uYPB1sDNJRs/b7Dgs6KxwMyGYgtIgDnKgEyw= -google.golang.org/genproto v0.0.0-20220329135034-5a5e19f58d62/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= diff --git a/secretmanager/go.mod b/secretmanager/go.mod index 404760af31d..dc5001b3e24 100644 --- a/secretmanager/go.mod +++ b/secretmanager/go.mod @@ -6,7 +6,7 @@ require ( cloud.google.com/go/iam v0.3.0 github.com/googleapis/gax-go/v2 v2.2.0 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/secretmanager/go.sum b/secretmanager/go.sum index aea171f19f5..75b07f42dff 100644 --- a/secretmanager/go.sum +++ b/secretmanager/go.sum @@ -539,8 +539,9 @@ google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= -google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb h1:0m9wktIpOxGw+SSKmydXWB3Z3GTfcPP6+q75HCQa6HI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= diff --git a/speech/go.mod b/speech/go.mod index e8279bd01fa..ba83aa6022b 100644 --- a/speech/go.mod +++ b/speech/go.mod @@ -7,7 +7,7 @@ require ( github.com/golang/protobuf v1.5.2 github.com/googleapis/gax-go/v2 v2.2.0 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/speech/go.sum b/speech/go.sum index 4379775bc6f..0c961fc692e 100644 --- a/speech/go.sum +++ b/speech/go.sum @@ -537,8 +537,9 @@ google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= -google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb h1:0m9wktIpOxGw+SSKmydXWB3Z3GTfcPP6+q75HCQa6HI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= diff --git a/storagetransfer/apiv1/gapic_metadata.json b/storagetransfer/apiv1/gapic_metadata.json index a02a46ffc2e..eef7424107a 100644 --- a/storagetransfer/apiv1/gapic_metadata.json +++ b/storagetransfer/apiv1/gapic_metadata.json @@ -10,11 +10,26 @@ "grpc": { "libraryClient": "Client", "rpcs": { + "CreateAgentPool": { + "methods": [ + "CreateAgentPool" + ] + }, "CreateTransferJob": { "methods": [ "CreateTransferJob" ] }, + "DeleteAgentPool": { + "methods": [ + "DeleteAgentPool" + ] + }, + "GetAgentPool": { + "methods": [ + "GetAgentPool" + ] + }, "GetGoogleServiceAccount": { "methods": [ "GetGoogleServiceAccount" @@ -25,6 +40,11 @@ "GetTransferJob" ] }, + "ListAgentPools": { + "methods": [ + "ListAgentPools" + ] + }, "ListTransferJobs": { "methods": [ "ListTransferJobs" @@ -45,6 +65,11 @@ "RunTransferJob" ] }, + "UpdateAgentPool": { + "methods": [ + "UpdateAgentPool" + ] + }, "UpdateTransferJob": { "methods": [ "UpdateTransferJob" diff --git a/storagetransfer/apiv1/storage_transfer_client.go b/storagetransfer/apiv1/storage_transfer_client.go index b41eb8be20e..8e4c5af5319 100644 --- a/storagetransfer/apiv1/storage_transfer_client.go +++ b/storagetransfer/apiv1/storage_transfer_client.go @@ -49,6 +49,11 @@ type CallOptions struct { PauseTransferOperation []gax.CallOption ResumeTransferOperation []gax.CallOption RunTransferJob []gax.CallOption + CreateAgentPool []gax.CallOption + UpdateAgentPool []gax.CallOption + GetAgentPool []gax.CallOption + ListAgentPools []gax.CallOption + DeleteAgentPool []gax.CallOption } func defaultGRPCClientOptions() []option.ClientOption { @@ -73,6 +78,11 @@ func defaultCallOptions() *CallOptions { PauseTransferOperation: []gax.CallOption{}, ResumeTransferOperation: []gax.CallOption{}, RunTransferJob: []gax.CallOption{}, + CreateAgentPool: []gax.CallOption{}, + UpdateAgentPool: []gax.CallOption{}, + GetAgentPool: []gax.CallOption{}, + ListAgentPools: []gax.CallOption{}, + DeleteAgentPool: []gax.CallOption{}, } } @@ -90,6 +100,11 @@ type internalClient interface { ResumeTransferOperation(context.Context, *storagetransferpb.ResumeTransferOperationRequest, ...gax.CallOption) error RunTransferJob(context.Context, *storagetransferpb.RunTransferJobRequest, ...gax.CallOption) (*RunTransferJobOperation, error) RunTransferJobOperation(name string) *RunTransferJobOperation + CreateAgentPool(context.Context, *storagetransferpb.CreateAgentPoolRequest, ...gax.CallOption) (*storagetransferpb.AgentPool, error) + UpdateAgentPool(context.Context, *storagetransferpb.UpdateAgentPoolRequest, ...gax.CallOption) (*storagetransferpb.AgentPool, error) + GetAgentPool(context.Context, *storagetransferpb.GetAgentPoolRequest, ...gax.CallOption) (*storagetransferpb.AgentPool, error) + ListAgentPools(context.Context, *storagetransferpb.ListAgentPoolsRequest, ...gax.CallOption) *AgentPoolIterator + DeleteAgentPool(context.Context, *storagetransferpb.DeleteAgentPoolRequest, ...gax.CallOption) error } // Client is a client for interacting with Storage Transfer API. @@ -136,7 +151,7 @@ func (c *Client) Connection() *grpc.ClientConn { // GetGoogleServiceAccount returns the Google service account that is used by Storage Transfer // Service to access buckets in the project where transfers // run or in other projects. Each Google service account is associated -// with one Google Cloud Platform Console project. Users +// with one Google Cloud project. Users // should add this service account to the Google Cloud Storage bucket // ACLs to grant access to Storage Transfer Service. This service // account is created and owned by Storage Transfer Service and can @@ -153,8 +168,8 @@ func (c *Client) CreateTransferJob(ctx context.Context, req *storagetransferpb.C // UpdateTransferJob updates a transfer job. Updating a job’s transfer spec does not affect // transfer operations that are running already. // -// Note: The job’s status -// field can be modified using this RPC (for example, to set a job’s status to +// Note: The job’s status field can be modified +// using this RPC (for example, to set a job’s status to // DELETED, // DISABLED, or // ENABLED). @@ -184,7 +199,7 @@ func (c *Client) ResumeTransferOperation(ctx context.Context, req *storagetransf // RunTransferJob attempts to start a new TransferOperation for the current TransferJob. A // TransferJob has a maximum of one active TransferOperation. If this method -// is called while a TransferOperation is active, an error wil be returned. +// is called while a TransferOperation is active, an error will be returned. func (c *Client) RunTransferJob(ctx context.Context, req *storagetransferpb.RunTransferJobRequest, opts ...gax.CallOption) (*RunTransferJobOperation, error) { return c.internalClient.RunTransferJob(ctx, req, opts...) } @@ -195,6 +210,31 @@ func (c *Client) RunTransferJobOperation(name string) *RunTransferJobOperation { return c.internalClient.RunTransferJobOperation(name) } +// CreateAgentPool creates an agent pool resource. +func (c *Client) CreateAgentPool(ctx context.Context, req *storagetransferpb.CreateAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + return c.internalClient.CreateAgentPool(ctx, req, opts...) +} + +// UpdateAgentPool updates an existing agent pool resource. +func (c *Client) UpdateAgentPool(ctx context.Context, req *storagetransferpb.UpdateAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + return c.internalClient.UpdateAgentPool(ctx, req, opts...) +} + +// GetAgentPool gets an agent pool. +func (c *Client) GetAgentPool(ctx context.Context, req *storagetransferpb.GetAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + return c.internalClient.GetAgentPool(ctx, req, opts...) +} + +// ListAgentPools lists agent pools. +func (c *Client) ListAgentPools(ctx context.Context, req *storagetransferpb.ListAgentPoolsRequest, opts ...gax.CallOption) *AgentPoolIterator { + return c.internalClient.ListAgentPools(ctx, req, opts...) +} + +// DeleteAgentPool deletes an agent pool. +func (c *Client) DeleteAgentPool(ctx context.Context, req *storagetransferpb.DeleteAgentPoolRequest, opts ...gax.CallOption) error { + return c.internalClient.DeleteAgentPool(ctx, req, opts...) +} + // gRPCClient is a client for interacting with Storage Transfer API over gRPC transport. // // Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls. @@ -295,7 +335,7 @@ func (c *gRPCClient) Close() error { func (c *gRPCClient) GetGoogleServiceAccount(ctx context.Context, req *storagetransferpb.GetGoogleServiceAccountRequest, opts ...gax.CallOption) (*storagetransferpb.GoogleServiceAccount, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -317,7 +357,7 @@ func (c *gRPCClient) GetGoogleServiceAccount(ctx context.Context, req *storagetr func (c *gRPCClient) CreateTransferJob(ctx context.Context, req *storagetransferpb.CreateTransferJobRequest, opts ...gax.CallOption) (*storagetransferpb.TransferJob, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -337,7 +377,7 @@ func (c *gRPCClient) CreateTransferJob(ctx context.Context, req *storagetransfer func (c *gRPCClient) UpdateTransferJob(ctx context.Context, req *storagetransferpb.UpdateTransferJobRequest, opts ...gax.CallOption) (*storagetransferpb.TransferJob, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -359,7 +399,7 @@ func (c *gRPCClient) UpdateTransferJob(ctx context.Context, req *storagetransfer func (c *gRPCClient) GetTransferJob(ctx context.Context, req *storagetransferpb.GetTransferJobRequest, opts ...gax.CallOption) (*storagetransferpb.TransferJob, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -424,7 +464,7 @@ func (c *gRPCClient) ListTransferJobs(ctx context.Context, req *storagetransferp func (c *gRPCClient) PauseTransferOperation(ctx context.Context, req *storagetransferpb.PauseTransferOperationRequest, opts ...gax.CallOption) error { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -442,7 +482,7 @@ func (c *gRPCClient) PauseTransferOperation(ctx context.Context, req *storagetra func (c *gRPCClient) ResumeTransferOperation(ctx context.Context, req *storagetransferpb.ResumeTransferOperationRequest, opts ...gax.CallOption) error { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -460,7 +500,7 @@ func (c *gRPCClient) ResumeTransferOperation(ctx context.Context, req *storagetr func (c *gRPCClient) RunTransferJob(ctx context.Context, req *storagetransferpb.RunTransferJobRequest, opts ...gax.CallOption) (*RunTransferJobOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) defer cancel() ctx = cctx } @@ -482,6 +522,135 @@ func (c *gRPCClient) RunTransferJob(ctx context.Context, req *storagetransferpb. }, nil } +func (c *gRPCClient) CreateAgentPool(ctx context.Context, req *storagetransferpb.CreateAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) + defer cancel() + ctx = cctx + } + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "project_id", url.QueryEscape(req.GetProjectId()))) + + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append((*c.CallOptions).CreateAgentPool[0:len((*c.CallOptions).CreateAgentPool):len((*c.CallOptions).CreateAgentPool)], opts...) + var resp *storagetransferpb.AgentPool + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.client.CreateAgentPool(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err + } + return resp, nil +} + +func (c *gRPCClient) UpdateAgentPool(ctx context.Context, req *storagetransferpb.UpdateAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) + defer cancel() + ctx = cctx + } + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "agent_pool.name", url.QueryEscape(req.GetAgentPool().GetName()))) + + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append((*c.CallOptions).UpdateAgentPool[0:len((*c.CallOptions).UpdateAgentPool):len((*c.CallOptions).UpdateAgentPool)], opts...) + var resp *storagetransferpb.AgentPool + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.client.UpdateAgentPool(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err + } + return resp, nil +} + +func (c *gRPCClient) GetAgentPool(ctx context.Context, req *storagetransferpb.GetAgentPoolRequest, opts ...gax.CallOption) (*storagetransferpb.AgentPool, error) { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) + defer cancel() + ctx = cctx + } + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append((*c.CallOptions).GetAgentPool[0:len((*c.CallOptions).GetAgentPool):len((*c.CallOptions).GetAgentPool)], opts...) + var resp *storagetransferpb.AgentPool + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.client.GetAgentPool(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err + } + return resp, nil +} + +func (c *gRPCClient) ListAgentPools(ctx context.Context, req *storagetransferpb.ListAgentPoolsRequest, opts ...gax.CallOption) *AgentPoolIterator { + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "project_id", url.QueryEscape(req.GetProjectId()))) + + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append((*c.CallOptions).ListAgentPools[0:len((*c.CallOptions).ListAgentPools):len((*c.CallOptions).ListAgentPools)], opts...) + it := &AgentPoolIterator{} + req = proto.Clone(req).(*storagetransferpb.ListAgentPoolsRequest) + it.InternalFetch = func(pageSize int, pageToken string) ([]*storagetransferpb.AgentPool, string, error) { + resp := &storagetransferpb.ListAgentPoolsResponse{} + if pageToken != "" { + req.PageToken = pageToken + } + if pageSize > math.MaxInt32 { + req.PageSize = math.MaxInt32 + } else if pageSize != 0 { + req.PageSize = int32(pageSize) + } + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.client.ListAgentPools(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, "", err + } + + it.Response = resp + return resp.GetAgentPools(), resp.GetNextPageToken(), nil + } + fetch := func(pageSize int, pageToken string) (string, error) { + items, nextPageToken, err := it.InternalFetch(pageSize, pageToken) + if err != nil { + return "", err + } + it.items = append(it.items, items...) + return nextPageToken, nil + } + + it.pageInfo, it.nextFunc = iterator.NewPageInfo(fetch, it.bufLen, it.takeBuf) + it.pageInfo.MaxSize = int(req.GetPageSize()) + it.pageInfo.Token = req.GetPageToken() + + return it +} + +func (c *gRPCClient) DeleteAgentPool(ctx context.Context, req *storagetransferpb.DeleteAgentPoolRequest, opts ...gax.CallOption) error { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 30000*time.Millisecond) + defer cancel() + ctx = cctx + } + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append((*c.CallOptions).DeleteAgentPool[0:len((*c.CallOptions).DeleteAgentPool):len((*c.CallOptions).DeleteAgentPool)], opts...) + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + _, err = c.client.DeleteAgentPool(ctx, req, settings.GRPC...) + return err + }, opts...) + return err +} + // RunTransferJobOperation manages a long-running operation from RunTransferJob. type RunTransferJobOperation struct { lro *longrunning.Operation @@ -540,6 +709,53 @@ func (op *RunTransferJobOperation) Name() string { return op.lro.Name() } +// AgentPoolIterator manages a stream of *storagetransferpb.AgentPool. +type AgentPoolIterator struct { + items []*storagetransferpb.AgentPool + pageInfo *iterator.PageInfo + nextFunc func() error + + // Response is the raw response for the current page. + // It must be cast to the RPC response type. + // Calling Next() or InternalFetch() updates this value. + Response interface{} + + // InternalFetch is for use by the Google Cloud Libraries only. + // It is not part of the stable interface of this package. + // + // InternalFetch returns results from a single call to the underlying RPC. + // The number of results is no greater than pageSize. + // If there are no more results, nextPageToken is empty and err is nil. + InternalFetch func(pageSize int, pageToken string) (results []*storagetransferpb.AgentPool, nextPageToken string, err error) +} + +// PageInfo supports pagination. See the google.golang.org/api/iterator package for details. +func (it *AgentPoolIterator) PageInfo() *iterator.PageInfo { + return it.pageInfo +} + +// Next returns the next result. Its second return value is iterator.Done if there are no more +// results. Once Next returns Done, all subsequent calls will return Done. +func (it *AgentPoolIterator) Next() (*storagetransferpb.AgentPool, error) { + var item *storagetransferpb.AgentPool + if err := it.nextFunc(); err != nil { + return item, err + } + item = it.items[0] + it.items = it.items[1:] + return item, nil +} + +func (it *AgentPoolIterator) bufLen() int { + return len(it.items) +} + +func (it *AgentPoolIterator) takeBuf() interface{} { + b := it.items + it.items = nil + return b +} + // TransferJobIterator manages a stream of *storagetransferpb.TransferJob. type TransferJobIterator struct { items []*storagetransferpb.TransferJob diff --git a/storagetransfer/apiv1/storage_transfer_client_example_test.go b/storagetransfer/apiv1/storage_transfer_client_example_test.go index e1a56dfe8bb..f9e4188efbc 100644 --- a/storagetransfer/apiv1/storage_transfer_client_example_test.go +++ b/storagetransfer/apiv1/storage_transfer_client_example_test.go @@ -200,3 +200,107 @@ func ExampleClient_RunTransferJob() { // TODO: Handle error. } } + +func ExampleClient_CreateAgentPool() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.CreateAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#CreateAgentPoolRequest. + } + resp, err := c.CreateAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +func ExampleClient_UpdateAgentPool() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.UpdateAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#UpdateAgentPoolRequest. + } + resp, err := c.UpdateAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +func ExampleClient_GetAgentPool() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.GetAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#GetAgentPoolRequest. + } + resp, err := c.GetAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp +} + +func ExampleClient_ListAgentPools() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.ListAgentPoolsRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#ListAgentPoolsRequest. + } + it := c.ListAgentPools(ctx, req) + for { + resp, err := it.Next() + if err == iterator.Done { + break + } + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp + } +} + +func ExampleClient_DeleteAgentPool() { + ctx := context.Background() + c, err := storagetransfer.NewClient(ctx) + if err != nil { + // TODO: Handle error. + } + defer c.Close() + + req := &storagetransferpb.DeleteAgentPoolRequest{ + // TODO: Fill request struct fields. + // See https://pkg.go.dev/google.golang.org/genproto/googleapis/storagetransfer/v1#DeleteAgentPoolRequest. + } + err = c.DeleteAgentPool(ctx, req) + if err != nil { + // TODO: Handle error. + } +} diff --git a/storagetransfer/go.mod b/storagetransfer/go.mod index 1529c1ff950..180d0ed296d 100644 --- a/storagetransfer/go.mod +++ b/storagetransfer/go.mod @@ -6,7 +6,7 @@ require ( cloud.google.com/go v0.100.2 github.com/googleapis/gax-go/v2 v2.2.0 google.golang.org/api v0.74.0 - google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb + google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf google.golang.org/grpc v1.45.0 google.golang.org/protobuf v1.28.0 ) diff --git a/storagetransfer/go.sum b/storagetransfer/go.sum index 4379775bc6f..0c961fc692e 100644 --- a/storagetransfer/go.sum +++ b/storagetransfer/go.sum @@ -537,8 +537,9 @@ google.golang.org/genproto v0.0.0-20220218161850-94dd64e39d7c/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= -google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb h1:0m9wktIpOxGw+SSKmydXWB3Z3GTfcPP6+q75HCQa6HI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf h1:JTjwKJX9erVpsw17w+OIPP7iAgEkN/r8urhWSunEDTs= +google.golang.org/genproto v0.0.0-20220405205423-9d709892a2bf/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=