Skip to content

Commit

Permalink
Regenerate server-streaming calls with Google request params
Browse files Browse the repository at this point in the history 
This uses the generator change in googleapis/gapic-generator-csharp#330

Fixes #6310.
  • Loading branch information
@jskeet
jskeet committed Apr 14, 2021
1 parent 080055b commit 9f5f0aa
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion ...Google.Cloud.BigQuery.Storage.V1/Google.Cloud.BigQuery.Storage.V1/BigQueryReadClient.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -758,7 +758,7 @@ public BigQueryReadClientImpl(BigQueryRead.BigQueryReadClient grpcClient, BigQue
_callCreateReadSession = clientHelper.BuildApiCall<CreateReadSessionRequest, ReadSession>(grpcClient.CreateReadSessionAsync, grpcClient.CreateReadSession, effectiveSettings.CreateReadSessionSettings).WithGoogleRequestParam("read_session.table", request => request.ReadSession?.Table);
Modify_ApiCall(ref _callCreateReadSession);
Modify_CreateReadSessionApiCall(ref _callCreateReadSession);
_callReadRows = clientHelper.BuildApiCall<ReadRowsRequest, ReadRowsResponse>(grpcClient.ReadRows, effectiveSettings.ReadRowsSettings);
_callReadRows = clientHelper.BuildApiCall<ReadRowsRequest, ReadRowsResponse>(grpcClient.ReadRows, effectiveSettings.ReadRowsSettings).WithGoogleRequestParam("read_stream", request => request.ReadStream);
Modify_ApiCall(ref _callReadRows);
Modify_ReadRowsApiCall(ref _callReadRows);
_callSplitReadStream = clientHelper.BuildApiCall<SplitReadStreamRequest, SplitReadStreamResponse>(grpcClient.SplitReadStreamAsync, grpcClient.SplitReadStream, effectiveSettings.SplitReadStreamSettings).WithGoogleRequestParam("name", request => request.Name);
Expand Down
6 changes: 3 additions & 3 deletions apis/Google.Cloud.Bigtable.V2/Google.Cloud.Bigtable.V2/BigtableServiceApiClient.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2090,16 +2090,16 @@ public BigtableServiceApiClientImpl(Bigtable.BigtableClient grpcClient, Bigtable
GrpcClient = grpcClient;
BigtableServiceApiSettings effectiveSettings = settings ?? BigtableServiceApiSettings.GetDefault();
gaxgrpc::ClientHelper clientHelper = new gaxgrpc::ClientHelper(effectiveSettings);
_callReadRows = clientHelper.BuildApiCall<ReadRowsRequest, ReadRowsResponse>(grpcClient.ReadRows, effectiveSettings.ReadRowsSettings);
_callReadRows = clientHelper.BuildApiCall<ReadRowsRequest, ReadRowsResponse>(grpcClient.ReadRows, effectiveSettings.ReadRowsSettings).WithGoogleRequestParam("table_name", request => request.TableName);
Modify_ApiCall(ref _callReadRows);
Modify_ReadRowsApiCall(ref _callReadRows);
_callSampleRowKeys = clientHelper.BuildApiCall<SampleRowKeysRequest, SampleRowKeysResponse>(grpcClient.SampleRowKeys, effectiveSettings.SampleRowKeysSettings);
_callSampleRowKeys = clientHelper.BuildApiCall<SampleRowKeysRequest, SampleRowKeysResponse>(grpcClient.SampleRowKeys, effectiveSettings.SampleRowKeysSettings).WithGoogleRequestParam("table_name", request => request.TableName);
Modify_ApiCall(ref _callSampleRowKeys);
Modify_SampleRowKeysApiCall(ref _callSampleRowKeys);
_callMutateRow = clientHelper.BuildApiCall<MutateRowRequest, MutateRowResponse>(grpcClient.MutateRowAsync, grpcClient.MutateRow, effectiveSettings.MutateRowSettings).WithGoogleRequestParam("table_name", request => request.TableName);
Modify_ApiCall(ref _callMutateRow);
Modify_MutateRowApiCall(ref _callMutateRow);
_callMutateRows = clientHelper.BuildApiCall<MutateRowsRequest, MutateRowsResponse>(grpcClient.MutateRows, effectiveSettings.MutateRowsSettings);
_callMutateRows = clientHelper.BuildApiCall<MutateRowsRequest, MutateRowsResponse>(grpcClient.MutateRows, effectiveSettings.MutateRowsSettings).WithGoogleRequestParam("table_name", request => request.TableName);
Modify_ApiCall(ref _callMutateRows);
Modify_MutateRowsApiCall(ref _callMutateRows);
_callCheckAndMutateRow = clientHelper.BuildApiCall<CheckAndMutateRowRequest, CheckAndMutateRowResponse>(grpcClient.CheckAndMutateRowAsync, grpcClient.CheckAndMutateRow, effectiveSettings.CheckAndMutateRowSettings).WithGoogleRequestParam("table_name", request => request.TableName);
Expand Down
4 changes: 2 additions & 2 deletions apis/Google.Cloud.Firestore.V1/Google.Cloud.Firestore.V1/FirestoreClient.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1192,7 +1192,7 @@ public FirestoreClientImpl(Firestore.FirestoreClient grpcClient, FirestoreSettin
_callDeleteDocument = clientHelper.BuildApiCall<DeleteDocumentRequest, wkt::Empty>(grpcClient.DeleteDocumentAsync, grpcClient.DeleteDocument, effectiveSettings.DeleteDocumentSettings).WithGoogleRequestParam("name", request => request.Name);
Modify_ApiCall(ref _callDeleteDocument);
Modify_DeleteDocumentApiCall(ref _callDeleteDocument);
_callBatchGetDocuments = clientHelper.BuildApiCall<BatchGetDocumentsRequest, BatchGetDocumentsResponse>(grpcClient.BatchGetDocuments, effectiveSettings.BatchGetDocumentsSettings);
_callBatchGetDocuments = clientHelper.BuildApiCall<BatchGetDocumentsRequest, BatchGetDocumentsResponse>(grpcClient.BatchGetDocuments, effectiveSettings.BatchGetDocumentsSettings).WithGoogleRequestParam("database", request => request.Database);
Modify_ApiCall(ref _callBatchGetDocuments);
Modify_BatchGetDocumentsApiCall(ref _callBatchGetDocuments);
_callBeginTransaction = clientHelper.BuildApiCall<BeginTransactionRequest, BeginTransactionResponse>(grpcClient.BeginTransactionAsync, grpcClient.BeginTransaction, effectiveSettings.BeginTransactionSettings).WithGoogleRequestParam("database", request => request.Database);
Expand All @@ -1204,7 +1204,7 @@ public FirestoreClientImpl(Firestore.FirestoreClient grpcClient, FirestoreSettin
_callRollback = clientHelper.BuildApiCall<RollbackRequest, wkt::Empty>(grpcClient.RollbackAsync, grpcClient.Rollback, effectiveSettings.RollbackSettings).WithGoogleRequestParam("database", request => request.Database);
Modify_ApiCall(ref _callRollback);
Modify_RollbackApiCall(ref _callRollback);
_callRunQuery = clientHelper.BuildApiCall<RunQueryRequest, RunQueryResponse>(grpcClient.RunQuery, effectiveSettings.RunQuerySettings);
_callRunQuery = clientHelper.BuildApiCall<RunQueryRequest, RunQueryResponse>(grpcClient.RunQuery, effectiveSettings.RunQuerySettings).WithGoogleRequestParam("parent", request => request.Parent);
Modify_ApiCall(ref _callRunQuery);
Modify_RunQueryApiCall(ref _callRunQuery);
_callPartitionQuery = clientHelper.BuildApiCall<PartitionQueryRequest, PartitionQueryResponse>(grpcClient.PartitionQueryAsync, grpcClient.PartitionQuery, effectiveSettings.PartitionQuerySettings).WithGoogleRequestParam("parent", request => request.Parent);
Expand Down
4 changes: 2 additions & 2 deletions apis/Google.Cloud.Spanner.V1/Google.Cloud.Spanner.V1/SpannerClient.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2548,7 +2548,7 @@ public SpannerClientImpl(Spanner.SpannerClient grpcClient, SpannerSettings setti
_callExecuteSql = clientHelper.BuildApiCall<ExecuteSqlRequest, ResultSet>(grpcClient.ExecuteSqlAsync, grpcClient.ExecuteSql, effectiveSettings.ExecuteSqlSettings).WithGoogleRequestParam("session", request => request.Session);
Modify_ApiCall(ref _callExecuteSql);
Modify_ExecuteSqlApiCall(ref _callExecuteSql);
_callExecuteStreamingSql = clientHelper.BuildApiCall<ExecuteSqlRequest, PartialResultSet>(grpcClient.ExecuteStreamingSql, effectiveSettings.ExecuteStreamingSqlSettings);
_callExecuteStreamingSql = clientHelper.BuildApiCall<ExecuteSqlRequest, PartialResultSet>(grpcClient.ExecuteStreamingSql, effectiveSettings.ExecuteStreamingSqlSettings).WithGoogleRequestParam("session", request => request.Session);
Modify_ApiCall(ref _callExecuteStreamingSql);
Modify_ExecuteStreamingSqlApiCall(ref _callExecuteStreamingSql);
_callExecuteBatchDml = clientHelper.BuildApiCall<ExecuteBatchDmlRequest, ExecuteBatchDmlResponse>(grpcClient.ExecuteBatchDmlAsync, grpcClient.ExecuteBatchDml, effectiveSettings.ExecuteBatchDmlSettings).WithGoogleRequestParam("session", request => request.Session);
Expand All @@ -2557,7 +2557,7 @@ public SpannerClientImpl(Spanner.SpannerClient grpcClient, SpannerSettings setti
_callRead = clientHelper.BuildApiCall<ReadRequest, ResultSet>(grpcClient.ReadAsync, grpcClient.Read, effectiveSettings.ReadSettings).WithGoogleRequestParam("session", request => request.Session);
Modify_ApiCall(ref _callRead);
Modify_ReadApiCall(ref _callRead);
_callStreamingRead = clientHelper.BuildApiCall<ReadRequest, PartialResultSet>(grpcClient.StreamingRead, effectiveSettings.StreamingReadSettings);
_callStreamingRead = clientHelper.BuildApiCall<ReadRequest, PartialResultSet>(grpcClient.StreamingRead, effectiveSettings.StreamingReadSettings).WithGoogleRequestParam("session", request => request.Session);
Modify_ApiCall(ref _callStreamingRead);
Modify_StreamingReadApiCall(ref _callStreamingRead);
_callBeginTransaction = clientHelper.BuildApiCall<BeginTransactionRequest, Transaction>(grpcClient.BeginTransactionAsync, grpcClient.BeginTransaction, effectiveSettings.BeginTransactionSettings).WithGoogleRequestParam("session", request => request.Session);
Expand Down

0 comments on commit 9f5f0aa

Please sign in to comment.