Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings
This repository was archived by the owner on Jul 17, 2023. It is now read-only.

Commit3209237

Browse files
feat: added support for BigQuery destination and PostgreSQL source types (#198)
- [ ] Regenerate this pull request now.PiperOrigin-RevId: 469482613Source-Link:googleapis/googleapis@441339aSource-Link:https://github.com/googleapis/googleapis-gen/commit/7ac2e52b36f2f84950bb471126c543b9e88e75d2Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiN2FjMmU1MmIzNmYyZjg0OTUwYmI0NzExMjZjNTQzYjllODhlNzVkMiJ9
1 parent4c3819e commit3209237

File tree

49 files changed

+20512
-1249
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

49 files changed

+20512
-1249
lines changed

‎google-cloud-datastream/pom.xml‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,11 @@
111111
<classifier>testlib</classifier>
112112
<scope>test</scope>
113113
</dependency>
114+
<dependency>
115+
<groupId>com.google.api.grpc</groupId>
116+
<artifactId>grpc-google-iam-v1</artifactId>
117+
<scope>test</scope>
118+
</dependency>
114119
</dependencies>
115120

116121
<profiles>

‎google-cloud-datastream/src/test/java/com/google/cloud/datastream/v1/DatastreamClientTest.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,7 @@
6262
@Generated("by gapic-generator-java")
6363
publicclassDatastreamClientTest {
6464
privatestaticMockDatastreammockDatastream;
65+
privatestaticMockIAMPolicymockIAMPolicy;
6566
privatestaticMockLocationsmockLocations;
6667
privatestaticMockServiceHelpermockServiceHelper;
6768
privateLocalChannelProviderchannelProvider;
@@ -71,10 +72,11 @@ public class DatastreamClientTest {
7172
publicstaticvoidstartStaticServer() {
7273
mockDatastream =newMockDatastream();
7374
mockLocations =newMockLocations();
75+
mockIAMPolicy =newMockIAMPolicy();
7476
mockServiceHelper =
7577
newMockServiceHelper(
7678
UUID.randomUUID().toString(),
77-
Arrays.<MockGrpcService>asList(mockDatastream,mockLocations));
79+
Arrays.<MockGrpcService>asList(mockDatastream,mockLocations,mockIAMPolicy));
7880
mockServiceHelper.start();
7981
}
8082

@@ -574,6 +576,7 @@ public void discoverConnectionProfileTest() throws Exception {
574576
Assert.assertEquals(request.getHierarchyDepth(),actualRequest.getHierarchyDepth());
575577
Assert.assertEquals(request.getOracleRdbms(),actualRequest.getOracleRdbms());
576578
Assert.assertEquals(request.getMysqlRdbms(),actualRequest.getMysqlRdbms());
579+
Assert.assertEquals(request.getPostgresqlRdbms(),actualRequest.getPostgresqlRdbms());
577580
Assert.assertTrue(
578581
channelProvider.isHeaderSent(
579582
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
Lines changed: 59 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,59 @@
1+
/*
2+
* Copyright 2022 Google LLC
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
packagecom.google.cloud.datastream.v1;
18+
19+
importcom.google.api.core.BetaApi;
20+
importcom.google.api.gax.grpc.testing.MockGrpcService;
21+
importcom.google.protobuf.AbstractMessage;
22+
importio.grpc.ServerServiceDefinition;
23+
importjava.util.List;
24+
importjavax.annotation.Generated;
25+
26+
@BetaApi
27+
@Generated("by gapic-generator-java")
28+
publicclassMockIAMPolicyimplementsMockGrpcService {
29+
privatefinalMockIAMPolicyImplserviceImpl;
30+
31+
publicMockIAMPolicy() {
32+
serviceImpl =newMockIAMPolicyImpl();
33+
}
34+
35+
@Override
36+
publicList<AbstractMessage>getRequests() {
37+
returnserviceImpl.getRequests();
38+
}
39+
40+
@Override
41+
publicvoidaddResponse(AbstractMessageresponse) {
42+
serviceImpl.addResponse(response);
43+
}
44+
45+
@Override
46+
publicvoidaddException(Exceptionexception) {
47+
serviceImpl.addException(exception);
48+
}
49+
50+
@Override
51+
publicServerServiceDefinitiongetServiceDefinition() {
52+
returnserviceImpl.bindService();
53+
}
54+
55+
@Override
56+
publicvoidreset() {
57+
serviceImpl.reset();
58+
}
59+
}
Lines changed: 59 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,59 @@
1+
/*
2+
* Copyright 2022 Google LLC
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
packagecom.google.cloud.datastream.v1;
18+
19+
importcom.google.api.core.BetaApi;
20+
importcom.google.iam.v1.IAMPolicyGrpc.IAMPolicyImplBase;
21+
importcom.google.protobuf.AbstractMessage;
22+
importjava.util.ArrayList;
23+
importjava.util.LinkedList;
24+
importjava.util.List;
25+
importjava.util.Queue;
26+
importjavax.annotation.Generated;
27+
28+
@BetaApi
29+
@Generated("by gapic-generator-java")
30+
publicclassMockIAMPolicyImplextendsIAMPolicyImplBase {
31+
privateList<AbstractMessage>requests;
32+
privateQueue<Object>responses;
33+
34+
publicMockIAMPolicyImpl() {
35+
requests =newArrayList<>();
36+
responses =newLinkedList<>();
37+
}
38+
39+
publicList<AbstractMessage>getRequests() {
40+
returnrequests;
41+
}
42+
43+
publicvoidaddResponse(AbstractMessageresponse) {
44+
responses.add(response);
45+
}
46+
47+
publicvoidsetResponses(List<AbstractMessage>responses) {
48+
this.responses =newLinkedList<Object>(responses);
49+
}
50+
51+
publicvoidaddException(Exceptionexception) {
52+
responses.add(exception);
53+
}
54+
55+
publicvoidreset() {
56+
requests =newArrayList<>();
57+
responses =newLinkedList<>();
58+
}
59+
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp