diff --git a/asset/apiv1/asset_client.go b/asset/apiv1/asset_client.go index 381b35d40470..87706cd7b8bc 100644 --- a/asset/apiv1/asset_client.go +++ b/asset/apiv1/asset_client.go @@ -19,6 +19,7 @@ package asset import ( "context" "fmt" + "math" "net/url" "time" @@ -44,6 +45,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudasset.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/asset/apiv1/doc.go b/asset/apiv1/doc.go index 79dd9a0850ee..a8980baf7aba 100644 --- a/asset/apiv1/doc.go +++ b/asset/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/asset/apiv1beta1/asset_client.go b/asset/apiv1beta1/asset_client.go index 41fcde091feb..204fd441a295 100644 --- a/asset/apiv1beta1/asset_client.go +++ b/asset/apiv1beta1/asset_client.go @@ -19,6 +19,7 @@ package asset import ( "context" "fmt" + "math" "net/url" "time" @@ -44,6 +45,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudasset.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/asset/apiv1beta1/doc.go b/asset/apiv1beta1/doc.go index 40c1744f0a5c..f41b28e45232 100644 --- a/asset/apiv1beta1/doc.go +++ b/asset/apiv1beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/asset/apiv1p2beta1/asset_client.go b/asset/apiv1p2beta1/asset_client.go index 55cacc6f3dce..c853711e0107 100644 --- a/asset/apiv1p2beta1/asset_client.go +++ b/asset/apiv1p2beta1/asset_client.go @@ -19,6 +19,7 @@ package asset import ( "context" "fmt" + "math" "net/url" "time" @@ -49,6 +50,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudasset.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/asset/apiv1p2beta1/doc.go b/asset/apiv1p2beta1/doc.go index 8d71f74d7236..569788d3e7a9 100644 --- a/asset/apiv1p2beta1/doc.go +++ b/asset/apiv1p2beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/automl/apiv1beta1/auto_ml_client.go b/automl/apiv1beta1/auto_ml_client.go index b4b7231b0aa7..d62a2e9f7eb1 100644 --- a/automl/apiv1beta1/auto_ml_client.go +++ b/automl/apiv1beta1/auto_ml_client.go @@ -69,6 +69,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("automl.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } @@ -470,8 +472,7 @@ func (c *Client) DeleteModel(ctx context.Context, req *automlpb.DeleteModelReque // [node_number][google.cloud.automl.v1beta1.ImageObjectDetectionModelDeploymentMetadata.node_number]) // will reset the deployment state without pausing the model's availability. // -// Only applicable for Text Classification, Image Object Detection and Tables; -// all other domains manage deployment automatically. +// Only applicable for Text Classification, Image Object Detection and Tables; all other domains manage deployment automatically. // // Returns an empty response in the // [response][google.longrunning.Operation.response] field when it completes. diff --git a/automl/apiv1beta1/doc.go b/automl/apiv1beta1/doc.go index fbbbf12a3343..69186c17f351 100644 --- a/automl/apiv1beta1/doc.go +++ b/automl/apiv1beta1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/automl/apiv1beta1/mock_test.go b/automl/apiv1beta1/mock_test.go index 17e9faa86a20..fc5ea27429ef 100644 --- a/automl/apiv1beta1/mock_test.go +++ b/automl/apiv1beta1/mock_test.go @@ -1769,12 +1769,14 @@ func TestAutoMlGetTableSpec(t *testing.T) { var name2 string = "name2-1052831874" var timeColumnSpecId string = "timeColumnSpecId1558734824" var rowCount int64 = 1340416618 + var validRowCount int64 = 406068761 var columnCount int64 = 122671386 var etag string = "etag3123477" var expectedResponse = &automlpb.TableSpec{ Name: name2, TimeColumnSpecId: timeColumnSpecId, RowCount: rowCount, + ValidRowCount: validRowCount, ColumnCount: columnCount, Etag: etag, } @@ -1908,12 +1910,14 @@ func TestAutoMlUpdateTableSpec(t *testing.T) { var name string = "name3373707" var timeColumnSpecId string = "timeColumnSpecId1558734824" var rowCount int64 = 1340416618 + var validRowCount int64 = 406068761 var columnCount int64 = 122671386 var etag string = "etag3123477" var expectedResponse = &automlpb.TableSpec{ Name: name, TimeColumnSpecId: timeColumnSpecId, RowCount: rowCount, + ValidRowCount: validRowCount, ColumnCount: columnCount, Etag: etag, } diff --git a/automl/apiv1beta1/prediction_client.go b/automl/apiv1beta1/prediction_client.go index af458708f5e4..62073ef5ce7d 100644 --- a/automl/apiv1beta1/prediction_client.go +++ b/automl/apiv1beta1/prediction_client.go @@ -19,6 +19,7 @@ package automl import ( "context" "fmt" + "math" "net/url" "time" @@ -43,6 +44,8 @@ func defaultPredictionClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("automl.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } @@ -151,6 +154,9 @@ func (c *PredictionClient) setGoogleClientInfo(keyval ...string) { // up to 5MB. Not available for FORECASTING // // [prediction_type][google.cloud.automl.v1beta1.TablesModelMetadata.prediction_type]. +// +// Text Sentiment - TextSnippet, content up 500 characters, UTF-8 +// encoded. func (c *PredictionClient) Predict(ctx context.Context, req *automlpb.PredictRequest, opts ...gax.CallOption) (*automlpb.PredictResponse, error) { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) @@ -167,19 +173,23 @@ func (c *PredictionClient) Predict(ctx context.Context, req *automlpb.PredictReq return resp, nil } -// BatchPredict perform a batch prediction. Unlike the online [Predict][google.cloud.automl.v1beta1.PredictionService.Predict], batch +// BatchPredict perform a batch prediction. Unlike the online +// [Predict][google.cloud.automl.v1beta1.PredictionService.Predict], batch // prediction result won't be immediately available in the response. Instead, // a long running operation object is returned. User can poll the operation // result via [GetOperation][google.longrunning.Operations.GetOperation] -// method. Once the operation is done, [BatchPredictResult][google.cloud.automl.v1beta1.BatchPredictResult] is returned in -// the [response][google.longrunning.Operation.response] field. +// method. Once the operation is done, +// [BatchPredictResult][google.cloud.automl.v1beta1.BatchPredictResult] is +// returned in the [response][google.longrunning.Operation.response] field. // Available for following ML problems: // -// Video Classification +// Image Classification // -// Video Object Tracking +// Image Object Detection +// +// Video Classification // -// Text Extraction +// Video Object Tracking * Text Extraction // // Tables func (c *PredictionClient) BatchPredict(ctx context.Context, req *automlpb.BatchPredictRequest, opts ...gax.CallOption) (*BatchPredictOperation, error) { diff --git a/bigquery/datatransfer/apiv1/data_transfer_client.go b/bigquery/datatransfer/apiv1/data_transfer_client.go index 68468544916d..bb26124c80c9 100644 --- a/bigquery/datatransfer/apiv1/data_transfer_client.go +++ b/bigquery/datatransfer/apiv1/data_transfer_client.go @@ -56,6 +56,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("bigquerydatatransfer.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/bigquery/datatransfer/apiv1/doc.go b/bigquery/datatransfer/apiv1/doc.go index 7353118966ff..e2328c5eddb5 100644 --- a/bigquery/datatransfer/apiv1/doc.go +++ b/bigquery/datatransfer/apiv1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/bigquery/storage/apiv1beta1/big_query_storage_client.go b/bigquery/storage/apiv1beta1/big_query_storage_client.go index 2e9bbe55333e..8d5656cbee85 100644 --- a/bigquery/storage/apiv1beta1/big_query_storage_client.go +++ b/bigquery/storage/apiv1beta1/big_query_storage_client.go @@ -19,6 +19,7 @@ package storage import ( "context" "fmt" + "math" "net/url" "time" @@ -44,6 +45,8 @@ func defaultBigQueryStorageClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("bigquerystorage.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/bigquery/storage/apiv1beta1/doc.go b/bigquery/storage/apiv1beta1/doc.go index e4111cd0ca78..3dc27b3b4305 100644 --- a/bigquery/storage/apiv1beta1/doc.go +++ b/bigquery/storage/apiv1beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/cloudtasks/apiv2/cloud_tasks_client.go b/cloudtasks/apiv2/cloud_tasks_client.go index eac1da6ef822..c63459e24517 100644 --- a/cloudtasks/apiv2/cloud_tasks_client.go +++ b/cloudtasks/apiv2/cloud_tasks_client.go @@ -59,6 +59,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudtasks.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/cloudtasks/apiv2/doc.go b/cloudtasks/apiv2/doc.go index 9366b3f16a59..b7047c4e3fb2 100644 --- a/cloudtasks/apiv2/doc.go +++ b/cloudtasks/apiv2/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/cloudtasks/apiv2beta2/cloud_tasks_client.go b/cloudtasks/apiv2beta2/cloud_tasks_client.go index 700efd8f7b9f..d7b822c130fc 100644 --- a/cloudtasks/apiv2beta2/cloud_tasks_client.go +++ b/cloudtasks/apiv2beta2/cloud_tasks_client.go @@ -63,6 +63,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudtasks.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/cloudtasks/apiv2beta2/doc.go b/cloudtasks/apiv2beta2/doc.go index cbb6e4191aac..4baa08e0ea27 100644 --- a/cloudtasks/apiv2beta2/doc.go +++ b/cloudtasks/apiv2beta2/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/cloudtasks/apiv2beta3/cloud_tasks_client.go b/cloudtasks/apiv2beta3/cloud_tasks_client.go index 4921bdc18617..457adf328ac7 100644 --- a/cloudtasks/apiv2beta3/cloud_tasks_client.go +++ b/cloudtasks/apiv2beta3/cloud_tasks_client.go @@ -59,6 +59,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudtasks.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/cloudtasks/apiv2beta3/doc.go b/cloudtasks/apiv2beta3/doc.go index 6423760a9c35..6e0933e66647 100644 --- a/cloudtasks/apiv2beta3/doc.go +++ b/cloudtasks/apiv2beta3/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/containeranalysis/apiv1beta1/container_analysis_v1_beta1_client.go b/containeranalysis/apiv1beta1/container_analysis_v1_beta1_client.go index b05ae7cf3099..c8c734cdff8f 100644 --- a/containeranalysis/apiv1beta1/container_analysis_v1_beta1_client.go +++ b/containeranalysis/apiv1beta1/container_analysis_v1_beta1_client.go @@ -49,6 +49,8 @@ func defaultContainerAnalysisV1Beta1ClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("containeranalysis.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/containeranalysis/apiv1beta1/doc.go b/containeranalysis/apiv1beta1/doc.go index f8d760f4ed9d..96f4cf578157 100644 --- a/containeranalysis/apiv1beta1/doc.go +++ b/containeranalysis/apiv1beta1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/containeranalysis/apiv1beta1/grafeas_v1_beta1_client.go b/containeranalysis/apiv1beta1/grafeas_v1_beta1_client.go index 24135c841598..05d3c5b9fe1e 100644 --- a/containeranalysis/apiv1beta1/grafeas_v1_beta1_client.go +++ b/containeranalysis/apiv1beta1/grafeas_v1_beta1_client.go @@ -57,6 +57,8 @@ func defaultGrafeasV1Beta1ClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("containeranalysis.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1/cluster_controller_client.go b/dataproc/apiv1/cluster_controller_client.go index 651f7561f9f1..ef40eab6a4c2 100644 --- a/dataproc/apiv1/cluster_controller_client.go +++ b/dataproc/apiv1/cluster_controller_client.go @@ -49,6 +49,8 @@ func defaultClusterControllerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1/doc.go b/dataproc/apiv1/doc.go index 445001192cf1..c13f7f8d31bd 100644 --- a/dataproc/apiv1/doc.go +++ b/dataproc/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/dataproc/apiv1/job_controller_client.go b/dataproc/apiv1/job_controller_client.go index 8cd8a0f1b48a..eb6e5c519edc 100644 --- a/dataproc/apiv1/job_controller_client.go +++ b/dataproc/apiv1/job_controller_client.go @@ -46,6 +46,8 @@ func defaultJobControllerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1/workflow_template_client.go b/dataproc/apiv1/workflow_template_client.go index fe283ca7703c..b27dff50680b 100644 --- a/dataproc/apiv1/workflow_template_client.go +++ b/dataproc/apiv1/workflow_template_client.go @@ -52,6 +52,8 @@ func defaultWorkflowTemplateClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1beta2/autoscaling_policy_client.go b/dataproc/apiv1beta2/autoscaling_policy_client.go index 380cd6f0a97b..783253b08f33 100644 --- a/dataproc/apiv1beta2/autoscaling_policy_client.go +++ b/dataproc/apiv1beta2/autoscaling_policy_client.go @@ -47,6 +47,8 @@ func defaultAutoscalingPolicyClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1beta2/cluster_controller_client.go b/dataproc/apiv1beta2/cluster_controller_client.go index 4cdd259955f5..191eab77cf7f 100644 --- a/dataproc/apiv1beta2/cluster_controller_client.go +++ b/dataproc/apiv1beta2/cluster_controller_client.go @@ -49,6 +49,8 @@ func defaultClusterControllerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1beta2/doc.go b/dataproc/apiv1beta2/doc.go index aecf924a8bd6..ffcec625c03a 100644 --- a/dataproc/apiv1beta2/doc.go +++ b/dataproc/apiv1beta2/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/dataproc/apiv1beta2/job_controller_client.go b/dataproc/apiv1beta2/job_controller_client.go index 5655471f98e4..86dfe74de7d5 100644 --- a/dataproc/apiv1beta2/job_controller_client.go +++ b/dataproc/apiv1beta2/job_controller_client.go @@ -46,6 +46,8 @@ func defaultJobControllerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dataproc/apiv1beta2/workflow_template_client.go b/dataproc/apiv1beta2/workflow_template_client.go index 06c3384d8c2c..2983abd9c5ff 100644 --- a/dataproc/apiv1beta2/workflow_template_client.go +++ b/dataproc/apiv1beta2/workflow_template_client.go @@ -52,6 +52,8 @@ func defaultWorkflowTemplateClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dataproc.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/debugger/apiv2/controller2_client.go b/debugger/apiv2/controller2_client.go index 7e198c57e148..963858dc5048 100644 --- a/debugger/apiv2/controller2_client.go +++ b/debugger/apiv2/controller2_client.go @@ -19,6 +19,7 @@ package debugger import ( "context" "fmt" + "math" "net/url" "time" @@ -42,6 +43,8 @@ func defaultController2ClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("clouddebugger.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/debugger/apiv2/debugger2_client.go b/debugger/apiv2/debugger2_client.go index 2e32ec47b235..ffc82553fa1b 100644 --- a/debugger/apiv2/debugger2_client.go +++ b/debugger/apiv2/debugger2_client.go @@ -19,6 +19,7 @@ package debugger import ( "context" "fmt" + "math" "net/url" "time" @@ -44,6 +45,8 @@ func defaultDebugger2ClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("clouddebugger.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/debugger/apiv2/doc.go b/debugger/apiv2/doc.go index 4f71da4a822e..1196c476767b 100644 --- a/debugger/apiv2/doc.go +++ b/debugger/apiv2/doc.go @@ -101,4 +101,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/dialogflow/apiv2/agents_client.go b/dialogflow/apiv2/agents_client.go index 6f71e2d3e5f0..d30559ae2892 100644 --- a/dialogflow/apiv2/agents_client.go +++ b/dialogflow/apiv2/agents_client.go @@ -54,6 +54,8 @@ func defaultAgentsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dialogflow/apiv2/contexts_client.go b/dialogflow/apiv2/contexts_client.go index c0cc9afa2b08..dea79b045f24 100644 --- a/dialogflow/apiv2/contexts_client.go +++ b/dialogflow/apiv2/contexts_client.go @@ -48,6 +48,8 @@ func defaultContextsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dialogflow/apiv2/doc.go b/dialogflow/apiv2/doc.go index 95171323702d..198d6a0cc83e 100644 --- a/dialogflow/apiv2/doc.go +++ b/dialogflow/apiv2/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/dialogflow/apiv2/entity_types_client.go b/dialogflow/apiv2/entity_types_client.go index 1d1ea1528814..32db397ba0d4 100644 --- a/dialogflow/apiv2/entity_types_client.go +++ b/dialogflow/apiv2/entity_types_client.go @@ -56,6 +56,8 @@ func defaultEntityTypesClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dialogflow/apiv2/intents_client.go b/dialogflow/apiv2/intents_client.go index 290757136836..618e36ec3c19 100644 --- a/dialogflow/apiv2/intents_client.go +++ b/dialogflow/apiv2/intents_client.go @@ -53,6 +53,8 @@ func defaultIntentsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dialogflow/apiv2/session_entity_types_client.go b/dialogflow/apiv2/session_entity_types_client.go index 57d73a7ae0d8..c91c32daeeb8 100644 --- a/dialogflow/apiv2/session_entity_types_client.go +++ b/dialogflow/apiv2/session_entity_types_client.go @@ -47,6 +47,8 @@ func defaultSessionEntityTypesClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } @@ -103,6 +105,10 @@ type SessionEntityTypesClient struct { // favorites, preferences, playlists, and so on. You can redefine a session // entity type at the session level. // +// Session entity methods do not work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. +// // For more information about entity types, see the // [Dialogflow // documentation](https://cloud.google.com/dialogflow/docs/entities-overview). @@ -142,6 +148,10 @@ func (c *SessionEntityTypesClient) setGoogleClientInfo(keyval ...string) { } // ListSessionEntityTypes returns the list of all session entity types in the specified session. +// +// This method doesn't work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. func (c *SessionEntityTypesClient) ListSessionEntityTypes(ctx context.Context, req *dialogflowpb.ListSessionEntityTypesRequest, opts ...gax.CallOption) *SessionEntityTypeIterator { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) @@ -181,6 +191,10 @@ func (c *SessionEntityTypesClient) ListSessionEntityTypes(ctx context.Context, r } // GetSessionEntityType retrieves the specified session entity type. +// +// This method doesn't work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. func (c *SessionEntityTypesClient) GetSessionEntityType(ctx context.Context, req *dialogflowpb.GetSessionEntityTypeRequest, opts ...gax.CallOption) (*dialogflowpb.SessionEntityType, error) { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) @@ -201,6 +215,10 @@ func (c *SessionEntityTypesClient) GetSessionEntityType(ctx context.Context, req // // If the specified session entity type already exists, overrides the session // entity type. +// +// This method doesn't work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. func (c *SessionEntityTypesClient) CreateSessionEntityType(ctx context.Context, req *dialogflowpb.CreateSessionEntityTypeRequest, opts ...gax.CallOption) (*dialogflowpb.SessionEntityType, error) { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", url.QueryEscape(req.GetParent()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) @@ -218,6 +236,10 @@ func (c *SessionEntityTypesClient) CreateSessionEntityType(ctx context.Context, } // UpdateSessionEntityType updates the specified session entity type. +// +// This method doesn't work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. func (c *SessionEntityTypesClient) UpdateSessionEntityType(ctx context.Context, req *dialogflowpb.UpdateSessionEntityTypeRequest, opts ...gax.CallOption) (*dialogflowpb.SessionEntityType, error) { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "session_entity_type.name", url.QueryEscape(req.GetSessionEntityType().GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) @@ -235,6 +257,10 @@ func (c *SessionEntityTypesClient) UpdateSessionEntityType(ctx context.Context, } // DeleteSessionEntityType deletes the specified session entity type. +// +// This method doesn't work with Google Assistant integration. +// Contact Dialogflow support if you need to use session entities +// with Google Assistant integration. func (c *SessionEntityTypesClient) DeleteSessionEntityType(ctx context.Context, req *dialogflowpb.DeleteSessionEntityTypeRequest, opts ...gax.CallOption) error { md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", url.QueryEscape(req.GetName()))) ctx = insertMetadata(ctx, c.xGoogMetadata, md) diff --git a/dialogflow/apiv2/sessions_client.go b/dialogflow/apiv2/sessions_client.go index 17ff06d76c13..dd3d80790d90 100644 --- a/dialogflow/apiv2/sessions_client.go +++ b/dialogflow/apiv2/sessions_client.go @@ -19,6 +19,7 @@ package dialogflow import ( "context" "fmt" + "math" "net/url" gax "github.com/googleapis/gax-go/v2" @@ -39,6 +40,8 @@ func defaultSessionsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dialogflow.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dlp/apiv2/dlp_client.go b/dlp/apiv2/dlp_client.go index 49a3f5587711..c255105f4a48 100644 --- a/dlp/apiv2/dlp_client.go +++ b/dlp/apiv2/dlp_client.go @@ -72,6 +72,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("dlp.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/dlp/apiv2/doc.go b/dlp/apiv2/doc.go index 3ea28ee907b2..9c1e80ea574d 100644 --- a/dlp/apiv2/doc.go +++ b/dlp/apiv2/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/errorreporting/apiv1beta1/doc.go b/errorreporting/apiv1beta1/doc.go index 04609b70fb0e..6513e2beb323 100644 --- a/errorreporting/apiv1beta1/doc.go +++ b/errorreporting/apiv1beta1/doc.go @@ -101,4 +101,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/errorreporting/apiv1beta1/error_group_client.go b/errorreporting/apiv1beta1/error_group_client.go index 099692fb9256..0e276e0867d3 100644 --- a/errorreporting/apiv1beta1/error_group_client.go +++ b/errorreporting/apiv1beta1/error_group_client.go @@ -19,6 +19,7 @@ package errorreporting import ( "context" "fmt" + "math" "net/url" "time" @@ -41,6 +42,8 @@ func defaultErrorGroupClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("clouderrorreporting.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/errorreporting/apiv1beta1/error_stats_client.go b/errorreporting/apiv1beta1/error_stats_client.go index 4eef436ea2cf..7ed78a66280c 100644 --- a/errorreporting/apiv1beta1/error_stats_client.go +++ b/errorreporting/apiv1beta1/error_stats_client.go @@ -45,6 +45,8 @@ func defaultErrorStatsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("clouderrorreporting.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/errorreporting/apiv1beta1/report_errors_client.go b/errorreporting/apiv1beta1/report_errors_client.go index 25f94493adc8..3f753d2b150d 100644 --- a/errorreporting/apiv1beta1/report_errors_client.go +++ b/errorreporting/apiv1beta1/report_errors_client.go @@ -19,6 +19,7 @@ package errorreporting import ( "context" "fmt" + "math" "net/url" gax "github.com/googleapis/gax-go/v2" @@ -38,6 +39,8 @@ func defaultReportErrorsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("clouderrorreporting.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/expr/apiv1alpha1/cel_client.go b/expr/apiv1alpha1/cel_client.go index 578a67d4de35..c3f6272921a7 100644 --- a/expr/apiv1alpha1/cel_client.go +++ b/expr/apiv1alpha1/cel_client.go @@ -18,6 +18,7 @@ package expr import ( "context" + "math" gax "github.com/googleapis/gax-go/v2" "google.golang.org/api/option" @@ -38,6 +39,8 @@ func defaultCelClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cel.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/expr/apiv1alpha1/conformance_client.go b/expr/apiv1alpha1/conformance_client.go index 6d2a5cac347c..5647f67ff589 100644 --- a/expr/apiv1alpha1/conformance_client.go +++ b/expr/apiv1alpha1/conformance_client.go @@ -18,6 +18,7 @@ package expr import ( "context" + "math" gax "github.com/googleapis/gax-go/v2" "google.golang.org/api/option" @@ -38,6 +39,8 @@ func defaultConformanceClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cel.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/expr/apiv1alpha1/doc.go b/expr/apiv1alpha1/doc.go index 77f8ddff4331..b4d5af1261a3 100644 --- a/expr/apiv1alpha1/doc.go +++ b/expr/apiv1alpha1/doc.go @@ -95,4 +95,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/firestore/apiv1/admin/doc.go b/firestore/apiv1/admin/doc.go index 3bff2054c88a..bc86c5ae9ce2 100644 --- a/firestore/apiv1/admin/doc.go +++ b/firestore/apiv1/admin/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/firestore/apiv1/admin/firestore_admin_client.go b/firestore/apiv1/admin/firestore_admin_client.go index 19089bac5198..76838760d332 100644 --- a/firestore/apiv1/admin/firestore_admin_client.go +++ b/firestore/apiv1/admin/firestore_admin_client.go @@ -52,6 +52,8 @@ func defaultFirestoreAdminClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("firestore.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/firestore/apiv1beta1/doc.go b/firestore/apiv1beta1/doc.go index 5cde089bdcde..608a51c90538 100644 --- a/firestore/apiv1beta1/doc.go +++ b/firestore/apiv1beta1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/firestore/apiv1beta1/firestore_client.go b/firestore/apiv1beta1/firestore_client.go index c1b5eb9f5ab9..f7ae16990557 100644 --- a/firestore/apiv1beta1/firestore_client.go +++ b/firestore/apiv1beta1/firestore_client.go @@ -55,6 +55,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("firestore.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/go.mod b/go.mod index 73991cc82b42..df18e46aacba 100644 --- a/go.mod +++ b/go.mod @@ -22,7 +22,7 @@ require ( golang.org/x/time v0.0.0-20190308202827-9d24e82272b4 golang.org/x/tools v0.0.0-20190628153133-6cdbf07be9d0 google.golang.org/api v0.8.0 - google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64 + google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55 google.golang.org/grpc v1.21.1 honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a ) diff --git a/go.sum b/go.sum index 848a43317306..e251f73d49a8 100644 --- a/go.sum +++ b/go.sum @@ -144,6 +144,8 @@ google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873 h1:nfPFGzJkUDX6uBm google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE= google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64 h1:iKtrH9Y8mcbADOP0YFaEMth7OfuHY9xHOwNj4znpM1A= google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= +google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55 h1:gSJIx1SDwno+2ElGhA4+qG2zF97qiUzTM+rQ0klBOcE= +google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= google.golang.org/grpc v1.19.0 h1:cfg4PD8YEdSFnm7qLV4++93WcmhH2nIUhMjhdCvl3j8= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1 h1:Hz2g2wirWK7H0qIIhGIqRGTuMwTE8HEKFnDZZ7lm9NU= diff --git a/iam/admin/apiv1/doc.go b/iam/admin/apiv1/doc.go index 6317c524e590..09bd63483a0e 100644 --- a/iam/admin/apiv1/doc.go +++ b/iam/admin/apiv1/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/iam/admin/apiv1/iam_client.go b/iam/admin/apiv1/iam_client.go index 8d732bae69e7..542c6c11a1b3 100644 --- a/iam/admin/apiv1/iam_client.go +++ b/iam/admin/apiv1/iam_client.go @@ -65,6 +65,8 @@ func defaultIamClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("iam.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/iam/credentials/apiv1/doc.go b/iam/credentials/apiv1/doc.go index abb16e2257eb..bbe129734ee5 100644 --- a/iam/credentials/apiv1/doc.go +++ b/iam/credentials/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/iam/credentials/apiv1/iam_credentials_client.go b/iam/credentials/apiv1/iam_credentials_client.go index 48f402127011..20b6c1e7d043 100644 --- a/iam/credentials/apiv1/iam_credentials_client.go +++ b/iam/credentials/apiv1/iam_credentials_client.go @@ -19,6 +19,7 @@ package credentials import ( "context" "fmt" + "math" "net/url" "time" @@ -43,6 +44,8 @@ func defaultIamCredentialsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("iamcredentials.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/iot/apiv1/device_manager_client.go b/iot/apiv1/device_manager_client.go index 0f82b266c691..64cadc169cc4 100644 --- a/iot/apiv1/device_manager_client.go +++ b/iot/apiv1/device_manager_client.go @@ -62,6 +62,8 @@ func defaultDeviceManagerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudiot.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/iot/apiv1/doc.go b/iot/apiv1/doc.go index a35d0f89bdfc..cf69f7804a27 100644 --- a/iot/apiv1/doc.go +++ b/iot/apiv1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/irm/apiv1alpha2/doc.go b/irm/apiv1alpha2/doc.go index ded4132c925e..43914a6e0ef1 100644 --- a/irm/apiv1alpha2/doc.go +++ b/irm/apiv1alpha2/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/irm/apiv1alpha2/incident_client.go b/irm/apiv1alpha2/incident_client.go index 6d6a1d748dbd..89172d8387d2 100644 --- a/irm/apiv1alpha2/incident_client.go +++ b/irm/apiv1alpha2/incident_client.go @@ -74,6 +74,8 @@ func defaultIncidentClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("irm.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/kms/apiv1/doc.go b/kms/apiv1/doc.go index 0bc4ce63833a..07fd6bb931d6 100644 --- a/kms/apiv1/doc.go +++ b/kms/apiv1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/kms/apiv1/key_management_client.go b/kms/apiv1/key_management_client.go index aef73f9f75ca..2903072219da 100644 --- a/kms/apiv1/key_management_client.go +++ b/kms/apiv1/key_management_client.go @@ -65,15 +65,18 @@ func defaultKeyManagementClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudkms.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } func defaultKeyManagementCallOptions() *KeyManagementCallOptions { retry := map[[2]string][]gax.CallOption{ - {"default", "idempotent"}: { + {"default", "retryable"}: { gax.WithRetry(func() gax.Retryer { return gax.OnCodes([]codes.Code{ codes.DeadlineExceeded, + codes.Internal, codes.Unavailable, }, gax.Backoff{ Initial: 100 * time.Millisecond, @@ -84,29 +87,29 @@ func defaultKeyManagementCallOptions() *KeyManagementCallOptions { }, } return &KeyManagementCallOptions{ - ListKeyRings: retry[[2]string{"default", "idempotent"}], - ListImportJobs: retry[[2]string{"default", "idempotent"}], - ListCryptoKeys: retry[[2]string{"default", "idempotent"}], - ListCryptoKeyVersions: retry[[2]string{"default", "idempotent"}], - GetKeyRing: retry[[2]string{"default", "idempotent"}], - GetImportJob: retry[[2]string{"default", "idempotent"}], - GetCryptoKey: retry[[2]string{"default", "idempotent"}], - GetCryptoKeyVersion: retry[[2]string{"default", "idempotent"}], - CreateKeyRing: retry[[2]string{"default", "non_idempotent"}], - CreateImportJob: retry[[2]string{"default", "non_idempotent"}], - CreateCryptoKey: retry[[2]string{"default", "non_idempotent"}], - CreateCryptoKeyVersion: retry[[2]string{"default", "non_idempotent"}], - ImportCryptoKeyVersion: retry[[2]string{"default", "non_idempotent"}], - UpdateCryptoKey: retry[[2]string{"default", "non_idempotent"}], - UpdateCryptoKeyVersion: retry[[2]string{"default", "non_idempotent"}], - Encrypt: retry[[2]string{"default", "idempotent"}], - Decrypt: retry[[2]string{"default", "idempotent"}], - UpdateCryptoKeyPrimaryVersion: retry[[2]string{"default", "non_idempotent"}], - DestroyCryptoKeyVersion: retry[[2]string{"default", "non_idempotent"}], - RestoreCryptoKeyVersion: retry[[2]string{"default", "non_idempotent"}], - GetPublicKey: retry[[2]string{"default", "idempotent"}], - AsymmetricDecrypt: retry[[2]string{"default", "idempotent"}], - AsymmetricSign: retry[[2]string{"default", "idempotent"}], + ListKeyRings: retry[[2]string{"default", "retryable"}], + ListImportJobs: retry[[2]string{"default", "retryable"}], + ListCryptoKeys: retry[[2]string{"default", "retryable"}], + ListCryptoKeyVersions: retry[[2]string{"default", "retryable"}], + GetKeyRing: retry[[2]string{"default", "retryable"}], + GetImportJob: retry[[2]string{"default", "retryable"}], + GetCryptoKey: retry[[2]string{"default", "retryable"}], + GetCryptoKeyVersion: retry[[2]string{"default", "retryable"}], + CreateKeyRing: retry[[2]string{"default", "retryable"}], + CreateImportJob: retry[[2]string{"default", "retryable"}], + CreateCryptoKey: retry[[2]string{"default", "retryable"}], + CreateCryptoKeyVersion: retry[[2]string{"default", "non_retryable"}], + ImportCryptoKeyVersion: retry[[2]string{"default", "non_retryable"}], + UpdateCryptoKey: retry[[2]string{"default", "retryable"}], + UpdateCryptoKeyVersion: retry[[2]string{"default", "retryable"}], + Encrypt: retry[[2]string{"default", "retryable"}], + Decrypt: retry[[2]string{"default", "retryable"}], + UpdateCryptoKeyPrimaryVersion: retry[[2]string{"default", "retryable"}], + DestroyCryptoKeyVersion: retry[[2]string{"default", "retryable"}], + RestoreCryptoKeyVersion: retry[[2]string{"default", "retryable"}], + GetPublicKey: retry[[2]string{"default", "retryable"}], + AsymmetricDecrypt: retry[[2]string{"default", "retryable"}], + AsymmetricSign: retry[[2]string{"default", "retryable"}], } } diff --git a/language/apiv1/doc.go b/language/apiv1/doc.go index 143fc6f8e7e8..4a1188320ef4 100644 --- a/language/apiv1/doc.go +++ b/language/apiv1/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/language/apiv1/language_client.go b/language/apiv1/language_client.go index 603f0a9ec150..0b0c97c20882 100644 --- a/language/apiv1/language_client.go +++ b/language/apiv1/language_client.go @@ -18,6 +18,7 @@ package language import ( "context" + "math" "time" gax "github.com/googleapis/gax-go/v2" @@ -43,6 +44,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("language.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/language/apiv1beta2/doc.go b/language/apiv1beta2/doc.go index 3a4e1d425d80..cccabc85974a 100644 --- a/language/apiv1beta2/doc.go +++ b/language/apiv1beta2/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/language/apiv1beta2/language_client.go b/language/apiv1beta2/language_client.go index 1d943ad10d23..82656edff3b0 100644 --- a/language/apiv1beta2/language_client.go +++ b/language/apiv1beta2/language_client.go @@ -18,6 +18,7 @@ package language import ( "context" + "math" "time" gax "github.com/googleapis/gax-go/v2" @@ -43,6 +44,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("language.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/logging/apiv2/config_client.go b/logging/apiv2/config_client.go index 747158714fd2..2fb11df64545 100644 --- a/logging/apiv2/config_client.go +++ b/logging/apiv2/config_client.go @@ -52,6 +52,8 @@ func defaultConfigClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("logging.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/logging/apiv2/doc.go b/logging/apiv2/doc.go index cd6d8f7421ec..8db14d135f96 100644 --- a/logging/apiv2/doc.go +++ b/logging/apiv2/doc.go @@ -103,4 +103,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/logging/apiv2/logging_client.go b/logging/apiv2/logging_client.go index f39bdce45759..11ef68aa7807 100644 --- a/logging/apiv2/logging_client.go +++ b/logging/apiv2/logging_client.go @@ -48,6 +48,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("logging.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/logging/apiv2/metrics_client.go b/logging/apiv2/metrics_client.go index 3b70ab741f51..cd074617b20a 100644 --- a/logging/apiv2/metrics_client.go +++ b/logging/apiv2/metrics_client.go @@ -47,6 +47,8 @@ func defaultMetricsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("logging.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/longrunning/autogen/doc.go b/longrunning/autogen/doc.go index 59e345888d2b..bfb96ad2de47 100644 --- a/longrunning/autogen/doc.go +++ b/longrunning/autogen/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/longrunning/autogen/operations_client.go b/longrunning/autogen/operations_client.go index 5ede122767fe..8f24d0afc5d5 100644 --- a/longrunning/autogen/operations_client.go +++ b/longrunning/autogen/operations_client.go @@ -46,6 +46,8 @@ func defaultOperationsClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("longrunning.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/monitoring/apiv3/alert_policy_client.go b/monitoring/apiv3/alert_policy_client.go index 5a43fe2b8655..836b033321a5 100644 --- a/monitoring/apiv3/alert_policy_client.go +++ b/monitoring/apiv3/alert_policy_client.go @@ -47,6 +47,8 @@ func defaultAlertPolicyClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("monitoring.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/monitoring/apiv3/doc.go b/monitoring/apiv3/doc.go index 0b6ae74fef95..0c9464d71276 100644 --- a/monitoring/apiv3/doc.go +++ b/monitoring/apiv3/doc.go @@ -102,4 +102,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/monitoring/apiv3/group_client.go b/monitoring/apiv3/group_client.go index c53719dae352..eecb511e63e9 100644 --- a/monitoring/apiv3/group_client.go +++ b/monitoring/apiv3/group_client.go @@ -49,6 +49,8 @@ func defaultGroupClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("monitoring.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/monitoring/apiv3/metric_client.go b/monitoring/apiv3/metric_client.go index e9c5cc5817a1..bce05a4ceefa 100644 --- a/monitoring/apiv3/metric_client.go +++ b/monitoring/apiv3/metric_client.go @@ -52,6 +52,8 @@ func defaultMetricClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("monitoring.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/monitoring/apiv3/notification_channel_client.go b/monitoring/apiv3/notification_channel_client.go index bf1e7e92de66..f97444af2c2a 100644 --- a/monitoring/apiv3/notification_channel_client.go +++ b/monitoring/apiv3/notification_channel_client.go @@ -52,6 +52,8 @@ func defaultNotificationChannelClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("monitoring.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/monitoring/apiv3/uptime_check_client.go b/monitoring/apiv3/uptime_check_client.go index f0a0501b286f..246262c7f7ce 100644 --- a/monitoring/apiv3/uptime_check_client.go +++ b/monitoring/apiv3/uptime_check_client.go @@ -48,6 +48,8 @@ func defaultUptimeCheckClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("monitoring.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/oslogin/apiv1/doc.go b/oslogin/apiv1/doc.go index 70602d563509..6df0022e0027 100644 --- a/oslogin/apiv1/doc.go +++ b/oslogin/apiv1/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/oslogin/apiv1/os_login_client.go b/oslogin/apiv1/os_login_client.go index fb0cf062c385..90999a408348 100644 --- a/oslogin/apiv1/os_login_client.go +++ b/oslogin/apiv1/os_login_client.go @@ -19,6 +19,7 @@ package oslogin import ( "context" "fmt" + "math" "net/url" "time" @@ -46,6 +47,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("oslogin.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/oslogin/apiv1beta/doc.go b/oslogin/apiv1beta/doc.go index 7b88a1b93085..eda9af6ac1d8 100644 --- a/oslogin/apiv1beta/doc.go +++ b/oslogin/apiv1beta/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/oslogin/apiv1beta/os_login_client.go b/oslogin/apiv1beta/os_login_client.go index 469e00c577e4..f0fbb6fa1f63 100644 --- a/oslogin/apiv1beta/os_login_client.go +++ b/oslogin/apiv1beta/os_login_client.go @@ -19,6 +19,7 @@ package oslogin import ( "context" "fmt" + "math" "net/url" "time" @@ -46,6 +47,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("oslogin.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/phishingprotection/apiv1beta1/doc.go b/phishingprotection/apiv1beta1/doc.go index 346a0670b7c5..e1bd8bb4571c 100644 --- a/phishingprotection/apiv1beta1/doc.go +++ b/phishingprotection/apiv1beta1/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/phishingprotection/apiv1beta1/phishing_protection_service_v1_beta1_client.go b/phishingprotection/apiv1beta1/phishing_protection_service_v1_beta1_client.go index b76db2383af7..06445b0fe71c 100644 --- a/phishingprotection/apiv1beta1/phishing_protection_service_v1_beta1_client.go +++ b/phishingprotection/apiv1beta1/phishing_protection_service_v1_beta1_client.go @@ -19,6 +19,7 @@ package phishingprotection import ( "context" "fmt" + "math" "net/url" gax "github.com/googleapis/gax-go/v2" @@ -38,6 +39,8 @@ func defaultPhishingProtectionServiceV1Beta1ClientOptions() []option.ClientOptio return []option.ClientOption{ option.WithEndpoint("phishingprotection.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/pubsub/apiv1/doc.go b/pubsub/apiv1/doc.go index eeae8918476f..e897795649df 100644 --- a/pubsub/apiv1/doc.go +++ b/pubsub/apiv1/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/pubsub/apiv1/publisher_client.go b/pubsub/apiv1/publisher_client.go index 228395c3e3d9..b99214db0f3d 100644 --- a/pubsub/apiv1/publisher_client.go +++ b/pubsub/apiv1/publisher_client.go @@ -49,6 +49,8 @@ func defaultPublisherClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("pubsub.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/pubsub/apiv1/subscriber_client.go b/pubsub/apiv1/subscriber_client.go index 37d71552b4bf..260615b07922 100644 --- a/pubsub/apiv1/subscriber_client.go +++ b/pubsub/apiv1/subscriber_client.go @@ -57,6 +57,8 @@ func defaultSubscriberClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("pubsub.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/recaptchaenterprise/apiv1beta1/doc.go b/recaptchaenterprise/apiv1beta1/doc.go index ef43722b1b02..408bbdbe0e7a 100644 --- a/recaptchaenterprise/apiv1beta1/doc.go +++ b/recaptchaenterprise/apiv1beta1/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/recaptchaenterprise/apiv1beta1/recaptcha_enterprise_service_v1_beta1_client.go b/recaptchaenterprise/apiv1beta1/recaptcha_enterprise_service_v1_beta1_client.go index 76860077bf3d..5943580b4a72 100644 --- a/recaptchaenterprise/apiv1beta1/recaptcha_enterprise_service_v1_beta1_client.go +++ b/recaptchaenterprise/apiv1beta1/recaptcha_enterprise_service_v1_beta1_client.go @@ -19,6 +19,7 @@ package recaptchaenterprise import ( "context" "fmt" + "math" "net/url" gax "github.com/googleapis/gax-go/v2" @@ -39,6 +40,8 @@ func defaultRecaptchaEnterpriseServiceV1Beta1ClientOptions() []option.ClientOpti return []option.ClientOption{ option.WithEndpoint("recaptchaenterprise.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/redis/apiv1/cloud_redis_client.go b/redis/apiv1/cloud_redis_client.go index 013c1b43381f..e031b1f1feeb 100644 --- a/redis/apiv1/cloud_redis_client.go +++ b/redis/apiv1/cloud_redis_client.go @@ -52,6 +52,8 @@ func defaultCloudRedisClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("redis.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/redis/apiv1/doc.go b/redis/apiv1/doc.go index ed72a2d9c33f..8fbcd182857a 100644 --- a/redis/apiv1/doc.go +++ b/redis/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/redis/apiv1beta1/cloud_redis_client.go b/redis/apiv1beta1/cloud_redis_client.go index bbb033ec69ec..c94036df0b39 100644 --- a/redis/apiv1beta1/cloud_redis_client.go +++ b/redis/apiv1beta1/cloud_redis_client.go @@ -53,6 +53,8 @@ func defaultCloudRedisClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("redis.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/redis/apiv1beta1/doc.go b/redis/apiv1beta1/doc.go index 13f21aaf6f19..547959a08ecb 100644 --- a/redis/apiv1beta1/doc.go +++ b/redis/apiv1beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/scheduler/apiv1/cloud_scheduler_client.go b/scheduler/apiv1/cloud_scheduler_client.go index 361b87a7b7a5..6a7eda0fd6f1 100644 --- a/scheduler/apiv1/cloud_scheduler_client.go +++ b/scheduler/apiv1/cloud_scheduler_client.go @@ -50,6 +50,8 @@ func defaultCloudSchedulerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudscheduler.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/scheduler/apiv1/doc.go b/scheduler/apiv1/doc.go index 64fd89581ae0..e80edb7b539f 100644 --- a/scheduler/apiv1/doc.go +++ b/scheduler/apiv1/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/scheduler/apiv1beta1/cloud_scheduler_client.go b/scheduler/apiv1beta1/cloud_scheduler_client.go index 665fa6f9132b..71caedf8f2d9 100644 --- a/scheduler/apiv1beta1/cloud_scheduler_client.go +++ b/scheduler/apiv1beta1/cloud_scheduler_client.go @@ -50,6 +50,8 @@ func defaultCloudSchedulerClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudscheduler.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/scheduler/apiv1beta1/doc.go b/scheduler/apiv1beta1/doc.go index ab88d4c47037..e36474957f5c 100644 --- a/scheduler/apiv1beta1/doc.go +++ b/scheduler/apiv1beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/securitycenter/apiv1/doc.go b/securitycenter/apiv1/doc.go index f9ff19d2e466..a09f6fce09fe 100644 --- a/securitycenter/apiv1/doc.go +++ b/securitycenter/apiv1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/securitycenter/apiv1/security_center_client.go b/securitycenter/apiv1/security_center_client.go index f4915b9750e6..c12c47d88bc4 100644 --- a/securitycenter/apiv1/security_center_client.go +++ b/securitycenter/apiv1/security_center_client.go @@ -64,6 +64,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("securitycenter.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/securitycenter/apiv1beta1/doc.go b/securitycenter/apiv1beta1/doc.go index 06c5cd58c86d..4d9996acd159 100644 --- a/securitycenter/apiv1beta1/doc.go +++ b/securitycenter/apiv1beta1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/securitycenter/apiv1beta1/security_center_client.go b/securitycenter/apiv1beta1/security_center_client.go index 4383fdff1b4d..1f822ff97e18 100644 --- a/securitycenter/apiv1beta1/security_center_client.go +++ b/securitycenter/apiv1beta1/security_center_client.go @@ -64,6 +64,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("securitycenter.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/spanner/admin/database/apiv1/database_admin_client.go b/spanner/admin/database/apiv1/database_admin_client.go index 65a8e14c87d7..77b5740e3f7b 100644 --- a/spanner/admin/database/apiv1/database_admin_client.go +++ b/spanner/admin/database/apiv1/database_admin_client.go @@ -55,6 +55,8 @@ func defaultDatabaseAdminClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("spanner.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/spanner/admin/database/apiv1/doc.go b/spanner/admin/database/apiv1/doc.go index b5de905b9a04..5e38c8e172b7 100644 --- a/spanner/admin/database/apiv1/doc.go +++ b/spanner/admin/database/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/spanner/admin/instance/apiv1/doc.go b/spanner/admin/instance/apiv1/doc.go index 030c9351ac27..a3b5e6db8dcc 100644 --- a/spanner/admin/instance/apiv1/doc.go +++ b/spanner/admin/instance/apiv1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/spanner/admin/instance/apiv1/instance_admin_client.go b/spanner/admin/instance/apiv1/instance_admin_client.go index c47bc284dcde..74f712a4b208 100644 --- a/spanner/admin/instance/apiv1/instance_admin_client.go +++ b/spanner/admin/instance/apiv1/instance_admin_client.go @@ -56,6 +56,8 @@ func defaultInstanceAdminClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("spanner.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/spanner/apiv1/doc.go b/spanner/apiv1/doc.go index a8dd3accb71a..56b1d4019066 100644 --- a/spanner/apiv1/doc.go +++ b/spanner/apiv1/doc.go @@ -100,4 +100,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/spanner/apiv1/spanner_client.go b/spanner/apiv1/spanner_client.go index dc9add691d6c..09f3e5428ee6 100644 --- a/spanner/apiv1/spanner_client.go +++ b/spanner/apiv1/spanner_client.go @@ -56,6 +56,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("spanner.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/speech/apiv1/doc.go b/speech/apiv1/doc.go index 88282307f2b1..8283a66eaed7 100644 --- a/speech/apiv1/doc.go +++ b/speech/apiv1/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/speech/apiv1/speech_client.go b/speech/apiv1/speech_client.go index 33000d190ec3..ea5c80306909 100644 --- a/speech/apiv1/speech_client.go +++ b/speech/apiv1/speech_client.go @@ -18,6 +18,7 @@ package speech import ( "context" + "math" "time" "cloud.google.com/go/longrunning" @@ -43,6 +44,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("speech.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/speech/apiv1p1beta1/doc.go b/speech/apiv1p1beta1/doc.go index 83b3ad1e94fa..2630596f453f 100644 --- a/speech/apiv1p1beta1/doc.go +++ b/speech/apiv1p1beta1/doc.go @@ -97,4 +97,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/speech/apiv1p1beta1/speech_client.go b/speech/apiv1p1beta1/speech_client.go index 631a089cc6f0..11f8e3014f07 100644 --- a/speech/apiv1p1beta1/speech_client.go +++ b/speech/apiv1p1beta1/speech_client.go @@ -18,6 +18,7 @@ package speech import ( "context" + "math" "time" "cloud.google.com/go/longrunning" @@ -43,6 +44,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("speech.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/application_client.go b/talent/apiv4beta1/application_client.go index f472bb0cb97b..f616302968c1 100644 --- a/talent/apiv4beta1/application_client.go +++ b/talent/apiv4beta1/application_client.go @@ -47,6 +47,8 @@ func defaultApplicationClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/company_client.go b/talent/apiv4beta1/company_client.go index c249a71a4b3b..89dcde8bad6d 100644 --- a/talent/apiv4beta1/company_client.go +++ b/talent/apiv4beta1/company_client.go @@ -47,6 +47,8 @@ func defaultCompanyClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/completion_client.go b/talent/apiv4beta1/completion_client.go index f68ee8638a55..74c7529fa24c 100644 --- a/talent/apiv4beta1/completion_client.go +++ b/talent/apiv4beta1/completion_client.go @@ -19,6 +19,7 @@ package talent import ( "context" "fmt" + "math" "net/url" "time" @@ -40,6 +41,8 @@ func defaultCompletionClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/doc.go b/talent/apiv4beta1/doc.go index 742eea568f41..b6bdedaf9768 100644 --- a/talent/apiv4beta1/doc.go +++ b/talent/apiv4beta1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/talent/apiv4beta1/event_client.go b/talent/apiv4beta1/event_client.go index 64f032df9c59..e52c0a2ee1aa 100644 --- a/talent/apiv4beta1/event_client.go +++ b/talent/apiv4beta1/event_client.go @@ -19,6 +19,7 @@ package talent import ( "context" "fmt" + "math" "net/url" gax "github.com/googleapis/gax-go/v2" @@ -38,6 +39,8 @@ func defaultEventClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/job_client.go b/talent/apiv4beta1/job_client.go index 647bae4b1c78..69c9df67cb36 100644 --- a/talent/apiv4beta1/job_client.go +++ b/talent/apiv4beta1/job_client.go @@ -55,6 +55,8 @@ func defaultJobClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/profile_client.go b/talent/apiv4beta1/profile_client.go index 1ff88262998f..8be89dbcb56d 100644 --- a/talent/apiv4beta1/profile_client.go +++ b/talent/apiv4beta1/profile_client.go @@ -48,6 +48,8 @@ func defaultProfileClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/talent/apiv4beta1/tenant_client.go b/talent/apiv4beta1/tenant_client.go index c8836f922c78..cd0c1d5876ec 100644 --- a/talent/apiv4beta1/tenant_client.go +++ b/talent/apiv4beta1/tenant_client.go @@ -47,6 +47,8 @@ func defaultTenantClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("jobs.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/texttospeech/apiv1/doc.go b/texttospeech/apiv1/doc.go index a2e707be1f92..4ed18a0b5416 100644 --- a/texttospeech/apiv1/doc.go +++ b/texttospeech/apiv1/doc.go @@ -98,4 +98,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/texttospeech/apiv1/text_to_speech_client.go b/texttospeech/apiv1/text_to_speech_client.go index 74cb9b7e8271..13af2b8609c4 100644 --- a/texttospeech/apiv1/text_to_speech_client.go +++ b/texttospeech/apiv1/text_to_speech_client.go @@ -18,6 +18,7 @@ package texttospeech import ( "context" + "math" "time" gax "github.com/googleapis/gax-go/v2" @@ -39,6 +40,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("texttospeech.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/trace/apiv1/doc.go b/trace/apiv1/doc.go index 292bed8ec691..4168ecfcfc76 100644 --- a/trace/apiv1/doc.go +++ b/trace/apiv1/doc.go @@ -105,4 +105,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/trace/apiv1/trace_client.go b/trace/apiv1/trace_client.go index c26f426c42c6..7bfb4114d22d 100644 --- a/trace/apiv1/trace_client.go +++ b/trace/apiv1/trace_client.go @@ -45,6 +45,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudtrace.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/trace/apiv2/doc.go b/trace/apiv2/doc.go index ee046abddb1d..51d2778334e7 100644 --- a/trace/apiv2/doc.go +++ b/trace/apiv2/doc.go @@ -102,4 +102,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/trace/apiv2/trace_client.go b/trace/apiv2/trace_client.go index 1a51184fb20b..f1cd45236983 100644 --- a/trace/apiv2/trace_client.go +++ b/trace/apiv2/trace_client.go @@ -19,6 +19,7 @@ package trace import ( "context" "fmt" + "math" "net/url" "time" @@ -41,6 +42,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("cloudtrace.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/videointelligence/apiv1/doc.go b/videointelligence/apiv1/doc.go index 866421f4c928..e7142dabb28c 100644 --- a/videointelligence/apiv1/doc.go +++ b/videointelligence/apiv1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/videointelligence/apiv1/video_intelligence_client.go b/videointelligence/apiv1/video_intelligence_client.go index 0991ebaab173..de11f1f27bbd 100644 --- a/videointelligence/apiv1/video_intelligence_client.go +++ b/videointelligence/apiv1/video_intelligence_client.go @@ -18,6 +18,7 @@ package videointelligence import ( "context" + "math" "time" "cloud.google.com/go/longrunning" @@ -41,6 +42,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("videointelligence.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/videointelligence/apiv1beta1/doc.go b/videointelligence/apiv1beta1/doc.go index 34cd11062760..add2003d7753 100644 --- a/videointelligence/apiv1beta1/doc.go +++ b/videointelligence/apiv1beta1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/videointelligence/apiv1beta1/video_intelligence_client.go b/videointelligence/apiv1beta1/video_intelligence_client.go index 8c3e30bbc850..e1d903ce4eec 100644 --- a/videointelligence/apiv1beta1/video_intelligence_client.go +++ b/videointelligence/apiv1beta1/video_intelligence_client.go @@ -18,6 +18,7 @@ package videointelligence import ( "context" + "math" "time" "cloud.google.com/go/longrunning" @@ -41,6 +42,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("videointelligence.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/videointelligence/apiv1beta2/doc.go b/videointelligence/apiv1beta2/doc.go index aeae913a8c58..931876f91394 100644 --- a/videointelligence/apiv1beta2/doc.go +++ b/videointelligence/apiv1beta2/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/videointelligence/apiv1beta2/video_intelligence_client.go b/videointelligence/apiv1beta2/video_intelligence_client.go index 3b88e5f4d3d5..0253ae9cf2c9 100644 --- a/videointelligence/apiv1beta2/video_intelligence_client.go +++ b/videointelligence/apiv1beta2/video_intelligence_client.go @@ -18,6 +18,7 @@ package videointelligence import ( "context" + "math" "time" "cloud.google.com/go/longrunning" @@ -41,6 +42,8 @@ func defaultClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("videointelligence.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/vision/apiv1/doc.go b/vision/apiv1/doc.go index b5368d68c509..21f0822948fc 100644 --- a/vision/apiv1/doc.go +++ b/vision/apiv1/doc.go @@ -99,4 +99,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/vision/apiv1/image_annotator_client.go b/vision/apiv1/image_annotator_client.go index 55c3e5d750d9..99778ad04b70 100644 --- a/vision/apiv1/image_annotator_client.go +++ b/vision/apiv1/image_annotator_client.go @@ -18,6 +18,9 @@ package vision import ( "context" + "fmt" + "math" + "net/url" "time" "cloud.google.com/go/longrunning" @@ -44,6 +47,8 @@ func defaultImageAnnotatorClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("vision.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } @@ -145,7 +150,8 @@ func (c *ImageAnnotatorClient) setGoogleClientInfo(keyval ...string) { // BatchAnnotateImages run image detection and annotation for a batch of images. func (c *ImageAnnotatorClient) BatchAnnotateImages(ctx context.Context, req *visionpb.BatchAnnotateImagesRequest, opts ...gax.CallOption) (*visionpb.BatchAnnotateImagesResponse, error) { - ctx = insertMetadata(ctx, c.xGoogMetadata) + 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.BatchAnnotateImages[0:len(c.CallOptions.BatchAnnotateImages):len(c.CallOptions.BatchAnnotateImages)], opts...) var resp *visionpb.BatchAnnotateImagesResponse err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { @@ -167,7 +173,8 @@ func (c *ImageAnnotatorClient) BatchAnnotateImages(ctx context.Context, req *vis // file provided and perform detection and annotation for each image // extracted. func (c *ImageAnnotatorClient) BatchAnnotateFiles(ctx context.Context, req *visionpb.BatchAnnotateFilesRequest, opts ...gax.CallOption) (*visionpb.BatchAnnotateFilesResponse, error) { - ctx = insertMetadata(ctx, c.xGoogMetadata) + 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.BatchAnnotateFiles[0:len(c.CallOptions.BatchAnnotateFiles):len(c.CallOptions.BatchAnnotateFiles)], opts...) var resp *visionpb.BatchAnnotateFilesResponse err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { @@ -191,7 +198,8 @@ func (c *ImageAnnotatorClient) BatchAnnotateFiles(ctx context.Context, req *visi // This service will write image annotation outputs to json files in customer // GCS bucket, each json file containing BatchAnnotateImagesResponse proto. func (c *ImageAnnotatorClient) AsyncBatchAnnotateImages(ctx context.Context, req *visionpb.AsyncBatchAnnotateImagesRequest, opts ...gax.CallOption) (*AsyncBatchAnnotateImagesOperation, error) { - ctx = insertMetadata(ctx, c.xGoogMetadata) + 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.AsyncBatchAnnotateImages[0:len(c.CallOptions.AsyncBatchAnnotateImages):len(c.CallOptions.AsyncBatchAnnotateImages)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { @@ -214,7 +222,8 @@ func (c *ImageAnnotatorClient) AsyncBatchAnnotateImages(ctx context.Context, req // Operation.metadata contains OperationMetadata (metadata). // Operation.response contains AsyncBatchAnnotateFilesResponse (results). func (c *ImageAnnotatorClient) AsyncBatchAnnotateFiles(ctx context.Context, req *visionpb.AsyncBatchAnnotateFilesRequest, opts ...gax.CallOption) (*AsyncBatchAnnotateFilesOperation, error) { - ctx = insertMetadata(ctx, c.xGoogMetadata) + 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.AsyncBatchAnnotateFiles[0:len(c.CallOptions.AsyncBatchAnnotateFiles):len(c.CallOptions.AsyncBatchAnnotateFiles)], opts...) var resp *longrunningpb.Operation err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { diff --git a/vision/apiv1/mock_test.go b/vision/apiv1/mock_test.go index aecf2bdcf139..36122066f922 100644 --- a/vision/apiv1/mock_test.go +++ b/vision/apiv1/mock_test.go @@ -341,6 +341,18 @@ func (s *mockProductSearchServer) ImportProductSets(ctx context.Context, req *vi return s.resps[0].(*longrunningpb.Operation), nil } +func (s *mockProductSearchServer) PurgeProducts(ctx context.Context, req *visionpb.PurgeProductsRequest) (*longrunningpb.Operation, error) { + md, _ := metadata.FromIncomingContext(ctx) + if xg := md["x-goog-api-client"]; len(xg) == 0 || !strings.Contains(xg[0], "gl-go/") { + return nil, fmt.Errorf("x-goog-api-client = %v, expected gl-go key", xg) + } + s.reqs = append(s.reqs, req) + if s.err != nil { + return nil, s.err + } + return s.resps[0].(*longrunningpb.Operation), nil +} + // clientOpt is the option tests should use to connect to the test server. // It is initialized by TestMain. var clientOpt option.ClientOption @@ -1808,3 +1820,81 @@ func TestProductSearchImportProductSetsError(t *testing.T) { } _ = resp } +func TestProductSearchPurgeProducts(t *testing.T) { + var expectedResponse *emptypb.Empty = &emptypb.Empty{} + + mockProductSearch.err = nil + mockProductSearch.reqs = nil + + any, err := ptypes.MarshalAny(expectedResponse) + if err != nil { + t.Fatal(err) + } + mockProductSearch.resps = append(mockProductSearch.resps[:0], &longrunningpb.Operation{ + Name: "longrunning-test", + Done: true, + Result: &longrunningpb.Operation_Response{Response: any}, + }) + + var formattedParent string = fmt.Sprintf("projects/%s/locations/%s", "[PROJECT]", "[LOCATION]") + var request = &visionpb.PurgeProductsRequest{ + Parent: formattedParent, + } + + c, err := NewProductSearchClient(context.Background(), clientOpt) + if err != nil { + t.Fatal(err) + } + + respLRO, err := c.PurgeProducts(context.Background(), request) + if err != nil { + t.Fatal(err) + } + err = respLRO.Wait(context.Background()) + + if err != nil { + t.Fatal(err) + } + + if want, got := request, mockProductSearch.reqs[0]; !proto.Equal(want, got) { + t.Errorf("wrong request %q, want %q", got, want) + } + +} + +func TestProductSearchPurgeProductsError(t *testing.T) { + errCode := codes.PermissionDenied + mockProductSearch.err = nil + mockProductSearch.resps = append(mockProductSearch.resps[:0], &longrunningpb.Operation{ + Name: "longrunning-test", + Done: true, + Result: &longrunningpb.Operation_Error{ + Error: &status.Status{ + Code: int32(errCode), + Message: "test error", + }, + }, + }) + + var formattedParent string = fmt.Sprintf("projects/%s/locations/%s", "[PROJECT]", "[LOCATION]") + var request = &visionpb.PurgeProductsRequest{ + Parent: formattedParent, + } + + c, err := NewProductSearchClient(context.Background(), clientOpt) + if err != nil { + t.Fatal(err) + } + + respLRO, err := c.PurgeProducts(context.Background(), request) + if err != nil { + t.Fatal(err) + } + err = respLRO.Wait(context.Background()) + + if st, ok := gstatus.FromError(err); !ok { + t.Errorf("got error %v, expected grpc error", err) + } else if c := st.Code(); c != errCode { + t.Errorf("got error code %q, want %q", c, errCode) + } +} diff --git a/vision/apiv1/product_search_client.go b/vision/apiv1/product_search_client.go index 1af5ee78a352..34788c3d217c 100644 --- a/vision/apiv1/product_search_client.go +++ b/vision/apiv1/product_search_client.go @@ -57,12 +57,15 @@ type ProductSearchCallOptions struct { RemoveProductFromProductSet []gax.CallOption ListProductsInProductSet []gax.CallOption ImportProductSets []gax.CallOption + PurgeProducts []gax.CallOption } func defaultProductSearchClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("vision.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } @@ -100,6 +103,7 @@ func defaultProductSearchCallOptions() *ProductSearchCallOptions { RemoveProductFromProductSet: retry[[2]string{"default", "idempotent"}], ListProductsInProductSet: retry[[2]string{"default", "idempotent"}], ImportProductSets: retry[[2]string{"default", "non_idempotent"}], + PurgeProducts: retry[[2]string{"default", "non_idempotent"}], } } @@ -689,6 +693,48 @@ func (c *ProductSearchClient) ImportProductSets(ctx context.Context, req *vision }, nil } +// PurgeProducts asynchronous API to delete all Products in a ProductSet or all Products +// that are in no ProductSet. +// +// If a Product is a member of the specified ProductSet in addition to other +// ProductSets, the Product will still be deleted. +// +// It is recommended to not delete the specified ProductSet until after this +// operation has completed. It is also recommended to not add any of the +// Products involved in the batch delete to a new ProductSet while this +// operation is running because those Products may still end up deleted. +// +// It's not possible to undo the PurgeProducts operation. Therefore, it is +// recommended to keep the csv files used in ImportProductSets (if that was +// how you originally built the Product Set) before starting PurgeProducts, in +// case you need to re-import the data after deletion. +// +// If the plan is to purge all of the Products from a ProductSet and then +// re-use the empty ProductSet to re-import new Products into the empty +// ProductSet, you must wait until the PurgeProducts operation has finished +// for that ProductSet. +// +// The [google.longrunning.Operation][google.longrunning.Operation] API can be +// used to keep track of the progress and results of the request. +// Operation.metadata contains BatchOperationMetadata. (progress) +func (c *ProductSearchClient) PurgeProducts(ctx context.Context, req *visionpb.PurgeProductsRequest, opts ...gax.CallOption) (*PurgeProductsOperation, error) { + 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.PurgeProducts[0:len(c.CallOptions.PurgeProducts):len(c.CallOptions.PurgeProducts)], opts...) + var resp *longrunningpb.Operation + err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error { + var err error + resp, err = c.productSearchClient.PurgeProducts(ctx, req, settings.GRPC...) + return err + }, opts...) + if err != nil { + return nil, err + } + return &PurgeProductsOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, resp), + }, nil +} + // ProductIterator manages a stream of *visionpb.Product. type ProductIterator struct { items []*visionpb.Product @@ -883,3 +929,59 @@ func (op *ImportProductSetsOperation) Done() bool { func (op *ImportProductSetsOperation) Name() string { return op.lro.Name() } + +// PurgeProductsOperation manages a long-running operation from PurgeProducts. +type PurgeProductsOperation struct { + lro *longrunning.Operation +} + +// PurgeProductsOperation returns a new PurgeProductsOperation from a given name. +// The name must be that of a previously created PurgeProductsOperation, possibly from a different process. +func (c *ProductSearchClient) PurgeProductsOperation(name string) *PurgeProductsOperation { + return &PurgeProductsOperation{ + lro: longrunning.InternalNewOperation(c.LROClient, &longrunningpb.Operation{Name: name}), + } +} + +// Wait blocks until the long-running operation is completed, returning any error encountered. +// +// See documentation of Poll for error-handling information. +func (op *PurgeProductsOperation) Wait(ctx context.Context, opts ...gax.CallOption) error { + return op.lro.WaitWithInterval(ctx, nil, 45000*time.Millisecond, 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. +func (op *PurgeProductsOperation) 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 *PurgeProductsOperation) Metadata() (*visionpb.BatchOperationMetadata, error) { + var meta visionpb.BatchOperationMetadata + 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 *PurgeProductsOperation) 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 *PurgeProductsOperation) Name() string { + return op.lro.Name() +} diff --git a/vision/apiv1/product_search_client_example_test.go b/vision/apiv1/product_search_client_example_test.go index 20b8d38bd5f0..81b40e0dbe4b 100644 --- a/vision/apiv1/product_search_client_example_test.go +++ b/vision/apiv1/product_search_client_example_test.go @@ -376,3 +376,22 @@ func ExampleProductSearchClient_ImportProductSets() { // TODO: Use resp. _ = resp } + +func ExampleProductSearchClient_PurgeProducts() { + ctx := context.Background() + c, err := vision.NewProductSearchClient(ctx) + if err != nil { + // TODO: Handle error. + } + + req := &visionpb.PurgeProductsRequest{ + // TODO: Fill request struct fields. + } + op, err := c.PurgeProducts(ctx, req) + if err != nil { + // TODO: Handle error. + } + + err = op.Wait(ctx) + // TODO: Handle error. +} diff --git a/vision/apiv1p1beta1/doc.go b/vision/apiv1p1beta1/doc.go index cfd44ab7c86b..80077c635e7c 100644 --- a/vision/apiv1p1beta1/doc.go +++ b/vision/apiv1p1beta1/doc.go @@ -101,4 +101,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/vision/apiv1p1beta1/image_annotator_client.go b/vision/apiv1p1beta1/image_annotator_client.go index 05653748585d..3f6a4980a384 100644 --- a/vision/apiv1p1beta1/image_annotator_client.go +++ b/vision/apiv1p1beta1/image_annotator_client.go @@ -18,6 +18,7 @@ package vision import ( "context" + "math" "time" gax "github.com/googleapis/gax-go/v2" @@ -38,6 +39,8 @@ func defaultImageAnnotatorClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("vision.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } } diff --git a/webrisk/apiv1beta1/doc.go b/webrisk/apiv1beta1/doc.go index 33d5257a325f..0b73e87c4ccc 100644 --- a/webrisk/apiv1beta1/doc.go +++ b/webrisk/apiv1beta1/doc.go @@ -96,4 +96,4 @@ func versionGo() string { return "UNKNOWN" } -const versionClient = "20190801" +const versionClient = "20190819" diff --git a/webrisk/apiv1beta1/web_risk_service_v1_beta1_client.go b/webrisk/apiv1beta1/web_risk_service_v1_beta1_client.go index 28e632fcce48..e3a7b8230f66 100644 --- a/webrisk/apiv1beta1/web_risk_service_v1_beta1_client.go +++ b/webrisk/apiv1beta1/web_risk_service_v1_beta1_client.go @@ -18,6 +18,7 @@ package webrisk import ( "context" + "math" "time" gax "github.com/googleapis/gax-go/v2" @@ -40,6 +41,8 @@ func defaultWebRiskServiceV1Beta1ClientOptions() []option.ClientOption { return []option.ClientOption{ option.WithEndpoint("webrisk.googleapis.com:443"), option.WithScopes(DefaultAuthScopes()...), + option.WithGRPCDialOption(grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(math.MaxInt32))), } }