Skip to content

Commit

Permalink
feat: add schema service
Browse files Browse the repository at this point in the history 
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
  • Loading branch information
@yoshi-automation @jskeet
yoshi-automation authored and jskeet committed Dec 18, 2020
1 parent 1fd137d commit d856a51
Show file tree
Hide file tree
Showing 14 changed files with 6,493 additions and 327 deletions.
4 changes: 4 additions & 0 deletions ...le.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/PublisherServiceApiClientSnippets.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,8 @@ public void CreateTopicRequestObject()
Labels = { { "", "" }, },
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
// Make the request
Topic response = publisherServiceApiClient.CreateTopic(request);
Expand All @@ -60,6 +62,8 @@ public async Task CreateTopicRequestObjectAsync()
Labels = { { "", "" }, },
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
// Make the request
Topic response = await publisherServiceApiClient.CreateTopicAsync(request);
Expand Down
716 changes: 716 additions & 0 deletions apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/SchemaServiceClientSnippets.g.cs
View file

Large diffs are not rendered by default.

32 changes: 32 additions & 0 deletions apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/PublisherServiceApiClientTest.g.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,8 @@ public void CreateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
Topic expectedResponse = new Topic
{
Expand All @@ -56,6 +58,8 @@ public void CreateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand All @@ -80,6 +84,8 @@ public void CreateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
Topic expectedResponse = new Topic
{
Expand All @@ -93,6 +99,8 @@ public void CreateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -123,6 +131,8 @@ public void CreateTopic()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -151,6 +161,8 @@ public void CreateTopic()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -181,6 +193,8 @@ public void CreateTopicResourceNames()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -209,6 +223,8 @@ public void CreateTopicResourceNames()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.CreateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -240,6 +256,8 @@ public void UpdateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.UpdateTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -269,6 +287,8 @@ public void UpdateTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.UpdateTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -461,6 +481,8 @@ public void GetTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -489,6 +511,8 @@ public void GetTopicRequestObject()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -519,6 +543,8 @@ public void GetTopic()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -547,6 +573,8 @@ public void GetTopic()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -577,6 +605,8 @@ public void GetTopicResourceNames()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopic(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -605,6 +635,8 @@ public void GetTopicResourceNames()
},
MessageStoragePolicy = new MessageStoragePolicy(),
KmsKeyName = "kms_key_name06bd122b",
SchemaSettings = new SchemaSettings(),
SatisfiesPzs = false,
};
mockGrpcClient.Setup(x => x.GetTopicAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Topic>(stt::Task.FromResult(expectedResponse), null, null, null, null));
PublisherServiceApiClient client = new PublisherServiceApiClientImpl(mockGrpcClient.Object, null);
Expand Down
Loading

0 comments on commit d856a51

Please sign in to comment.