Skip to content

Commit d856a51

Browse files
yoshi-automationjskeet
yoshi-automation
authored and
jskeet
committed
feat: add schema service
PiperOrigin-RevId: 348038736 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Dec 17 09:47:03 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: 41d8fbfec9d4bc4a8859f78185713950913b4bf3 Source-Link: googleapis/googleapis@41d8fbf
1 parent 1fd137d commit d856a51

14 files changed

+6493
-327
lines changed

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/PublisherServiceApiClientSnippets.g.cs

+4
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ public void CreateTopicRequestObject()
4040
Labels = { { "", "" }, },
4141
MessageStoragePolicy = new MessageStoragePolicy(),
4242
KmsKeyName = "",
43+
SchemaSettings = new SchemaSettings(),
44+
SatisfiesPzs = false,
4345
};
4446
// Make the request
4547
Topic response = publisherServiceApiClient.CreateTopic(request);
@@ -60,6 +62,8 @@ public async Task CreateTopicRequestObjectAsync()
6062
Labels = { { "", "" }, },
6163
MessageStoragePolicy = new MessageStoragePolicy(),
6264
KmsKeyName = "",
65+
SchemaSettings = new SchemaSettings(),
66+
SatisfiesPzs = false,
6367
};
6468
// Make the request
6569
Topic response = await publisherServiceApiClient.CreateTopicAsync(request);

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/SchemaServiceClientSnippets.g.cs

+716
Large diffs are not rendered by default.

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/PublisherServiceApiClientTest.g.cs

+32
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@ public void CreateTopicRequestObject()
4343
},
4444
MessageStoragePolicy = new MessageStoragePolicy(),
4545
KmsKeyName = "kms_key_name06bd122b",
46+
SchemaSettings = new SchemaSettings(),
47+
SatisfiesPzs = false,
4648
};
4749
Topic expectedResponse = new Topic
4850
{
@@ -56,6 +58,8 @@ public void CreateTopicRequestObject()
5658
},
5759
MessageStoragePolicy = new MessageStoragePolicy(),
5860
KmsKeyName = "kms_key_name06bd122b",
61+
SchemaSettings = new SchemaSettings(),
62+
SatisfiesPzs = false,
5963
};
6064
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
6165
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -80,6 +84,8 @@ public void CreateTopicRequestObject()
8084
},
8185
MessageStoragePolicy = new MessageStoragePolicy(),
8286
KmsKeyName = "kms_key_name06bd122b",
87+
SchemaSettings = new SchemaSettings(),
88+
SatisfiesPzs = false,
8389
};
8490
Topic expectedResponse = new Topic
8591
{
@@ -93,6 +99,8 @@ public void CreateTopicRequestObject()
9399
},
94100
MessageStoragePolicy = new MessageStoragePolicy(),
95101
KmsKeyName = "kms_key_name06bd122b",
102+
SchemaSettings = new SchemaSettings(),
103+
SatisfiesPzs = false,
96104
};
97105
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
98106
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -123,6 +131,8 @@ public void CreateTopic()
123131
},
124132
MessageStoragePolicy = new MessageStoragePolicy(),
125133
KmsKeyName = "kms_key_name06bd122b",
134+
SchemaSettings = new SchemaSettings(),
135+
SatisfiesPzs = false,
126136
};
127137
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
128138
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -151,6 +161,8 @@ public void CreateTopic()
151161
},
152162
MessageStoragePolicy = new MessageStoragePolicy(),
153163
KmsKeyName = "kms_key_name06bd122b",
164+
SchemaSettings = new SchemaSettings(),
165+
SatisfiesPzs = false,
154166
};
155167
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
156168
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -181,6 +193,8 @@ public void CreateTopicResourceNames()
181193
},
182194
MessageStoragePolicy = new MessageStoragePolicy(),
183195
KmsKeyName = "kms_key_name06bd122b",
196+
SchemaSettings = new SchemaSettings(),
197+
SatisfiesPzs = false,
184198
};
185199
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
186200
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -209,6 +223,8 @@ public void CreateTopicResourceNames()
209223
},
210224
MessageStoragePolicy = new MessageStoragePolicy(),
211225
KmsKeyName = "kms_key_name06bd122b",
226+
SchemaSettings = new SchemaSettings(),
227+
SatisfiesPzs = false,
212228
};
213229
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
214230
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -240,6 +256,8 @@ public void UpdateTopicRequestObject()
240256
},
241257
MessageStoragePolicy = new MessageStoragePolicy(),
242258
KmsKeyName = "kms_key_name06bd122b",
259+
SchemaSettings = new SchemaSettings(),
260+
SatisfiesPzs = false,
243261
};
244262
mockGrpcClient.Setup(x => x.UpdateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
245263
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -269,6 +287,8 @@ public void UpdateTopicRequestObject()
269287
},
270288
MessageStoragePolicy = new MessageStoragePolicy(),
271289
KmsKeyName = "kms_key_name06bd122b",
290+
SchemaSettings = new SchemaSettings(),
291+
SatisfiesPzs = false,
272292
};
273293
mockGrpcClient.Setup(x => x.UpdateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
274294
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -461,6 +481,8 @@ public void GetTopicRequestObject()
461481
},
462482
MessageStoragePolicy = new MessageStoragePolicy(),
463483
KmsKeyName = "kms_key_name06bd122b",
484+
SchemaSettings = new SchemaSettings(),
485+
SatisfiesPzs = false,
464486
};
465487
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
466488
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -489,6 +511,8 @@ public void GetTopicRequestObject()
489511
},
490512
MessageStoragePolicy = new MessageStoragePolicy(),
491513
KmsKeyName = "kms_key_name06bd122b",
514+
SchemaSettings = new SchemaSettings(),
515+
SatisfiesPzs = false,
492516
};
493517
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
494518
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -519,6 +543,8 @@ public void GetTopic()
519543
},
520544
MessageStoragePolicy = new MessageStoragePolicy(),
521545
KmsKeyName = "kms_key_name06bd122b",
546+
SchemaSettings = new SchemaSettings(),
547+
SatisfiesPzs = false,
522548
};
523549
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
524550
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -547,6 +573,8 @@ public void GetTopic()
547573
},
548574
MessageStoragePolicy = new MessageStoragePolicy(),
549575
KmsKeyName = "kms_key_name06bd122b",
576+
SchemaSettings = new SchemaSettings(),
577+
SatisfiesPzs = false,
550578
};
551579
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
552580
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -577,6 +605,8 @@ public void GetTopicResourceNames()
577605
},
578606
MessageStoragePolicy = new MessageStoragePolicy(),
579607
KmsKeyName = "kms_key_name06bd122b",
608+
SchemaSettings = new SchemaSettings(),
609+
SatisfiesPzs = false,
580610
};
581611
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
582612
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
@@ -605,6 +635,8 @@ public void GetTopicResourceNames()
605635
},
606636
MessageStoragePolicy = new MessageStoragePolicy(),
607637
KmsKeyName = "kms_key_name06bd122b",
638+
SchemaSettings = new SchemaSettings(),
639+
SatisfiesPzs = false,
608640
};
609641
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
610642
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);

0 commit comments

Comments
 (0)