From 2a93ca815e60aada1f5c56bfe6b80835af08b330 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Fri, 4 Sep 2020 00:07:12 +0000 Subject: [PATCH] feat(all): auto-regenerate gapics 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/440 --- analytics/admin/apiv1alpha/doc.go | 2 +- analytics/data/apiv1alpha/doc.go | 2 +- area120/tables/apiv1alpha1/doc.go | 2 +- asset/apiv1/doc.go | 2 +- asset/apiv1beta1/doc.go | 2 +- asset/apiv1p2beta1/doc.go | 2 +- asset/apiv1p5beta1/doc.go | 2 +- automl/apiv1/doc.go | 2 +- automl/apiv1beta1/doc.go | 2 +- bigquery/connection/apiv1/doc.go | 2 +- bigquery/connection/apiv1beta1/doc.go | 2 +- bigquery/datatransfer/apiv1/doc.go | 2 +- bigquery/reservation/apiv1/doc.go | 2 +- bigquery/reservation/apiv1beta1/doc.go | 2 +- bigquery/storage/apiv1/doc.go | 2 +- bigquery/storage/apiv1alpha2/doc.go | 2 +- bigquery/storage/apiv1beta1/doc.go | 2 +- bigquery/storage/apiv1beta2/doc.go | 2 +- billing/apiv1/doc.go | 2 +- billing/budgets/apiv1beta1/doc.go | 2 +- cloudbuild/apiv1/v2/doc.go | 2 +- cloudtasks/apiv2/doc.go | 2 +- cloudtasks/apiv2beta2/doc.go | 2 +- cloudtasks/apiv2beta3/doc.go | 2 +- container/apiv1/doc.go | 2 +- containeranalysis/apiv1beta1/doc.go | 2 +- datacatalog/apiv1/doc.go | 2 +- datacatalog/apiv1beta1/doc.go | 2 +- dataproc/apiv1/doc.go | 2 +- dataproc/apiv1beta2/doc.go | 2 +- datastore/admin/apiv1/doc.go | 2 +- debugger/apiv2/doc.go | 2 +- dialogflow/apiv2/doc.go | 2 +- dlp/apiv2/doc.go | 2 +- errorreporting/apiv1beta1/doc.go | 2 +- firestore/apiv1/admin/doc.go | 2 +- firestore/apiv1/doc.go | 2 +- functions/apiv1/doc.go | 2 +- gaming/apiv1/doc.go | 2 +- gaming/apiv1beta/doc.go | 2 +- iam/credentials/apiv1/doc.go | 2 +- iot/apiv1/doc.go | 2 +- kms/apiv1/doc.go | 2 +- language/apiv1/doc.go | 2 +- language/apiv1beta2/doc.go | 2 +- logging/apiv2/doc.go | 2 +- longrunning/autogen/doc.go | 2 +- memcache/apiv1beta2/doc.go | 2 +- monitoring/apiv3/v2/doc.go | 2 +- monitoring/dashboard/apiv1/doc.go | 2 +- notebooks/apiv1beta1/doc.go | 2 +- osconfig/agentendpoint/apiv1/doc.go | 2 +- osconfig/agentendpoint/apiv1beta/doc.go | 2 +- osconfig/apiv1/doc.go | 2 +- osconfig/apiv1beta/doc.go | 2 +- oslogin/apiv1/doc.go | 2 +- oslogin/apiv1beta/doc.go | 2 +- phishingprotection/apiv1beta1/doc.go | 2 +- policytroubleshooter/apiv1/doc.go | 2 +- pubsub/apiv1/doc.go | 2 +- pubsublite/apiv1/doc.go | 2 +- recaptchaenterprise/apiv1/doc.go | 2 +- recaptchaenterprise/apiv1beta1/doc.go | 2 +- recommender/apiv1/doc.go | 2 +- recommender/apiv1beta1/doc.go | 2 +- redis/apiv1/doc.go | 2 +- redis/apiv1beta1/doc.go | 2 +- scheduler/apiv1/doc.go | 2 +- scheduler/apiv1beta1/doc.go | 2 +- secretmanager/apiv1/doc.go | 2 +- secretmanager/apiv1beta1/doc.go | 2 +- .../certificate_authority_client.go | 683 ++++++++++-------- ...rtificate_authority_client_example_test.go | 279 +++---- security/privateca/apiv1beta1/doc.go | 2 +- securitycenter/apiv1/doc.go | 2 +- securitycenter/apiv1beta1/doc.go | 2 +- securitycenter/apiv1p1beta1/doc.go | 2 +- securitycenter/settings/apiv1beta1/doc.go | 2 +- servicedirectory/apiv1beta1/doc.go | 2 +- spanner/admin/database/apiv1/doc.go | 2 +- spanner/admin/instance/apiv1/doc.go | 2 +- spanner/apiv1/doc.go | 2 +- speech/apiv1/doc.go | 2 +- speech/apiv1p1beta1/doc.go | 2 +- talent/apiv4beta1/doc.go | 2 +- texttospeech/apiv1/doc.go | 2 +- trace/apiv1/doc.go | 2 +- trace/apiv2/doc.go | 2 +- translate/apiv3/doc.go | 2 +- video/transcoder/apiv1beta1/doc.go | 2 +- videointelligence/apiv1/doc.go | 2 +- videointelligence/apiv1beta2/doc.go | 2 +- vision/apiv1/doc.go | 2 +- vision/apiv1p1beta1/doc.go | 2 +- webrisk/apiv1/doc.go | 2 +- webrisk/apiv1beta1/doc.go | 2 +- workflows/apiv1beta/doc.go | 2 +- workflows/executions/apiv1beta/doc.go | 2 +- 98 files changed, 642 insertions(+), 512 deletions(-) diff --git a/analytics/admin/apiv1alpha/doc.go b/analytics/admin/apiv1alpha/doc.go index eb1d8def3abc..8745171451f4 100644 --- a/analytics/admin/apiv1alpha/doc.go +++ b/analytics/admin/apiv1alpha/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/analytics/data/apiv1alpha/doc.go b/analytics/data/apiv1alpha/doc.go index e6a6372e6c45..fc7497e8e8c0 100644 --- a/analytics/data/apiv1alpha/doc.go +++ b/analytics/data/apiv1alpha/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/area120/tables/apiv1alpha1/doc.go b/area120/tables/apiv1alpha1/doc.go index 40d5ae74164b..1c6276c897e9 100644 --- a/area120/tables/apiv1alpha1/doc.go +++ b/area120/tables/apiv1alpha1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/asset/apiv1/doc.go b/asset/apiv1/doc.go index c8194221ac79..68e2a2b5137b 100644 --- a/asset/apiv1/doc.go +++ b/asset/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/asset/apiv1beta1/doc.go b/asset/apiv1beta1/doc.go index 9f04a0b3027b..e1c3523ada43 100644 --- a/asset/apiv1beta1/doc.go +++ b/asset/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/asset/apiv1p2beta1/doc.go b/asset/apiv1p2beta1/doc.go index 2840beb97d67..d3df87beecb4 100644 --- a/asset/apiv1p2beta1/doc.go +++ b/asset/apiv1p2beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/asset/apiv1p5beta1/doc.go b/asset/apiv1p5beta1/doc.go index 234d429cad6d..d7adcf66d1a0 100644 --- a/asset/apiv1p5beta1/doc.go +++ b/asset/apiv1p5beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/automl/apiv1/doc.go b/automl/apiv1/doc.go index 3fce7a032099..1377f3579b01 100644 --- a/automl/apiv1/doc.go +++ b/automl/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/automl/apiv1beta1/doc.go b/automl/apiv1beta1/doc.go index 4f91ddd26523..7b99c4900144 100644 --- a/automl/apiv1beta1/doc.go +++ b/automl/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/connection/apiv1/doc.go b/bigquery/connection/apiv1/doc.go index e181f70e8d4d..f584ad99b9a6 100644 --- a/bigquery/connection/apiv1/doc.go +++ b/bigquery/connection/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/connection/apiv1beta1/doc.go b/bigquery/connection/apiv1beta1/doc.go index 4d06f7fdad33..34f190b2f59a 100644 --- a/bigquery/connection/apiv1beta1/doc.go +++ b/bigquery/connection/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/datatransfer/apiv1/doc.go b/bigquery/datatransfer/apiv1/doc.go index fe56766994ea..ebc08726cf97 100644 --- a/bigquery/datatransfer/apiv1/doc.go +++ b/bigquery/datatransfer/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/reservation/apiv1/doc.go b/bigquery/reservation/apiv1/doc.go index 90c6ffe83bdf..7c49b5157ca5 100644 --- a/bigquery/reservation/apiv1/doc.go +++ b/bigquery/reservation/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/reservation/apiv1beta1/doc.go b/bigquery/reservation/apiv1beta1/doc.go index 616549461dde..4f51cb52343e 100644 --- a/bigquery/reservation/apiv1beta1/doc.go +++ b/bigquery/reservation/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/storage/apiv1/doc.go b/bigquery/storage/apiv1/doc.go index 0688e5ce3e37..3f68846da417 100644 --- a/bigquery/storage/apiv1/doc.go +++ b/bigquery/storage/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/storage/apiv1alpha2/doc.go b/bigquery/storage/apiv1alpha2/doc.go index e6a7e9bf58de..97ff161ac626 100644 --- a/bigquery/storage/apiv1alpha2/doc.go +++ b/bigquery/storage/apiv1alpha2/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/storage/apiv1beta1/doc.go b/bigquery/storage/apiv1beta1/doc.go index f0abe9337025..d6aa4018846d 100644 --- a/bigquery/storage/apiv1beta1/doc.go +++ b/bigquery/storage/apiv1beta1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/bigquery/storage/apiv1beta2/doc.go b/bigquery/storage/apiv1beta2/doc.go index 588355bd0f6b..154d5672785e 100644 --- a/bigquery/storage/apiv1beta2/doc.go +++ b/bigquery/storage/apiv1beta2/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/billing/apiv1/doc.go b/billing/apiv1/doc.go index 9677901b086f..3d01c40aeac0 100644 --- a/billing/apiv1/doc.go +++ b/billing/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/billing/budgets/apiv1beta1/doc.go b/billing/budgets/apiv1beta1/doc.go index f7e93d67ea4a..46c6be0f2269 100644 --- a/billing/budgets/apiv1beta1/doc.go +++ b/billing/budgets/apiv1beta1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/cloudbuild/apiv1/v2/doc.go b/cloudbuild/apiv1/v2/doc.go index 5be8b3a01212..133ac6197c92 100644 --- a/cloudbuild/apiv1/v2/doc.go +++ b/cloudbuild/apiv1/v2/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/cloudtasks/apiv2/doc.go b/cloudtasks/apiv2/doc.go index 33c8e09d42ad..937201d189cb 100644 --- a/cloudtasks/apiv2/doc.go +++ b/cloudtasks/apiv2/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/cloudtasks/apiv2beta2/doc.go b/cloudtasks/apiv2beta2/doc.go index b71d7a6fa71b..70cf51b8f1b0 100644 --- a/cloudtasks/apiv2beta2/doc.go +++ b/cloudtasks/apiv2beta2/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/cloudtasks/apiv2beta3/doc.go b/cloudtasks/apiv2beta3/doc.go index 019082ee5b0f..f0de9fec8f1b 100644 --- a/cloudtasks/apiv2beta3/doc.go +++ b/cloudtasks/apiv2beta3/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/container/apiv1/doc.go b/container/apiv1/doc.go index 3d58929a0fc2..d587bf9f283b 100644 --- a/container/apiv1/doc.go +++ b/container/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/containeranalysis/apiv1beta1/doc.go b/containeranalysis/apiv1beta1/doc.go index 68ed9617ce5a..76447c10a078 100644 --- a/containeranalysis/apiv1beta1/doc.go +++ b/containeranalysis/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/datacatalog/apiv1/doc.go b/datacatalog/apiv1/doc.go index 93b01798cc2b..0bbc8e192acc 100644 --- a/datacatalog/apiv1/doc.go +++ b/datacatalog/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/datacatalog/apiv1beta1/doc.go b/datacatalog/apiv1beta1/doc.go index 8b8e549217a4..a4c4ad913e12 100644 --- a/datacatalog/apiv1beta1/doc.go +++ b/datacatalog/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/dataproc/apiv1/doc.go b/dataproc/apiv1/doc.go index 51fc669a21fe..e36638d8d087 100644 --- a/dataproc/apiv1/doc.go +++ b/dataproc/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/dataproc/apiv1beta2/doc.go b/dataproc/apiv1beta2/doc.go index fee3b103a980..32e75187c6b5 100644 --- a/dataproc/apiv1beta2/doc.go +++ b/dataproc/apiv1beta2/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/datastore/admin/apiv1/doc.go b/datastore/admin/apiv1/doc.go index 1c49bd4dcea4..53d7b5a57c63 100644 --- a/datastore/admin/apiv1/doc.go +++ b/datastore/admin/apiv1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/debugger/apiv2/doc.go b/debugger/apiv2/doc.go index 5cfff35b668d..db12174e1d68 100644 --- a/debugger/apiv2/doc.go +++ b/debugger/apiv2/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/dialogflow/apiv2/doc.go b/dialogflow/apiv2/doc.go index 5abfebeb9766..72b392a88542 100644 --- a/dialogflow/apiv2/doc.go +++ b/dialogflow/apiv2/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/dlp/apiv2/doc.go b/dlp/apiv2/doc.go index 0416aa8cb3be..00de3c47013f 100644 --- a/dlp/apiv2/doc.go +++ b/dlp/apiv2/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/errorreporting/apiv1beta1/doc.go b/errorreporting/apiv1beta1/doc.go index 14fa61515962..59436e913cb9 100644 --- a/errorreporting/apiv1beta1/doc.go +++ b/errorreporting/apiv1beta1/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/firestore/apiv1/admin/doc.go b/firestore/apiv1/admin/doc.go index a1089ca8231f..758db8dec47f 100644 --- a/firestore/apiv1/admin/doc.go +++ b/firestore/apiv1/admin/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/firestore/apiv1/doc.go b/firestore/apiv1/doc.go index c1aa642ab5f7..5edb8044f906 100644 --- a/firestore/apiv1/doc.go +++ b/firestore/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/functions/apiv1/doc.go b/functions/apiv1/doc.go index ea9c6b707f55..60789f8aaef7 100644 --- a/functions/apiv1/doc.go +++ b/functions/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/gaming/apiv1/doc.go b/gaming/apiv1/doc.go index 9e7a3d90692e..669615a7e04c 100644 --- a/gaming/apiv1/doc.go +++ b/gaming/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/gaming/apiv1beta/doc.go b/gaming/apiv1beta/doc.go index c0497c21455b..27ba8143ac5e 100644 --- a/gaming/apiv1beta/doc.go +++ b/gaming/apiv1beta/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/iam/credentials/apiv1/doc.go b/iam/credentials/apiv1/doc.go index b33cdccb1122..03730c0cbbe5 100644 --- a/iam/credentials/apiv1/doc.go +++ b/iam/credentials/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/iot/apiv1/doc.go b/iot/apiv1/doc.go index e192079498e3..309b969d7ef4 100644 --- a/iot/apiv1/doc.go +++ b/iot/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/kms/apiv1/doc.go b/kms/apiv1/doc.go index 883625843a66..7ec93adf09de 100644 --- a/kms/apiv1/doc.go +++ b/kms/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/language/apiv1/doc.go b/language/apiv1/doc.go index 12b27d41cfeb..268a9429eb3e 100644 --- a/language/apiv1/doc.go +++ b/language/apiv1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/language/apiv1beta2/doc.go b/language/apiv1beta2/doc.go index 25f0c3ba0d22..b34bd70fb058 100644 --- a/language/apiv1beta2/doc.go +++ b/language/apiv1beta2/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/logging/apiv2/doc.go b/logging/apiv2/doc.go index f8a06c1cc6de..ed8c14e5e5b0 100644 --- a/logging/apiv2/doc.go +++ b/logging/apiv2/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/longrunning/autogen/doc.go b/longrunning/autogen/doc.go index 56d7cee7d604..cc6c37c08313 100644 --- a/longrunning/autogen/doc.go +++ b/longrunning/autogen/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/memcache/apiv1beta2/doc.go b/memcache/apiv1beta2/doc.go index 8c7a61b70306..fa67f5194907 100644 --- a/memcache/apiv1beta2/doc.go +++ b/memcache/apiv1beta2/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/monitoring/apiv3/v2/doc.go b/monitoring/apiv3/v2/doc.go index 6c827bd953f9..4e975ed8a856 100644 --- a/monitoring/apiv3/v2/doc.go +++ b/monitoring/apiv3/v2/doc.go @@ -53,7 +53,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/monitoring/dashboard/apiv1/doc.go b/monitoring/dashboard/apiv1/doc.go index 031ee03fd6a3..69d1da5513fb 100644 --- a/monitoring/dashboard/apiv1/doc.go +++ b/monitoring/dashboard/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/notebooks/apiv1beta1/doc.go b/notebooks/apiv1beta1/doc.go index 39b2d18e143c..90b7cc4302d2 100644 --- a/notebooks/apiv1beta1/doc.go +++ b/notebooks/apiv1beta1/doc.go @@ -53,7 +53,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/osconfig/agentendpoint/apiv1/doc.go b/osconfig/agentendpoint/apiv1/doc.go index 2f880a080572..c14cf9fede72 100644 --- a/osconfig/agentendpoint/apiv1/doc.go +++ b/osconfig/agentendpoint/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/osconfig/agentendpoint/apiv1beta/doc.go b/osconfig/agentendpoint/apiv1beta/doc.go index 3b659dfd9c47..5e4a122b77ff 100644 --- a/osconfig/agentendpoint/apiv1beta/doc.go +++ b/osconfig/agentendpoint/apiv1beta/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/osconfig/apiv1/doc.go b/osconfig/apiv1/doc.go index d3fc1f5deec6..ec4b5bea4674 100644 --- a/osconfig/apiv1/doc.go +++ b/osconfig/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/osconfig/apiv1beta/doc.go b/osconfig/apiv1beta/doc.go index 6c8936b9a04f..0f65baa24c65 100644 --- a/osconfig/apiv1beta/doc.go +++ b/osconfig/apiv1beta/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/oslogin/apiv1/doc.go b/oslogin/apiv1/doc.go index 1fb26141c6c2..11a21c97acc2 100644 --- a/oslogin/apiv1/doc.go +++ b/oslogin/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/oslogin/apiv1beta/doc.go b/oslogin/apiv1beta/doc.go index affd7f295149..7a9fee8f05d0 100644 --- a/oslogin/apiv1beta/doc.go +++ b/oslogin/apiv1beta/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/phishingprotection/apiv1beta1/doc.go b/phishingprotection/apiv1beta1/doc.go index bc45509693ab..6afe61ce9ce2 100644 --- a/phishingprotection/apiv1beta1/doc.go +++ b/phishingprotection/apiv1beta1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/policytroubleshooter/apiv1/doc.go b/policytroubleshooter/apiv1/doc.go index 2265e917f7d1..a6b546d9475f 100644 --- a/policytroubleshooter/apiv1/doc.go +++ b/policytroubleshooter/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/pubsub/apiv1/doc.go b/pubsub/apiv1/doc.go index aa114ee24f1d..ee9cf2803dd8 100644 --- a/pubsub/apiv1/doc.go +++ b/pubsub/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/pubsublite/apiv1/doc.go b/pubsublite/apiv1/doc.go index 0a5b15e6a405..83f3ff192ab8 100644 --- a/pubsublite/apiv1/doc.go +++ b/pubsublite/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/recaptchaenterprise/apiv1/doc.go b/recaptchaenterprise/apiv1/doc.go index e6296f84730b..744770588375 100644 --- a/recaptchaenterprise/apiv1/doc.go +++ b/recaptchaenterprise/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/recaptchaenterprise/apiv1beta1/doc.go b/recaptchaenterprise/apiv1beta1/doc.go index e11f39a1d364..b2f19e23b662 100644 --- a/recaptchaenterprise/apiv1beta1/doc.go +++ b/recaptchaenterprise/apiv1beta1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/recommender/apiv1/doc.go b/recommender/apiv1/doc.go index 5176368922aa..a6618cc46eeb 100644 --- a/recommender/apiv1/doc.go +++ b/recommender/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/recommender/apiv1beta1/doc.go b/recommender/apiv1beta1/doc.go index 080faad63513..52e2c69ac9bd 100644 --- a/recommender/apiv1beta1/doc.go +++ b/recommender/apiv1beta1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/redis/apiv1/doc.go b/redis/apiv1/doc.go index 4cd5ea7178e0..406011054fd6 100644 --- a/redis/apiv1/doc.go +++ b/redis/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/redis/apiv1beta1/doc.go b/redis/apiv1beta1/doc.go index a4342b0df0ce..de47b2e6f0d7 100644 --- a/redis/apiv1beta1/doc.go +++ b/redis/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/scheduler/apiv1/doc.go b/scheduler/apiv1/doc.go index fbaee8c9e849..7d44ad239b50 100644 --- a/scheduler/apiv1/doc.go +++ b/scheduler/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/scheduler/apiv1beta1/doc.go b/scheduler/apiv1beta1/doc.go index e3078a6842b2..246e12b1620e 100644 --- a/scheduler/apiv1beta1/doc.go +++ b/scheduler/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/secretmanager/apiv1/doc.go b/secretmanager/apiv1/doc.go index 9ae23de19f95..ea345f247a76 100644 --- a/secretmanager/apiv1/doc.go +++ b/secretmanager/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/secretmanager/apiv1beta1/doc.go b/secretmanager/apiv1beta1/doc.go index 7349d4c2774a..f698bfb25ffa 100644 --- a/secretmanager/apiv1beta1/doc.go +++ b/secretmanager/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/security/privateca/apiv1beta1/certificate_authority_client.go b/security/privateca/apiv1beta1/certificate_authority_client.go index 471257af146c..48694b92dd65 100644 --- a/security/privateca/apiv1beta1/certificate_authority_client.go +++ b/security/privateca/apiv1beta1/certificate_authority_client.go @@ -41,29 +41,30 @@ var newCertificateAuthorityClientHook clientHook // CertificateAuthorityCallOptions contains the retry settings for each method of CertificateAuthorityClient. type CertificateAuthorityCallOptions struct { - ListCertificateAuthorities []gax.CallOption - ListCertificateRevocationLists []gax.CallOption - ListCertificates []gax.CallOption - ListReusableConfigs []gax.CallOption - GetCertificateAuthority []gax.CallOption - GetCertificateRevocationList []gax.CallOption - GetCertificate []gax.CallOption - GetReusableConfig []gax.CallOption - CreateCertificateAuthority []gax.CallOption - CreateCertificateRevocationList []gax.CallOption CreateCertificate []gax.CallOption - CreateReusableConfig []gax.CallOption - UpdateCertificateAuthority []gax.CallOption - UpdateCertificateRevocationList []gax.CallOption + GetCertificate []gax.CallOption + ListCertificates []gax.CallOption + RevokeCertificate []gax.CallOption UpdateCertificate []gax.CallOption - UpdateReusableConfig []gax.CallOption - GetCertificateAuthorityCsr []gax.CallOption ActivateCertificateAuthority []gax.CallOption + CreateCertificateAuthority []gax.CallOption DisableCertificateAuthority []gax.CallOption EnableCertificateAuthority []gax.CallOption - ScheduleDeleteCertificateAuthority []gax.CallOption + FetchCertificateAuthorityCsr []gax.CallOption + GetCertificateAuthority []gax.CallOption + ListCertificateAuthorities []gax.CallOption RestoreCertificateAuthority []gax.CallOption - RevokeCertificate []gax.CallOption + ScheduleDeleteCertificateAuthority []gax.CallOption + UpdateCertificateAuthority []gax.CallOption + CreateCertificateRevocationList []gax.CallOption + GetCertificateRevocationList []gax.CallOption + ListCertificateRevocationLists []gax.CallOption + UpdateCertificateRevocationList []gax.CallOption + CreateReusableConfig []gax.CallOption + DeleteReusableConfig []gax.CallOption + GetReusableConfig []gax.CallOption + ListReusableConfigs []gax.CallOption + UpdateReusableConfig []gax.CallOption } func defaultCertificateAuthorityClientOptions() []option.ClientOption { @@ -78,7 +79,7 @@ func defaultCertificateAuthorityClientOptions() []option.ClientOption { func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { return &CertificateAuthorityCallOptions{ - ListCertificateAuthorities: []gax.CallOption{ + CreateCertificate: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -91,7 +92,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - ListCertificateRevocationLists: []gax.CallOption{ + GetCertificate: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -117,7 +118,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - ListReusableConfigs: []gax.CallOption{ + RevokeCertificate: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -130,7 +131,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - GetCertificateAuthority: []gax.CallOption{ + UpdateCertificate: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -143,7 +144,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - GetCertificateRevocationList: []gax.CallOption{ + ActivateCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -156,7 +157,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - GetCertificate: []gax.CallOption{ + CreateCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -169,7 +170,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - GetReusableConfig: []gax.CallOption{ + DisableCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -182,7 +183,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - CreateCertificateAuthority: []gax.CallOption{ + EnableCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -195,7 +196,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - CreateCertificateRevocationList: []gax.CallOption{ + FetchCertificateAuthorityCsr: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -208,7 +209,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - CreateCertificate: []gax.CallOption{ + GetCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -221,7 +222,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - CreateReusableConfig: []gax.CallOption{ + ListCertificateAuthorities: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -234,7 +235,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - UpdateCertificateAuthority: []gax.CallOption{ + RestoreCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -247,7 +248,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - UpdateCertificateRevocationList: []gax.CallOption{ + ScheduleDeleteCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -260,7 +261,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - UpdateCertificate: []gax.CallOption{ + UpdateCertificateAuthority: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -273,7 +274,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - UpdateReusableConfig: []gax.CallOption{ + CreateCertificateRevocationList: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -286,7 +287,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - GetCertificateAuthorityCsr: []gax.CallOption{ + GetCertificateRevocationList: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -299,7 +300,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - ActivateCertificateAuthority: []gax.CallOption{ + ListCertificateRevocationLists: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -312,7 +313,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - DisableCertificateAuthority: []gax.CallOption{ + UpdateCertificateRevocationList: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -325,7 +326,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - EnableCertificateAuthority: []gax.CallOption{ + CreateReusableConfig: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -338,7 +339,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - ScheduleDeleteCertificateAuthority: []gax.CallOption{ + DeleteReusableConfig: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -351,7 +352,7 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - RestoreCertificateAuthority: []gax.CallOption{ + GetReusableConfig: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -364,7 +365,20 @@ func defaultCertificateAuthorityCallOptions() *CertificateAuthorityCallOptions { }) }), }, - RevokeCertificate: []gax.CallOption{ + ListReusableConfigs: []gax.CallOption{ + gax.WithRetry(func() gax.Retryer { + return gax.OnCodes([]codes.Code{ + codes.Unknown, + codes.Unavailable, + codes.DeadlineExceeded, + }, gax.Backoff{ + Initial: 100 * time.Millisecond, + Max: 60000 * time.Millisecond, + Multiplier: 1.30, + }) + }), + }, + UpdateReusableConfig: []gax.CallOption{ gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.Unknown, @@ -473,86 +487,49 @@ func (c *CertificateAuthorityClient) setGoogleClientInfo(keyval ...string) { c.xGoogMetadata = metadata.Pairs("x-goog-api-client", gax.XGoogHeader(kv...)) } -// ListCertificateAuthorities lists CertificateAuthorities. -func (c *CertificateAuthorityClient) ListCertificateAuthorities(ctx context.Context, req *privatecapb.ListCertificateAuthoritiesRequest, opts ...gax.CallOption) *CertificateAuthorityIterator { +// CreateCertificate create a new Certificate in a given Project, Location from a particular +// CertificateAuthority. +func (c *CertificateAuthorityClient) CreateCertificate(ctx context.Context, req *privatecapb.CreateCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + defer cancel() + ctx = cctx + } md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.ListCertificateAuthorities[0:len(c.CallOptions.ListCertificateAuthorities):len(c.CallOptions.ListCertificateAuthorities)], opts...) - it := &CertificateAuthorityIterator{} - req = proto.Clone(req).(*privatecapb.ListCertificateAuthoritiesRequest) - it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.CertificateAuthority, string, error) { - var resp *privatecapb.ListCertificateAuthoritiesResponse - req.PageToken = pageToken - if pageSize > math.MaxInt32 { - req.PageSize = math.MaxInt32 - } else { - req.PageSize = int32(pageSize) - } - err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { - var err error - resp, err = c.certificateAuthorityClient.ListCertificateAuthorities(ctx, req, settings.GRPC...) - return err - }, opts...) - if err != nil { - return nil, "", err - } - - it.Response = resp - return resp.GetCertificateAuthorities(), 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 + opts = append(c.CallOptions.CreateCertificate[0:len(c.CallOptions.CreateCertificate):len(c.CallOptions.CreateCertificate)], opts...) + var resp *privatecapb.Certificate + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.certificateAuthorityClient.CreateCertificate(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err } - it.pageInfo, it.nextFunc = iterator.NewPageInfo(fetch, it.bufLen, it.takeBuf) - it.pageInfo.MaxSize = int(req.GetPageSize()) - it.pageInfo.Token = req.GetPageToken() - return it + return resp, nil } -// ListCertificateRevocationLists lists CertificateRevocationLists. -func (c *CertificateAuthorityClient) ListCertificateRevocationLists(ctx context.Context, req *privatecapb.ListCertificateRevocationListsRequest, opts ...gax.CallOption) *CertificateRevocationListIterator { - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) - ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.ListCertificateRevocationLists[0:len(c.CallOptions.ListCertificateRevocationLists):len(c.CallOptions.ListCertificateRevocationLists)], opts...) - it := &CertificateRevocationListIterator{} - req = proto.Clone(req).(*privatecapb.ListCertificateRevocationListsRequest) - it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.CertificateRevocationList, string, error) { - var resp *privatecapb.ListCertificateRevocationListsResponse - req.PageToken = pageToken - if pageSize > math.MaxInt32 { - req.PageSize = math.MaxInt32 - } else { - req.PageSize = int32(pageSize) - } - err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { - var err error - resp, err = c.certificateAuthorityClient.ListCertificateRevocationLists(ctx, req, settings.GRPC...) - return err - }, opts...) - if err != nil { - return nil, "", err - } - - it.Response = resp - return resp.GetCertificateRevocationLists(), resp.GetNextPageToken(), nil +// GetCertificate returns a Certificate. +func (c *CertificateAuthorityClient) GetCertificate(ctx context.Context, req *privatecapb.GetCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { + if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { + cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) + defer cancel() + ctx = cctx } - 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 + 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.GetCertificate[0:len(c.CallOptions.GetCertificate):len(c.CallOptions.GetCertificate)], opts...) + var resp *privatecapb.Certificate + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.certificateAuthorityClient.GetCertificate(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err } - it.pageInfo, it.nextFunc = iterator.NewPageInfo(fetch, it.bufLen, it.takeBuf) - it.pageInfo.MaxSize = int(req.GetPageSize()) - it.pageInfo.Token = req.GetPageToken() - return it + return resp, nil } // ListCertificates lists Certificates. @@ -596,49 +573,8 @@ func (c *CertificateAuthorityClient) ListCertificates(ctx context.Context, req * return it } -// ListReusableConfigs lists ReusableConfigs. -func (c *CertificateAuthorityClient) ListReusableConfigs(ctx context.Context, req *privatecapb.ListReusableConfigsRequest, opts ...gax.CallOption) *ReusableConfigIterator { - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) - ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.ListReusableConfigs[0:len(c.CallOptions.ListReusableConfigs):len(c.CallOptions.ListReusableConfigs)], opts...) - it := &ReusableConfigIterator{} - req = proto.Clone(req).(*privatecapb.ListReusableConfigsRequest) - it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.ReusableConfig, string, error) { - var resp *privatecapb.ListReusableConfigsResponse - req.PageToken = pageToken - if pageSize > math.MaxInt32 { - req.PageSize = math.MaxInt32 - } else { - req.PageSize = int32(pageSize) - } - err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { - var err error - resp, err = c.certificateAuthorityClient.ListReusableConfigs(ctx, req, settings.GRPC...) - return err - }, opts...) - if err != nil { - return nil, "", err - } - - it.Response = resp - return resp.GetReusableConfigs(), 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 -} - -// GetCertificateAuthority returns a CertificateAuthority. -func (c *CertificateAuthorityClient) GetCertificateAuthority(ctx context.Context, req *privatecapb.GetCertificateAuthorityRequest, opts ...gax.CallOption) (*privatecapb.CertificateAuthority, error) { +// RevokeCertificate revoke a Certificate. +func (c *CertificateAuthorityClient) RevokeCertificate(ctx context.Context, req *privatecapb.RevokeCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() @@ -646,11 +582,11 @@ func (c *CertificateAuthorityClient) GetCertificateAuthority(ctx context.Context } 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.GetCertificateAuthority[0:len(c.CallOptions.GetCertificateAuthority):len(c.CallOptions.GetCertificateAuthority)], opts...) - var resp *privatecapb.CertificateAuthority + opts = append(c.CallOptions.RevokeCertificate[0:len(c.CallOptions.RevokeCertificate):len(c.CallOptions.RevokeCertificate)], opts...) + var resp *privatecapb.Certificate err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.GetCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.RevokeCertificate(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { @@ -659,20 +595,20 @@ func (c *CertificateAuthorityClient) GetCertificateAuthority(ctx context.Context return resp, nil } -// GetCertificateRevocationList returns a CertificateRevocationList. -func (c *CertificateAuthorityClient) GetCertificateRevocationList(ctx context.Context, req *privatecapb.GetCertificateRevocationListRequest, opts ...gax.CallOption) (*privatecapb.CertificateRevocationList, error) { +// UpdateCertificate update a Certificate. +func (c *CertificateAuthorityClient) UpdateCertificate(ctx context.Context, req *privatecapb.UpdateCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate.name", url.QueryEscape(req.GetCertificate().GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.GetCertificateRevocationList[0:len(c.CallOptions.GetCertificateRevocationList):len(c.CallOptions.GetCertificateRevocationList)], opts...) - var resp *privatecapb.CertificateRevocationList + opts = append(c.CallOptions.UpdateCertificate[0:len(c.CallOptions.UpdateCertificate):len(c.CallOptions.UpdateCertificate)], opts...) + var resp *privatecapb.Certificate err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.GetCertificateRevocationList(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.UpdateCertificate(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { @@ -681,8 +617,13 @@ func (c *CertificateAuthorityClient) GetCertificateRevocationList(ctx context.Co return resp, nil } -// GetCertificate returns a Certificate. -func (c *CertificateAuthorityClient) GetCertificate(ctx context.Context, req *privatecapb.GetCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { +// ActivateCertificateAuthority activate a CertificateAuthority that is in state +// PENDING_ACTIVATION and is +// of type SUBORDINATE. After the +// parent Certificate Authority signs a certificate signing request from +// FetchCertificateAuthorityCsr, this method can complete the activation +// process. +func (c *CertificateAuthorityClient) ActivateCertificateAuthority(ctx context.Context, req *privatecapb.ActivateCertificateAuthorityRequest, opts ...gax.CallOption) (*ActivateCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() @@ -690,105 +631,113 @@ func (c *CertificateAuthorityClient) GetCertificate(ctx context.Context, req *pr } 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.GetCertificate[0:len(c.CallOptions.GetCertificate):len(c.CallOptions.GetCertificate)], opts...) - var resp *privatecapb.Certificate + opts = append(c.CallOptions.ActivateCertificateAuthority[0:len(c.CallOptions.ActivateCertificateAuthority):len(c.CallOptions.ActivateCertificateAuthority)], opts...) + var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.GetCertificate(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.ActivateCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return resp, nil + return &ActivateCertificateAuthorityOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, resp), + }, nil } -// GetReusableConfig returns a ReusableConfig. -func (c *CertificateAuthorityClient) GetReusableConfig(ctx context.Context, req *privatecapb.GetReusableConfigRequest, opts ...gax.CallOption) (*privatecapb.ReusableConfig, error) { +// CreateCertificateAuthority create a new CertificateAuthority in a given Project and Location. +func (c *CertificateAuthorityClient) CreateCertificateAuthority(ctx context.Context, req *privatecapb.CreateCertificateAuthorityRequest, opts ...gax.CallOption) (*CreateCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.GetReusableConfig[0:len(c.CallOptions.GetReusableConfig):len(c.CallOptions.GetReusableConfig)], opts...) - var resp *privatecapb.ReusableConfig + opts = append(c.CallOptions.CreateCertificateAuthority[0:len(c.CallOptions.CreateCertificateAuthority):len(c.CallOptions.CreateCertificateAuthority)], opts...) + var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.GetReusableConfig(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.CreateCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return resp, nil + return &CreateCertificateAuthorityOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, resp), + }, nil } -// CreateCertificateAuthority create a new CertificateAuthority in a given Project and Location. -func (c *CertificateAuthorityClient) CreateCertificateAuthority(ctx context.Context, req *privatecapb.CreateCertificateAuthorityRequest, opts ...gax.CallOption) (*CreateCertificateAuthorityOperation, error) { +// DisableCertificateAuthority disable a CertificateAuthority. +func (c *CertificateAuthorityClient) DisableCertificateAuthority(ctx context.Context, req *privatecapb.DisableCertificateAuthorityRequest, opts ...gax.CallOption) (*DisableCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + 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.CreateCertificateAuthority[0:len(c.CallOptions.CreateCertificateAuthority):len(c.CallOptions.CreateCertificateAuthority)], opts...) + opts = append(c.CallOptions.DisableCertificateAuthority[0:len(c.CallOptions.DisableCertificateAuthority):len(c.CallOptions.DisableCertificateAuthority)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.CreateCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.DisableCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &CreateCertificateAuthorityOperation{ + return &DisableCertificateAuthorityOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// CreateCertificateRevocationList create a new CertificateRevocationList in a given Project, Location -// for a particular CertificateAuthority. -func (c *CertificateAuthorityClient) CreateCertificateRevocationList(ctx context.Context, req *privatecapb.CreateCertificateRevocationListRequest, opts ...gax.CallOption) (*CreateCertificateRevocationListOperation, error) { +// EnableCertificateAuthority enable a CertificateAuthority. +func (c *CertificateAuthorityClient) EnableCertificateAuthority(ctx context.Context, req *privatecapb.EnableCertificateAuthorityRequest, opts ...gax.CallOption) (*EnableCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + 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.CreateCertificateRevocationList[0:len(c.CallOptions.CreateCertificateRevocationList):len(c.CallOptions.CreateCertificateRevocationList)], opts...) + opts = append(c.CallOptions.EnableCertificateAuthority[0:len(c.CallOptions.EnableCertificateAuthority):len(c.CallOptions.EnableCertificateAuthority)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.CreateCertificateRevocationList(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.EnableCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &CreateCertificateRevocationListOperation{ + return &EnableCertificateAuthorityOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// CreateCertificate create a new Certificate in a given Project, Location from a particular -// CertificateAuthority. -func (c *CertificateAuthorityClient) CreateCertificate(ctx context.Context, req *privatecapb.CreateCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { +// FetchCertificateAuthorityCsr fetch a certificate signing request (CSR) from a CertificateAuthority +// that is in state +// PENDING_ACTIVATION and is +// of type SUBORDINATE. The CSR must +// then be signed by the desired parent Certificate Authority, which could be +// another CertificateAuthority resource, or could be an on-prem +// certificate authority. See also ActivateCertificateAuthority. +func (c *CertificateAuthorityClient) FetchCertificateAuthorityCsr(ctx context.Context, req *privatecapb.FetchCertificateAuthorityCsrRequest, opts ...gax.CallOption) (*privatecapb.FetchCertificateAuthorityCsrResponse, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + 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.CreateCertificate[0:len(c.CallOptions.CreateCertificate):len(c.CallOptions.CreateCertificate)], opts...) - var resp *privatecapb.Certificate + opts = append(c.CallOptions.FetchCertificateAuthorityCsr[0:len(c.CallOptions.FetchCertificateAuthorityCsr):len(c.CallOptions.FetchCertificateAuthorityCsr)], opts...) + var resp *privatecapb.FetchCertificateAuthorityCsrResponse err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.CreateCertificate(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.FetchCertificateAuthorityCsr(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { @@ -797,126 +746,168 @@ func (c *CertificateAuthorityClient) CreateCertificate(ctx context.Context, req return resp, nil } -// CreateReusableConfig create a new ReusableConfig in a given Project and Location. -func (c *CertificateAuthorityClient) CreateReusableConfig(ctx context.Context, req *privatecapb.CreateReusableConfigRequest, opts ...gax.CallOption) (*CreateReusableConfigOperation, error) { +// GetCertificateAuthority returns a CertificateAuthority. +func (c *CertificateAuthorityClient) GetCertificateAuthority(ctx context.Context, req *privatecapb.GetCertificateAuthorityRequest, opts ...gax.CallOption) (*privatecapb.CertificateAuthority, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + 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.CreateReusableConfig[0:len(c.CallOptions.CreateReusableConfig):len(c.CallOptions.CreateReusableConfig)], opts...) - var resp *longrunningpb.Operation + opts = append(c.CallOptions.GetCertificateAuthority[0:len(c.CallOptions.GetCertificateAuthority):len(c.CallOptions.GetCertificateAuthority)], opts...) + var resp *privatecapb.CertificateAuthority err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.CreateReusableConfig(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.GetCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &CreateReusableConfigOperation{ - lro: longrunning.InternalNewOperation(c.LROClient, resp), - }, nil + return resp, nil } -// UpdateCertificateAuthority update a CertificateAuthority. -func (c *CertificateAuthorityClient) UpdateCertificateAuthority(ctx context.Context, req *privatecapb.UpdateCertificateAuthorityRequest, opts ...gax.CallOption) (*UpdateCertificateAuthorityOperation, error) { +// ListCertificateAuthorities lists CertificateAuthorities. +func (c *CertificateAuthorityClient) ListCertificateAuthorities(ctx context.Context, req *privatecapb.ListCertificateAuthoritiesRequest, opts ...gax.CallOption) *CertificateAuthorityIterator { + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append(c.CallOptions.ListCertificateAuthorities[0:len(c.CallOptions.ListCertificateAuthorities):len(c.CallOptions.ListCertificateAuthorities)], opts...) + it := &CertificateAuthorityIterator{} + req = proto.Clone(req).(*privatecapb.ListCertificateAuthoritiesRequest) + it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.CertificateAuthority, string, error) { + var resp *privatecapb.ListCertificateAuthoritiesResponse + req.PageToken = pageToken + if pageSize > math.MaxInt32 { + req.PageSize = math.MaxInt32 + } else { + req.PageSize = int32(pageSize) + } + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.certificateAuthorityClient.ListCertificateAuthorities(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, "", err + } + + it.Response = resp + return resp.GetCertificateAuthorities(), 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 +} + +// RestoreCertificateAuthority restore a CertificateAuthority that is scheduled for deletion. +func (c *CertificateAuthorityClient) RestoreCertificateAuthority(ctx context.Context, req *privatecapb.RestoreCertificateAuthorityRequest, opts ...gax.CallOption) (*RestoreCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate_authority.name", url.QueryEscape(req.GetCertificateAuthority().GetName()))) + 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.UpdateCertificateAuthority[0:len(c.CallOptions.UpdateCertificateAuthority):len(c.CallOptions.UpdateCertificateAuthority)], opts...) + opts = append(c.CallOptions.RestoreCertificateAuthority[0:len(c.CallOptions.RestoreCertificateAuthority):len(c.CallOptions.RestoreCertificateAuthority)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.UpdateCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.RestoreCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &UpdateCertificateAuthorityOperation{ + return &RestoreCertificateAuthorityOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// UpdateCertificateRevocationList update a CertificateRevocationList. -func (c *CertificateAuthorityClient) UpdateCertificateRevocationList(ctx context.Context, req *privatecapb.UpdateCertificateRevocationListRequest, opts ...gax.CallOption) (*UpdateCertificateRevocationListOperation, error) { +// ScheduleDeleteCertificateAuthority schedule a CertificateAuthority for deletion. +func (c *CertificateAuthorityClient) ScheduleDeleteCertificateAuthority(ctx context.Context, req *privatecapb.ScheduleDeleteCertificateAuthorityRequest, opts ...gax.CallOption) (*ScheduleDeleteCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate_revocation_list.name", url.QueryEscape(req.GetCertificateRevocationList().GetName()))) + 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.UpdateCertificateRevocationList[0:len(c.CallOptions.UpdateCertificateRevocationList):len(c.CallOptions.UpdateCertificateRevocationList)], opts...) + opts = append(c.CallOptions.ScheduleDeleteCertificateAuthority[0:len(c.CallOptions.ScheduleDeleteCertificateAuthority):len(c.CallOptions.ScheduleDeleteCertificateAuthority)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.UpdateCertificateRevocationList(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.ScheduleDeleteCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &UpdateCertificateRevocationListOperation{ + return &ScheduleDeleteCertificateAuthorityOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// UpdateCertificate update a Certificate. -func (c *CertificateAuthorityClient) UpdateCertificate(ctx context.Context, req *privatecapb.UpdateCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { +// UpdateCertificateAuthority update a CertificateAuthority. +func (c *CertificateAuthorityClient) UpdateCertificateAuthority(ctx context.Context, req *privatecapb.UpdateCertificateAuthorityRequest, opts ...gax.CallOption) (*UpdateCertificateAuthorityOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate.name", url.QueryEscape(req.GetCertificate().GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate_authority.name", url.QueryEscape(req.GetCertificateAuthority().GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.UpdateCertificate[0:len(c.CallOptions.UpdateCertificate):len(c.CallOptions.UpdateCertificate)], opts...) - var resp *privatecapb.Certificate + opts = append(c.CallOptions.UpdateCertificateAuthority[0:len(c.CallOptions.UpdateCertificateAuthority):len(c.CallOptions.UpdateCertificateAuthority)], opts...) + var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.UpdateCertificate(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.UpdateCertificateAuthority(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return resp, nil + return &UpdateCertificateAuthorityOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, resp), + }, nil } -// UpdateReusableConfig update a ReusableConfig. -func (c *CertificateAuthorityClient) UpdateReusableConfig(ctx context.Context, req *privatecapb.UpdateReusableConfigRequest, opts ...gax.CallOption) (*UpdateReusableConfigOperation, error) { +// CreateCertificateRevocationList create a new CertificateRevocationList in a given Project, Location +// for a particular CertificateAuthority. +func (c *CertificateAuthorityClient) CreateCertificateRevocationList(ctx context.Context, req *privatecapb.CreateCertificateRevocationListRequest, opts ...gax.CallOption) (*CreateCertificateRevocationListOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "reusable_config.name", url.QueryEscape(req.GetReusableConfig().GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.UpdateReusableConfig[0:len(c.CallOptions.UpdateReusableConfig):len(c.CallOptions.UpdateReusableConfig)], opts...) + opts = append(c.CallOptions.CreateCertificateRevocationList[0:len(c.CallOptions.CreateCertificateRevocationList):len(c.CallOptions.CreateCertificateRevocationList)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.UpdateReusableConfig(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.CreateCertificateRevocationList(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &UpdateReusableConfigOperation{ + return &CreateCertificateRevocationListOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// GetCertificateAuthorityCsr get the CSR for a pending CertificateAuthority. -func (c *CertificateAuthorityClient) GetCertificateAuthorityCsr(ctx context.Context, req *privatecapb.GetCertificateAuthorityCsrRequest, opts ...gax.CallOption) (*privatecapb.GetCertificateAuthorityCsrResponse, error) { +// GetCertificateRevocationList returns a CertificateRevocationList. +func (c *CertificateAuthorityClient) GetCertificateRevocationList(ctx context.Context, req *privatecapb.GetCertificateRevocationListRequest, opts ...gax.CallOption) (*privatecapb.CertificateRevocationList, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() @@ -924,11 +915,11 @@ func (c *CertificateAuthorityClient) GetCertificateAuthorityCsr(ctx context.Cont } 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.GetCertificateAuthorityCsr[0:len(c.CallOptions.GetCertificateAuthorityCsr):len(c.CallOptions.GetCertificateAuthorityCsr)], opts...) - var resp *privatecapb.GetCertificateAuthorityCsrResponse + opts = append(c.CallOptions.GetCertificateRevocationList[0:len(c.CallOptions.GetCertificateRevocationList):len(c.CallOptions.GetCertificateRevocationList)], opts...) + var resp *privatecapb.CertificateRevocationList err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.GetCertificateAuthorityCsr(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.GetCertificateRevocationList(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { @@ -937,80 +928,97 @@ func (c *CertificateAuthorityClient) GetCertificateAuthorityCsr(ctx context.Cont return resp, nil } -// ActivateCertificateAuthority activate a pending CertificateAuthority. -func (c *CertificateAuthorityClient) ActivateCertificateAuthority(ctx context.Context, req *privatecapb.ActivateCertificateAuthorityRequest, opts ...gax.CallOption) (*ActivateCertificateAuthorityOperation, error) { - if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { - cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) - defer cancel() - ctx = cctx - } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) +// ListCertificateRevocationLists lists CertificateRevocationLists. +func (c *CertificateAuthorityClient) ListCertificateRevocationLists(ctx context.Context, req *privatecapb.ListCertificateRevocationListsRequest, opts ...gax.CallOption) *CertificateRevocationListIterator { + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.ActivateCertificateAuthority[0:len(c.CallOptions.ActivateCertificateAuthority):len(c.CallOptions.ActivateCertificateAuthority)], opts...) - var resp *longrunningpb.Operation - err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { - var err error - resp, err = c.certificateAuthorityClient.ActivateCertificateAuthority(ctx, req, settings.GRPC...) - return err - }, opts...) - if err != nil { - return nil, err + opts = append(c.CallOptions.ListCertificateRevocationLists[0:len(c.CallOptions.ListCertificateRevocationLists):len(c.CallOptions.ListCertificateRevocationLists)], opts...) + it := &CertificateRevocationListIterator{} + req = proto.Clone(req).(*privatecapb.ListCertificateRevocationListsRequest) + it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.CertificateRevocationList, string, error) { + var resp *privatecapb.ListCertificateRevocationListsResponse + req.PageToken = pageToken + if pageSize > math.MaxInt32 { + req.PageSize = math.MaxInt32 + } else { + req.PageSize = int32(pageSize) + } + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.certificateAuthorityClient.ListCertificateRevocationLists(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, "", err + } + + it.Response = resp + return resp.GetCertificateRevocationLists(), resp.GetNextPageToken(), nil } - return &ActivateCertificateAuthorityOperation{ - lro: longrunning.InternalNewOperation(c.LROClient, resp), - }, 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 } -// DisableCertificateAuthority disable a CertificateAuthority. -func (c *CertificateAuthorityClient) DisableCertificateAuthority(ctx context.Context, req *privatecapb.DisableCertificateAuthorityRequest, opts ...gax.CallOption) (*DisableCertificateAuthorityOperation, error) { +// UpdateCertificateRevocationList update a CertificateRevocationList. +func (c *CertificateAuthorityClient) UpdateCertificateRevocationList(ctx context.Context, req *privatecapb.UpdateCertificateRevocationListRequest, opts ...gax.CallOption) (*UpdateCertificateRevocationListOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "certificate_revocation_list.name", url.QueryEscape(req.GetCertificateRevocationList().GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.DisableCertificateAuthority[0:len(c.CallOptions.DisableCertificateAuthority):len(c.CallOptions.DisableCertificateAuthority)], opts...) + opts = append(c.CallOptions.UpdateCertificateRevocationList[0:len(c.CallOptions.UpdateCertificateRevocationList):len(c.CallOptions.UpdateCertificateRevocationList)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.DisableCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.UpdateCertificateRevocationList(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &DisableCertificateAuthorityOperation{ + return &UpdateCertificateRevocationListOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// EnableCertificateAuthority enable a CertificateAuthority. -func (c *CertificateAuthorityClient) EnableCertificateAuthority(ctx context.Context, req *privatecapb.EnableCertificateAuthorityRequest, opts ...gax.CallOption) (*EnableCertificateAuthorityOperation, error) { +// CreateReusableConfig create a new ReusableConfig in a given Project and Location. +func (c *CertificateAuthorityClient) CreateReusableConfig(ctx context.Context, req *privatecapb.CreateReusableConfigRequest, opts ...gax.CallOption) (*CreateReusableConfigOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.EnableCertificateAuthority[0:len(c.CallOptions.EnableCertificateAuthority):len(c.CallOptions.EnableCertificateAuthority)], opts...) + opts = append(c.CallOptions.CreateReusableConfig[0:len(c.CallOptions.CreateReusableConfig):len(c.CallOptions.CreateReusableConfig)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.EnableCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.CreateReusableConfig(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &EnableCertificateAuthorityOperation{ + return &CreateReusableConfigOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// ScheduleDeleteCertificateAuthority schedule a CertificateAuthority for deletion. -func (c *CertificateAuthorityClient) ScheduleDeleteCertificateAuthority(ctx context.Context, req *privatecapb.ScheduleDeleteCertificateAuthorityRequest, opts ...gax.CallOption) (*ScheduleDeleteCertificateAuthorityOperation, error) { +// DeleteReusableConfig deleteReusableConfig deletes a ReusableConfig. +func (c *CertificateAuthorityClient) DeleteReusableConfig(ctx context.Context, req *privatecapb.DeleteReusableConfigRequest, opts ...gax.CallOption) (*DeleteReusableConfigOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() @@ -1018,23 +1026,23 @@ func (c *CertificateAuthorityClient) ScheduleDeleteCertificateAuthority(ctx cont } 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.ScheduleDeleteCertificateAuthority[0:len(c.CallOptions.ScheduleDeleteCertificateAuthority):len(c.CallOptions.ScheduleDeleteCertificateAuthority)], opts...) + opts = append(c.CallOptions.DeleteReusableConfig[0:len(c.CallOptions.DeleteReusableConfig):len(c.CallOptions.DeleteReusableConfig)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.ScheduleDeleteCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.DeleteReusableConfig(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &ScheduleDeleteCertificateAuthorityOperation{ + return &DeleteReusableConfigOperation{ lro: longrunning.InternalNewOperation(c.LROClient, resp), }, nil } -// RestoreCertificateAuthority restore a CertificateAuthority that is scheduled for deletion. -func (c *CertificateAuthorityClient) RestoreCertificateAuthority(ctx context.Context, req *privatecapb.RestoreCertificateAuthorityRequest, opts ...gax.CallOption) (*RestoreCertificateAuthorityOperation, error) { +// GetReusableConfig returns a ReusableConfig. +func (c *CertificateAuthorityClient) GetReusableConfig(ctx context.Context, req *privatecapb.GetReusableConfigRequest, opts ...gax.CallOption) (*privatecapb.ReusableConfig, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() @@ -1042,41 +1050,82 @@ func (c *CertificateAuthorityClient) RestoreCertificateAuthority(ctx context.Con } 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.RestoreCertificateAuthority[0:len(c.CallOptions.RestoreCertificateAuthority):len(c.CallOptions.RestoreCertificateAuthority)], opts...) - var resp *longrunningpb.Operation + opts = append(c.CallOptions.GetReusableConfig[0:len(c.CallOptions.GetReusableConfig):len(c.CallOptions.GetReusableConfig)], opts...) + var resp *privatecapb.ReusableConfig err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.RestoreCertificateAuthority(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.GetReusableConfig(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return &RestoreCertificateAuthorityOperation{ - lro: longrunning.InternalNewOperation(c.LROClient, resp), - }, nil + return resp, nil } -// RevokeCertificate revoke a Certificate. -func (c *CertificateAuthorityClient) RevokeCertificate(ctx context.Context, req *privatecapb.RevokeCertificateRequest, opts ...gax.CallOption) (*privatecapb.Certificate, error) { +// ListReusableConfigs lists ReusableConfigs. +func (c *CertificateAuthorityClient) ListReusableConfigs(ctx context.Context, req *privatecapb.ListReusableConfigsRequest, opts ...gax.CallOption) *ReusableConfigIterator { + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) + ctx = insertMetadata(ctx, c.xGoogMetadata, md) + opts = append(c.CallOptions.ListReusableConfigs[0:len(c.CallOptions.ListReusableConfigs):len(c.CallOptions.ListReusableConfigs)], opts...) + it := &ReusableConfigIterator{} + req = proto.Clone(req).(*privatecapb.ListReusableConfigsRequest) + it.InternalFetch = func(pageSize int, pageToken string) ([]*privatecapb.ReusableConfig, string, error) { + var resp *privatecapb.ListReusableConfigsResponse + req.PageToken = pageToken + if pageSize > math.MaxInt32 { + req.PageSize = math.MaxInt32 + } else { + req.PageSize = int32(pageSize) + } + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.certificateAuthorityClient.ListReusableConfigs(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, "", err + } + + it.Response = resp + return resp.GetReusableConfigs(), 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 +} + +// UpdateReusableConfig update a ReusableConfig. +func (c *CertificateAuthorityClient) UpdateReusableConfig(ctx context.Context, req *privatecapb.UpdateReusableConfigRequest, opts ...gax.CallOption) (*UpdateReusableConfigOperation, error) { if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines { cctx, cancel := context.WithTimeout(ctx, 60000*time.Millisecond) defer cancel() ctx = cctx } - md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) + md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "reusable_config.name", url.QueryEscape(req.GetReusableConfig().GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) - opts = append(c.CallOptions.RevokeCertificate[0:len(c.CallOptions.RevokeCertificate):len(c.CallOptions.RevokeCertificate)], opts...) - var resp *privatecapb.Certificate + opts = append(c.CallOptions.UpdateReusableConfig[0:len(c.CallOptions.UpdateReusableConfig):len(c.CallOptions.UpdateReusableConfig)], opts...) + var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { var err error - resp, err = c.certificateAuthorityClient.RevokeCertificate(ctx, req, settings.GRPC...) + resp, err = c.certificateAuthorityClient.UpdateReusableConfig(ctx, req, settings.GRPC...) return err }, opts...) if err != nil { return nil, err } - return resp, nil + return &UpdateReusableConfigOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, resp), + }, nil } // ActivateCertificateAuthorityOperation manages a long-running operation from ActivateCertificateAuthority. @@ -1355,6 +1404,64 @@ func (op *CreateReusableConfigOperation) Name() string { return op.lro.Name() } +// DeleteReusableConfigOperation manages a long-running operation from DeleteReusableConfig. +type DeleteReusableConfigOperation struct { + lro *longrunning.Operation +} + +// DeleteReusableConfigOperation returns a new DeleteReusableConfigOperation from a given name. +// The name must be that of a previously created DeleteReusableConfigOperation, possibly from a different process. +func (c *CertificateAuthorityClient) DeleteReusableConfigOperation(name string) *DeleteReusableConfigOperation { + return &DeleteReusableConfigOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, &longrunningpb.Operation{Name: name}), + } +} + +// Wait blocks until the long-running operation is completed, returning the response and any errors encountered. +// +// See documentation of Poll for error-handling information. +func (op *DeleteReusableConfigOperation) Wait(ctx context.Context, opts ...gax.CallOption) error { + return op.lro.WaitWithInterval(ctx, nil, time.Minute, opts...) +} + +// Poll fetches the latest state of the long-running operation. +// +// Poll also fetches the latest metadata, which can be retrieved by Metadata. +// +// If Poll fails, the error is returned and op is unmodified. If Poll succeeds and +// the operation has completed with failure, the error is returned and op.Done will return true. +// If Poll succeeds and the operation has completed successfully, +// op.Done will return true, and the response of the operation is returned. +// If Poll succeeds and the operation has not completed, the returned response and error are both nil. +func (op *DeleteReusableConfigOperation) Poll(ctx context.Context, opts ...gax.CallOption) error { + return op.lro.Poll(ctx, nil, opts...) +} + +// Metadata returns metadata associated with the long-running operation. +// Metadata itself does not contact the server, but Poll does. +// To get the latest metadata, call this method after a successful call to Poll. +// If the metadata is not available, the returned metadata and error are both nil. +func (op *DeleteReusableConfigOperation) Metadata() (*privatecapb.OperationMetadata, error) { + var meta privatecapb.OperationMetadata + if err := op.lro.Metadata(&meta); err == longrunning.ErrNoMetadata { + return nil, nil + } else if err != nil { + return nil, err + } + return &meta, nil +} + +// Done reports whether the long-running operation has completed. +func (op *DeleteReusableConfigOperation) Done() bool { + return op.lro.Done() +} + +// Name returns the name of the long-running operation. +// The name is assigned by the server and is unique within the service from which the operation is created. +func (op *DeleteReusableConfigOperation) Name() string { + return op.lro.Name() +} + // DisableCertificateAuthorityOperation manages a long-running operation from DisableCertificateAuthority. type DisableCertificateAuthorityOperation struct { lro *longrunning.Operation diff --git a/security/privateca/apiv1beta1/certificate_authority_client_example_test.go b/security/privateca/apiv1beta1/certificate_authority_client_example_test.go index fd8a37295154..8681be65723e 100644 --- a/security/privateca/apiv1beta1/certificate_authority_client_example_test.go +++ b/security/privateca/apiv1beta1/certificate_authority_client_example_test.go @@ -34,9 +34,8 @@ func ExampleNewCertificateAuthorityClient() { _ = c } -func ExampleCertificateAuthorityClient_ListCertificateAuthorities() { +func ExampleCertificateAuthorityClient_CreateCertificate() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" - // import "google.golang.org/api/iterator" ctx := context.Background() c, err := privateca.NewCertificateAuthorityClient(ctx) @@ -44,26 +43,19 @@ func ExampleCertificateAuthorityClient_ListCertificateAuthorities() { // TODO: Handle error. } - req := &privatecapb.ListCertificateAuthoritiesRequest{ + req := &privatecapb.CreateCertificateRequest{ // TODO: Fill request struct fields. } - it := c.ListCertificateAuthorities(ctx, req) - for { - resp, err := it.Next() - if err == iterator.Done { - break - } - if err != nil { - // TODO: Handle error. - } - // TODO: Use resp. - _ = resp + resp, err := c.CreateCertificate(ctx, req) + if err != nil { + // TODO: Handle error. } + // TODO: Use resp. + _ = resp } -func ExampleCertificateAuthorityClient_ListCertificateRevocationLists() { +func ExampleCertificateAuthorityClient_GetCertificate() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" - // import "google.golang.org/api/iterator" ctx := context.Background() c, err := privateca.NewCertificateAuthorityClient(ctx) @@ -71,21 +63,15 @@ func ExampleCertificateAuthorityClient_ListCertificateRevocationLists() { // TODO: Handle error. } - req := &privatecapb.ListCertificateRevocationListsRequest{ + req := &privatecapb.GetCertificateRequest{ // TODO: Fill request struct fields. } - it := c.ListCertificateRevocationLists(ctx, req) - for { - resp, err := it.Next() - if err == iterator.Done { - break - } - if err != nil { - // TODO: Handle error. - } - // TODO: Use resp. - _ = resp + resp, err := c.GetCertificate(ctx, req) + if err != nil { + // TODO: Handle error. } + // TODO: Use resp. + _ = resp } func ExampleCertificateAuthorityClient_ListCertificates() { @@ -115,9 +101,8 @@ func ExampleCertificateAuthorityClient_ListCertificates() { } } -func ExampleCertificateAuthorityClient_ListReusableConfigs() { +func ExampleCertificateAuthorityClient_RevokeCertificate() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" - // import "google.golang.org/api/iterator" ctx := context.Background() c, err := privateca.NewCertificateAuthorityClient(ctx) @@ -125,24 +110,18 @@ func ExampleCertificateAuthorityClient_ListReusableConfigs() { // TODO: Handle error. } - req := &privatecapb.ListReusableConfigsRequest{ + req := &privatecapb.RevokeCertificateRequest{ // TODO: Fill request struct fields. } - it := c.ListReusableConfigs(ctx, req) - for { - resp, err := it.Next() - if err == iterator.Done { - break - } - if err != nil { - // TODO: Handle error. - } - // TODO: Use resp. - _ = resp + resp, err := c.RevokeCertificate(ctx, req) + if err != nil { + // TODO: Handle error. } + // TODO: Use resp. + _ = resp } -func ExampleCertificateAuthorityClient_GetCertificateAuthority() { +func ExampleCertificateAuthorityClient_UpdateCertificate() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -151,10 +130,10 @@ func ExampleCertificateAuthorityClient_GetCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.GetCertificateAuthorityRequest{ + req := &privatecapb.UpdateCertificateRequest{ // TODO: Fill request struct fields. } - resp, err := c.GetCertificateAuthority(ctx, req) + resp, err := c.UpdateCertificate(ctx, req) if err != nil { // TODO: Handle error. } @@ -162,7 +141,7 @@ func ExampleCertificateAuthorityClient_GetCertificateAuthority() { _ = resp } -func ExampleCertificateAuthorityClient_GetCertificateRevocationList() { +func ExampleCertificateAuthorityClient_ActivateCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -171,10 +150,15 @@ func ExampleCertificateAuthorityClient_GetCertificateRevocationList() { // TODO: Handle error. } - req := &privatecapb.GetCertificateRevocationListRequest{ + req := &privatecapb.ActivateCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - resp, err := c.GetCertificateRevocationList(ctx, req) + op, err := c.ActivateCertificateAuthority(ctx, req) + if err != nil { + // TODO: Handle error. + } + + resp, err := op.Wait(ctx) if err != nil { // TODO: Handle error. } @@ -182,7 +166,7 @@ func ExampleCertificateAuthorityClient_GetCertificateRevocationList() { _ = resp } -func ExampleCertificateAuthorityClient_GetCertificate() { +func ExampleCertificateAuthorityClient_CreateCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -191,10 +175,15 @@ func ExampleCertificateAuthorityClient_GetCertificate() { // TODO: Handle error. } - req := &privatecapb.GetCertificateRequest{ + req := &privatecapb.CreateCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - resp, err := c.GetCertificate(ctx, req) + op, err := c.CreateCertificateAuthority(ctx, req) + if err != nil { + // TODO: Handle error. + } + + resp, err := op.Wait(ctx) if err != nil { // TODO: Handle error. } @@ -202,7 +191,7 @@ func ExampleCertificateAuthorityClient_GetCertificate() { _ = resp } -func ExampleCertificateAuthorityClient_GetReusableConfig() { +func ExampleCertificateAuthorityClient_DisableCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -211,10 +200,15 @@ func ExampleCertificateAuthorityClient_GetReusableConfig() { // TODO: Handle error. } - req := &privatecapb.GetReusableConfigRequest{ + req := &privatecapb.DisableCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - resp, err := c.GetReusableConfig(ctx, req) + op, err := c.DisableCertificateAuthority(ctx, req) + if err != nil { + // TODO: Handle error. + } + + resp, err := op.Wait(ctx) if err != nil { // TODO: Handle error. } @@ -222,7 +216,7 @@ func ExampleCertificateAuthorityClient_GetReusableConfig() { _ = resp } -func ExampleCertificateAuthorityClient_CreateCertificateAuthority() { +func ExampleCertificateAuthorityClient_EnableCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -231,10 +225,10 @@ func ExampleCertificateAuthorityClient_CreateCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.CreateCertificateAuthorityRequest{ + req := &privatecapb.EnableCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - op, err := c.CreateCertificateAuthority(ctx, req) + op, err := c.EnableCertificateAuthority(ctx, req) if err != nil { // TODO: Handle error. } @@ -247,7 +241,7 @@ func ExampleCertificateAuthorityClient_CreateCertificateAuthority() { _ = resp } -func ExampleCertificateAuthorityClient_CreateCertificateRevocationList() { +func ExampleCertificateAuthorityClient_FetchCertificateAuthorityCsr() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -256,15 +250,10 @@ func ExampleCertificateAuthorityClient_CreateCertificateRevocationList() { // TODO: Handle error. } - req := &privatecapb.CreateCertificateRevocationListRequest{ + req := &privatecapb.FetchCertificateAuthorityCsrRequest{ // TODO: Fill request struct fields. } - op, err := c.CreateCertificateRevocationList(ctx, req) - if err != nil { - // TODO: Handle error. - } - - resp, err := op.Wait(ctx) + resp, err := c.FetchCertificateAuthorityCsr(ctx, req) if err != nil { // TODO: Handle error. } @@ -272,7 +261,7 @@ func ExampleCertificateAuthorityClient_CreateCertificateRevocationList() { _ = resp } -func ExampleCertificateAuthorityClient_CreateCertificate() { +func ExampleCertificateAuthorityClient_GetCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -281,10 +270,10 @@ func ExampleCertificateAuthorityClient_CreateCertificate() { // TODO: Handle error. } - req := &privatecapb.CreateCertificateRequest{ + req := &privatecapb.GetCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - resp, err := c.CreateCertificate(ctx, req) + resp, err := c.GetCertificateAuthority(ctx, req) if err != nil { // TODO: Handle error. } @@ -292,8 +281,9 @@ func ExampleCertificateAuthorityClient_CreateCertificate() { _ = resp } -func ExampleCertificateAuthorityClient_CreateReusableConfig() { +func ExampleCertificateAuthorityClient_ListCertificateAuthorities() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" + // import "google.golang.org/api/iterator" ctx := context.Background() c, err := privateca.NewCertificateAuthorityClient(ctx) @@ -301,23 +291,24 @@ func ExampleCertificateAuthorityClient_CreateReusableConfig() { // TODO: Handle error. } - req := &privatecapb.CreateReusableConfigRequest{ + req := &privatecapb.ListCertificateAuthoritiesRequest{ // TODO: Fill request struct fields. } - op, err := c.CreateReusableConfig(ctx, req) - if err != nil { - // TODO: Handle error. - } - - resp, err := op.Wait(ctx) - if err != nil { - // TODO: Handle error. + it := c.ListCertificateAuthorities(ctx, req) + for { + resp, err := it.Next() + if err == iterator.Done { + break + } + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp } - // TODO: Use resp. - _ = resp } -func ExampleCertificateAuthorityClient_UpdateCertificateAuthority() { +func ExampleCertificateAuthorityClient_RestoreCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -326,10 +317,10 @@ func ExampleCertificateAuthorityClient_UpdateCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.UpdateCertificateAuthorityRequest{ + req := &privatecapb.RestoreCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - op, err := c.UpdateCertificateAuthority(ctx, req) + op, err := c.RestoreCertificateAuthority(ctx, req) if err != nil { // TODO: Handle error. } @@ -342,7 +333,7 @@ func ExampleCertificateAuthorityClient_UpdateCertificateAuthority() { _ = resp } -func ExampleCertificateAuthorityClient_UpdateCertificateRevocationList() { +func ExampleCertificateAuthorityClient_ScheduleDeleteCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -351,10 +342,10 @@ func ExampleCertificateAuthorityClient_UpdateCertificateRevocationList() { // TODO: Handle error. } - req := &privatecapb.UpdateCertificateRevocationListRequest{ + req := &privatecapb.ScheduleDeleteCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - op, err := c.UpdateCertificateRevocationList(ctx, req) + op, err := c.ScheduleDeleteCertificateAuthority(ctx, req) if err != nil { // TODO: Handle error. } @@ -367,7 +358,7 @@ func ExampleCertificateAuthorityClient_UpdateCertificateRevocationList() { _ = resp } -func ExampleCertificateAuthorityClient_UpdateCertificate() { +func ExampleCertificateAuthorityClient_UpdateCertificateAuthority() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -376,10 +367,15 @@ func ExampleCertificateAuthorityClient_UpdateCertificate() { // TODO: Handle error. } - req := &privatecapb.UpdateCertificateRequest{ + req := &privatecapb.UpdateCertificateAuthorityRequest{ // TODO: Fill request struct fields. } - resp, err := c.UpdateCertificate(ctx, req) + op, err := c.UpdateCertificateAuthority(ctx, req) + if err != nil { + // TODO: Handle error. + } + + resp, err := op.Wait(ctx) if err != nil { // TODO: Handle error. } @@ -387,7 +383,7 @@ func ExampleCertificateAuthorityClient_UpdateCertificate() { _ = resp } -func ExampleCertificateAuthorityClient_UpdateReusableConfig() { +func ExampleCertificateAuthorityClient_CreateCertificateRevocationList() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -396,10 +392,10 @@ func ExampleCertificateAuthorityClient_UpdateReusableConfig() { // TODO: Handle error. } - req := &privatecapb.UpdateReusableConfigRequest{ + req := &privatecapb.CreateCertificateRevocationListRequest{ // TODO: Fill request struct fields. } - op, err := c.UpdateReusableConfig(ctx, req) + op, err := c.CreateCertificateRevocationList(ctx, req) if err != nil { // TODO: Handle error. } @@ -412,7 +408,7 @@ func ExampleCertificateAuthorityClient_UpdateReusableConfig() { _ = resp } -func ExampleCertificateAuthorityClient_GetCertificateAuthorityCsr() { +func ExampleCertificateAuthorityClient_GetCertificateRevocationList() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -421,10 +417,10 @@ func ExampleCertificateAuthorityClient_GetCertificateAuthorityCsr() { // TODO: Handle error. } - req := &privatecapb.GetCertificateAuthorityCsrRequest{ + req := &privatecapb.GetCertificateRevocationListRequest{ // TODO: Fill request struct fields. } - resp, err := c.GetCertificateAuthorityCsr(ctx, req) + resp, err := c.GetCertificateRevocationList(ctx, req) if err != nil { // TODO: Handle error. } @@ -432,8 +428,9 @@ func ExampleCertificateAuthorityClient_GetCertificateAuthorityCsr() { _ = resp } -func ExampleCertificateAuthorityClient_ActivateCertificateAuthority() { +func ExampleCertificateAuthorityClient_ListCertificateRevocationLists() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" + // import "google.golang.org/api/iterator" ctx := context.Background() c, err := privateca.NewCertificateAuthorityClient(ctx) @@ -441,23 +438,24 @@ func ExampleCertificateAuthorityClient_ActivateCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.ActivateCertificateAuthorityRequest{ + req := &privatecapb.ListCertificateRevocationListsRequest{ // TODO: Fill request struct fields. } - op, err := c.ActivateCertificateAuthority(ctx, req) - if err != nil { - // TODO: Handle error. - } - - resp, err := op.Wait(ctx) - if err != nil { - // TODO: Handle error. + it := c.ListCertificateRevocationLists(ctx, req) + for { + resp, err := it.Next() + if err == iterator.Done { + break + } + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp } - // TODO: Use resp. - _ = resp } -func ExampleCertificateAuthorityClient_DisableCertificateAuthority() { +func ExampleCertificateAuthorityClient_UpdateCertificateRevocationList() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -466,10 +464,10 @@ func ExampleCertificateAuthorityClient_DisableCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.DisableCertificateAuthorityRequest{ + req := &privatecapb.UpdateCertificateRevocationListRequest{ // TODO: Fill request struct fields. } - op, err := c.DisableCertificateAuthority(ctx, req) + op, err := c.UpdateCertificateRevocationList(ctx, req) if err != nil { // TODO: Handle error. } @@ -482,7 +480,7 @@ func ExampleCertificateAuthorityClient_DisableCertificateAuthority() { _ = resp } -func ExampleCertificateAuthorityClient_EnableCertificateAuthority() { +func ExampleCertificateAuthorityClient_CreateReusableConfig() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -491,10 +489,10 @@ func ExampleCertificateAuthorityClient_EnableCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.EnableCertificateAuthorityRequest{ + req := &privatecapb.CreateReusableConfigRequest{ // TODO: Fill request struct fields. } - op, err := c.EnableCertificateAuthority(ctx, req) + op, err := c.CreateReusableConfig(ctx, req) if err != nil { // TODO: Handle error. } @@ -507,7 +505,7 @@ func ExampleCertificateAuthorityClient_EnableCertificateAuthority() { _ = resp } -func ExampleCertificateAuthorityClient_ScheduleDeleteCertificateAuthority() { +func ExampleCertificateAuthorityClient_DeleteReusableConfig() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -516,23 +514,21 @@ func ExampleCertificateAuthorityClient_ScheduleDeleteCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.ScheduleDeleteCertificateAuthorityRequest{ + req := &privatecapb.DeleteReusableConfigRequest{ // TODO: Fill request struct fields. } - op, err := c.ScheduleDeleteCertificateAuthority(ctx, req) + op, err := c.DeleteReusableConfig(ctx, req) if err != nil { // TODO: Handle error. } - resp, err := op.Wait(ctx) + err = op.Wait(ctx) if err != nil { // TODO: Handle error. } - // TODO: Use resp. - _ = resp } -func ExampleCertificateAuthorityClient_RestoreCertificateAuthority() { +func ExampleCertificateAuthorityClient_GetReusableConfig() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -541,23 +537,45 @@ func ExampleCertificateAuthorityClient_RestoreCertificateAuthority() { // TODO: Handle error. } - req := &privatecapb.RestoreCertificateAuthorityRequest{ + req := &privatecapb.GetReusableConfigRequest{ // TODO: Fill request struct fields. } - op, err := c.RestoreCertificateAuthority(ctx, req) + resp, err := c.GetReusableConfig(ctx, req) if err != nil { // TODO: Handle error. } + // TODO: Use resp. + _ = resp +} - resp, err := op.Wait(ctx) +func ExampleCertificateAuthorityClient_ListReusableConfigs() { + // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" + // import "google.golang.org/api/iterator" + + ctx := context.Background() + c, err := privateca.NewCertificateAuthorityClient(ctx) if err != nil { // TODO: Handle error. } - // TODO: Use resp. - _ = resp + + req := &privatecapb.ListReusableConfigsRequest{ + // TODO: Fill request struct fields. + } + it := c.ListReusableConfigs(ctx, req) + for { + resp, err := it.Next() + if err == iterator.Done { + break + } + if err != nil { + // TODO: Handle error. + } + // TODO: Use resp. + _ = resp + } } -func ExampleCertificateAuthorityClient_RevokeCertificate() { +func ExampleCertificateAuthorityClient_UpdateReusableConfig() { // import privatecapb "google.golang.org/genproto/googleapis/cloud/security/privateca/v1beta1" ctx := context.Background() @@ -566,10 +584,15 @@ func ExampleCertificateAuthorityClient_RevokeCertificate() { // TODO: Handle error. } - req := &privatecapb.RevokeCertificateRequest{ + req := &privatecapb.UpdateReusableConfigRequest{ // TODO: Fill request struct fields. } - resp, err := c.RevokeCertificate(ctx, req) + op, err := c.UpdateReusableConfig(ctx, req) + if err != nil { + // TODO: Handle error. + } + + resp, err := op.Wait(ctx) if err != nil { // TODO: Handle error. } diff --git a/security/privateca/apiv1beta1/doc.go b/security/privateca/apiv1beta1/doc.go index 302bb9cff05a..5ef90216b052 100644 --- a/security/privateca/apiv1beta1/doc.go +++ b/security/privateca/apiv1beta1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/securitycenter/apiv1/doc.go b/securitycenter/apiv1/doc.go index 764d0207de0e..3f42f7f46ba0 100644 --- a/securitycenter/apiv1/doc.go +++ b/securitycenter/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/securitycenter/apiv1beta1/doc.go b/securitycenter/apiv1beta1/doc.go index ca299fbdbc8a..529ee142b564 100644 --- a/securitycenter/apiv1beta1/doc.go +++ b/securitycenter/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/securitycenter/apiv1p1beta1/doc.go b/securitycenter/apiv1p1beta1/doc.go index f7a8bce31591..c365a920c1cf 100644 --- a/securitycenter/apiv1p1beta1/doc.go +++ b/securitycenter/apiv1p1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/securitycenter/settings/apiv1beta1/doc.go b/securitycenter/settings/apiv1beta1/doc.go index 4c50b8aa73ed..f8a3d2d70a44 100644 --- a/securitycenter/settings/apiv1beta1/doc.go +++ b/securitycenter/settings/apiv1beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/servicedirectory/apiv1beta1/doc.go b/servicedirectory/apiv1beta1/doc.go index 15f55044842d..47658b08ca82 100644 --- a/servicedirectory/apiv1beta1/doc.go +++ b/servicedirectory/apiv1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/spanner/admin/database/apiv1/doc.go b/spanner/admin/database/apiv1/doc.go index 395cbb3f84c6..9969c6b587d5 100644 --- a/spanner/admin/database/apiv1/doc.go +++ b/spanner/admin/database/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/spanner/admin/instance/apiv1/doc.go b/spanner/admin/instance/apiv1/doc.go index fe453bdc7b07..eb3fb4fbe124 100644 --- a/spanner/admin/instance/apiv1/doc.go +++ b/spanner/admin/instance/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/spanner/apiv1/doc.go b/spanner/apiv1/doc.go index 5f93d66fd641..a6b7e6c59ca3 100644 --- a/spanner/apiv1/doc.go +++ b/spanner/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/speech/apiv1/doc.go b/speech/apiv1/doc.go index ceadd4fe0f90..cb13ff384fd0 100644 --- a/speech/apiv1/doc.go +++ b/speech/apiv1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/speech/apiv1p1beta1/doc.go b/speech/apiv1p1beta1/doc.go index 80ea8ed3a9ae..f44e1a00ae38 100644 --- a/speech/apiv1p1beta1/doc.go +++ b/speech/apiv1p1beta1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/talent/apiv4beta1/doc.go b/talent/apiv4beta1/doc.go index ec8750105c0b..733b83aef61c 100644 --- a/talent/apiv4beta1/doc.go +++ b/talent/apiv4beta1/doc.go @@ -51,7 +51,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/texttospeech/apiv1/doc.go b/texttospeech/apiv1/doc.go index 1f0b84de3f42..9232fd4eded7 100644 --- a/texttospeech/apiv1/doc.go +++ b/texttospeech/apiv1/doc.go @@ -49,7 +49,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/trace/apiv1/doc.go b/trace/apiv1/doc.go index 4c90a7cd6ca9..46cbe6e69309 100644 --- a/trace/apiv1/doc.go +++ b/trace/apiv1/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/trace/apiv2/doc.go b/trace/apiv2/doc.go index a9de1ea54209..2a2d18576185 100644 --- a/trace/apiv2/doc.go +++ b/trace/apiv2/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/translate/apiv3/doc.go b/translate/apiv3/doc.go index 7899b730830d..d52ca916c157 100644 --- a/translate/apiv3/doc.go +++ b/translate/apiv3/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/video/transcoder/apiv1beta1/doc.go b/video/transcoder/apiv1beta1/doc.go index 2e7d9a75c91f..a8e0c5a9aed6 100644 --- a/video/transcoder/apiv1beta1/doc.go +++ b/video/transcoder/apiv1beta1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/videointelligence/apiv1/doc.go b/videointelligence/apiv1/doc.go index 100c73f41138..eeb103bdad00 100644 --- a/videointelligence/apiv1/doc.go +++ b/videointelligence/apiv1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/videointelligence/apiv1beta2/doc.go b/videointelligence/apiv1beta2/doc.go index 4941688e824b..e4cc7299a3ab 100644 --- a/videointelligence/apiv1beta2/doc.go +++ b/videointelligence/apiv1beta2/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/vision/apiv1/doc.go b/vision/apiv1/doc.go index c8103b3c1d7a..b149a0cb47bd 100644 --- a/vision/apiv1/doc.go +++ b/vision/apiv1/doc.go @@ -50,7 +50,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/vision/apiv1p1beta1/doc.go b/vision/apiv1p1beta1/doc.go index 6ceb931a0dca..78174dda3a10 100644 --- a/vision/apiv1p1beta1/doc.go +++ b/vision/apiv1p1beta1/doc.go @@ -52,7 +52,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/webrisk/apiv1/doc.go b/webrisk/apiv1/doc.go index fdcf5e015a51..79be76eb29c7 100644 --- a/webrisk/apiv1/doc.go +++ b/webrisk/apiv1/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/webrisk/apiv1beta1/doc.go b/webrisk/apiv1beta1/doc.go index 8e48c6303c04..dded79ac3c0b 100644 --- a/webrisk/apiv1beta1/doc.go +++ b/webrisk/apiv1beta1/doc.go @@ -48,7 +48,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/workflows/apiv1beta/doc.go b/workflows/apiv1beta/doc.go index 4af21f5f7a4b..85f9627ca646 100644 --- a/workflows/apiv1beta/doc.go +++ b/workflows/apiv1beta/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx) diff --git a/workflows/executions/apiv1beta/doc.go b/workflows/executions/apiv1beta/doc.go index fe62baf6f6bd..a8860201794a 100644 --- a/workflows/executions/apiv1beta/doc.go +++ b/workflows/executions/apiv1beta/doc.go @@ -46,7 +46,7 @@ import ( type clientHookParams struct{} type clientHook func(context.Context, clientHookParams) ([]option.ClientOption, error) -const versionClient = "20200903" +const versionClient = "20200904" func insertMetadata(ctx context.Context, mds ...metadata.MD) context.Context { out, _ := metadata.FromOutgoingContext(ctx)