Skip to content

Commit d74bfb6

Browse files
igorbernstein2igorbernstein2
authored
---
yaml --- r: 11663 b: refs/heads/autosynth-pubsub c: c6e2d63 h: refs/heads/master i: 11661: 61d3b56 11659: 2068b22 11655: eb0c089 11647: fb83105
1 parent 2a39bca commit d74bfb6

14 files changed

Lines changed: 1421 additions & 1 deletion

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ refs/heads/autosynth-compute: fa508ebab5b6a1db14949441c8de868cefbcf1a6
116116
refs/heads/autosynth-container: d0346e84b1f26e3dc10444450a998f357a43bcef
117117
refs/heads/autosynth-dataproc: c0f21dd811166848a60f810565a5614bb9c7f47e
118118
refs/heads/autosynth-monitoring: 28bf7ca67c0aab4815884e5d6253aaa8aa3baa1c
119-
refs/heads/autosynth-pubsub: 9fdb16331f5a0aa62a45ccae8462d78a750e28f2
119+
refs/heads/autosynth-pubsub: c6e2d631ef81727b744c39ef42bb30d574dda69b
120120
refs/heads/autosynth-video-intelligence: 06fb1841ae847f4ef79a62ba995efbabc213edf8
121121
refs/heads/autosynth-vision: 6bece1ee6c1c41d5822c72bf0d6a82484166b402
122122
refs/heads/spanner: 54a5e197bfe0a004e13c190427f46c3413ab572d

‎branches/autosynth-pubsub/google-cloud-bom/pom.xml‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,6 +254,11 @@
254254
<artifactId>grpc-google-cloud-bigtable-admin-v2</artifactId>
255255
<version>0.35.1-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-bigtable-admin-v2:current} -->
256256
</dependency>
257+
<dependency>
258+
<groupId>com.google.cloud</groupId>
259+
<artifactId>google-cloud-bigtable-emulator</artifactId>
260+
<version>0.70.1-alpha-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigtable-emulator:current} -->
261+
</dependency>
257262
<dependency>
258263
<groupId>com.google.cloud</groupId>
259264
<artifactId>google-cloud-bigquery</artifactId>

‎branches/autosynth-pubsub/google-cloud-testing/google-cloud-bigtable-emulator/README.md‎

Lines changed: 182 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,182 @@
1+
# Google Cloud Java Emulator for Bigtable
2+
3+
A Java wrapper for the [Cloud Bigtable][cloud-bigtable] emulator. This
4+
wrapper bundles the native Bigtable emulator and exposes a simple Java
5+
interface to ease writing tests. Please note that this wrapper is under
6+
heavy development and APIs may change in the future.
7+
8+
[![Kokoro CI](http://storage.googleapis.com/cloud-devrel-public/java/badges/google-cloud-java/master.svg)](http://storage.googleapis.com/cloud-devrel-public/java/badges/google-cloud-java/master.html)
9+
[![Maven](https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-bigtable-emulator.svg)](https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-bigtable-emulator.svg)
10+
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/google-cloud-java)
11+
12+
## Quickstart
13+
14+
[//]: # ({x-version-update-start:google-cloud-bom:released})
15+
If you are using Maven, add this to your pom.xml file
16+
```xml
17+
<dependencyManagement>
18+
<dependencies>
19+
<dependency>
20+
<groupId>com.google.cloud</groupId>
21+
<artifactId>google-cloud-bom</artifactId>
22+
<version>0.70.0-alpha</version>
23+
<type>pom</type>
24+
<scope>import</scope>
25+
</dependency>
26+
</dependencies>
27+
</dependencyManagement>
28+
29+
<dependencies>
30+
<dependency>
31+
<groupId>com.google.cloud</groupId>
32+
<artifactId>google-cloud-bigtable</artifactId>
33+
</dependency>
34+
35+
<dependency>
36+
<groupId>com.google.cloud</groupId>
37+
<artifactId>google-cloud-bigtable-admin</artifactId>
38+
</dependency>
39+
40+
<dependency>
41+
<groupId>com.google.cloud</groupId>
42+
<artifactId>google-cloud-bigtable-emulator</artifactId>
43+
<scope>test</scope>
44+
</dependency>
45+
46+
<dependency>
47+
<groupId>junit</groupId>
48+
<artifactId>junit</artifactId>
49+
<version>4.12</version>
50+
<scope>test</scope>
51+
</dependency>
52+
</dependencies>```
53+
54+
If you are using Gradle, add this to your dependencies
55+
```Groovy
56+
compile 'com.google.cloud:google-cloud-bigtable:0.70.0-alpha'
57+
compile 'com.google.cloud:google-cloud-bigtable-admin:0.70.0-alpha'
58+
testCompile 'com.google.cloud:google-cloud-bigtable-emulator:0.70.0-alpha'
59+
testCompile 'junit:junit:4.12'
60+
```
61+
If you are using SBT, add this to your dependencies
62+
```Scala
63+
libraryDependencies += "com.google.cloud" % "google-cloud-bigtable" % "0.70.0-alpha"
64+
libraryDependencies += "com.google.cloud" % "google-cloud-bigtable-admin" % "0.70.0-alpha"
65+
libraryDependencies += "com.google.cloud" % "google-cloud-bigtable-emulator" % "0.70.0-alpha" % Test
66+
libraryDependencies += "junit" % "junit" % "4.12" % Test
67+
```
68+
[//]: # ({x-version-update-end})
69+
70+
## Getting Started
71+
72+
Here is a code snippet showing a simple JUnit test. Add the following imports
73+
at the top of your file:
74+
75+
```java
76+
import com.google.api.core.ApiFuture;
77+
import com.google.api.gax.core.NoCredentialsProvider;
78+
import com.google.api.gax.grpc.GrpcTransportChannel;
79+
import com.google.api.gax.rpc.FixedTransportChannelProvider;
80+
import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient;
81+
import com.google.cloud.bigtable.admin.v2.BigtableTableAdminSettings;
82+
import com.google.cloud.bigtable.admin.v2.models.CreateTableRequest;
83+
import com.google.cloud.bigtable.data.v2.BigtableDataClient;
84+
import com.google.cloud.bigtable.data.v2.BigtableDataSettings;
85+
import com.google.cloud.bigtable.data.v2.models.Row;
86+
import com.google.cloud.bigtable.data.v2.models.RowMutation;
87+
import com.google.cloud.bigtable.emulator.v2.BigtableEmulatorRule;
88+
import java.io.IOException;
89+
import java.util.concurrent.ExecutionException;
90+
import org.junit.Assert;
91+
import org.junit.Before;
92+
import org.junit.Rule;
93+
import org.junit.Test;
94+
import org.junit.runner.RunWith;
95+
import org.junit.runners.JUnit4;
96+
```
97+
98+
Then, to make a query to Bigtable, use the following code:
99+
```java
100+
@RunWith(JUnit4.class)
101+
public class ExampleTest {
102+
// Initialize the emulator Rule
103+
@Rule
104+
public final BigtableEmulatorRule bigtableEmulator = BigtableEmulatorRule.create();
105+
106+
// Clients that will be connected to the emulator
107+
private BigtableTableAdminClient tableAdminClient;
108+
private BigtableDataClient dataClient;
109+
110+
@Before
111+
public void setUp() throws IOException {
112+
// Initialize the clients to connect to the emulator
113+
BigtableTableAdminSettings.Builder tableAdminSettings = BigtableTableAdminSettings.newBuilder()
114+
.setInstanceName(com.google.bigtable.admin.v2.InstanceName.of("fake-project", "fake-instance"));
115+
tableAdminSettings.stubSettings()
116+
.setCredentialsProvider(NoCredentialsProvider.create())
117+
.setTransportChannelProvider(
118+
FixedTransportChannelProvider.create(
119+
GrpcTransportChannel.create(bigtableEmulator.getAdminChannel())
120+
)
121+
);
122+
tableAdminClient = BigtableTableAdminClient.create(tableAdminSettings.build());
123+
124+
BigtableDataSettings.Builder dataSettings = BigtableDataSettings.newBuilder()
125+
.setInstanceName(com.google.cloud.bigtable.data.v2.models.InstanceName.of("fake-project", "fake-instance"))
126+
.setCredentialsProvider(NoCredentialsProvider.create())
127+
.setTransportChannelProvider(
128+
FixedTransportChannelProvider.create(
129+
GrpcTransportChannel.create(bigtableEmulator.getDataChannel())
130+
)
131+
);
132+
dataClient = BigtableDataClient.create(dataSettings.build());
133+
134+
// Create a test table that can be used in tests
135+
tableAdminClient.createTable(
136+
CreateTableRequest.of("fake-table")
137+
.addFamily("cf")
138+
);
139+
}
140+
141+
@Test
142+
public void testWriteRead() throws ExecutionException, InterruptedException {
143+
ApiFuture<Void> mutateFuture = dataClient.mutateRowAsync(
144+
RowMutation.create("fake-table", "fake-key")
145+
.setCell("cf", "col", "value")
146+
);
147+
148+
mutateFuture.get();
149+
150+
ApiFuture<Row> rowFuture = dataClient.readRowAsync("fake-table", "fake-key");
151+
152+
Assert.assertEquals("value", rowFuture.get().getCells().get(0).getValue().toStringUtf8());
153+
}
154+
}
155+
```
156+
157+
## Java Versions
158+
159+
Java 7 or above is required for using this emulator.
160+
161+
## Versioning
162+
163+
This library follows [Semantic Versioning](http://semver.org/).
164+
165+
It is currently in major version zero (`0.y.z`), which means that anything may
166+
change at any time and the public API should not be considered stable.
167+
168+
## Contributing
169+
170+
Contributions to this library are always welcome and highly encouraged.
171+
172+
See [CONTRIBUTING] for more information on how to get started and [DEVELOPING] for a layout of the
173+
codebase.
174+
175+
## License
176+
177+
Apache 2.0 - See [LICENSE] for more information.
178+
179+
[CONTRIBUTING]:https://github.com/googleapis/google-cloud-java/blob/master/CONTRIBUTING.md
180+
[LICENSE]: https://github.com/googleapis/google-cloud-java/blob/master/LICENSE
181+
[cloud-bigtable]: https://cloud.google.com/bigtable/
182+

‎branches/autosynth-pubsub/google-cloud-testing/google-cloud-bigtable-emulator/pom.xml‎

Lines changed: 92 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,92 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<artifactId>google-cloud-testing</artifactId>
7+
<groupId>com.google.cloud</groupId>
8+
<version>0.70.1-alpha-SNAPSHOT</version><!-- {x-version-update:google-cloud-testing:current} -->
9+
</parent>
10+
<modelVersion>4.0.0</modelVersion>
11+
12+
<artifactId>google-cloud-bigtable-emulator</artifactId>
13+
<version>0.70.1-alpha-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigtable-emulator:current} -->
14+
15+
<build>
16+
<plugins>
17+
<plugin>
18+
<groupId>com.google.cloud</groupId>
19+
<artifactId>google-cloud-gcloud-maven-plugin</artifactId>
20+
<version>0.70.1-alpha-SNAPSHOT</version><!-- {x-version-update:google-cloud-gcloud-maven-plugin:current} -->
21+
22+
<executions>
23+
<execution>
24+
<id>gen-sources</id>
25+
<phase>generate-resources</phase>
26+
<goals>
27+
<goal>download</goal>
28+
</goals>
29+
<configuration>
30+
<componentNames>
31+
<componentName>bigtable-darwin-x86</componentName>
32+
<componentName>bigtable-darwin-x86_64</componentName>
33+
<componentName>bigtable-linux-x86</componentName>
34+
<componentName>bigtable-linux-x86_64</componentName>
35+
<componentName>bigtable-windows-x86</componentName>
36+
<componentName>bigtable-windows-x86_64</componentName>
37+
</componentNames>
38+
</configuration>
39+
</execution>
40+
</executions>
41+
</plugin>
42+
</plugins>
43+
</build>
44+
45+
<dependencies>
46+
<!-- grpc deps are provided by the client -->
47+
<dependency>
48+
<groupId>io.grpc</groupId>
49+
<artifactId>grpc-core</artifactId>
50+
<version>1.13.1</version>
51+
<scope>provided</scope>
52+
</dependency>
53+
54+
<dependency>
55+
<groupId>io.grpc</groupId>
56+
<artifactId>grpc-netty-shaded</artifactId>
57+
<version>1.13.1</version>
58+
<scope>provided</scope>
59+
</dependency>
60+
61+
<dependency>
62+
<groupId>com.google.api</groupId>
63+
<artifactId>api-common</artifactId>
64+
</dependency>
65+
66+
<!-- junit is optional because the emulator can be used w/o the junit Rule. -->
67+
<dependency>
68+
<groupId>junit</groupId>
69+
<artifactId>junit</artifactId>
70+
<scope>compile</scope>
71+
<optional>true</optional>
72+
</dependency>
73+
74+
<dependency>
75+
<groupId>com.google.truth</groupId>
76+
<artifactId>truth</artifactId>
77+
<scope>test</scope>
78+
</dependency>
79+
80+
<dependency>
81+
<groupId>com.google.api.grpc</groupId>
82+
<artifactId>grpc-google-cloud-bigtable-v2</artifactId>
83+
<scope>test</scope>
84+
</dependency>
85+
86+
<dependency>
87+
<groupId>com.google.api.grpc</groupId>
88+
<artifactId>grpc-google-cloud-bigtable-admin-v2</artifactId>
89+
<scope>test</scope>
90+
</dependency>
91+
</dependencies>
92+
</project>

‎branches/autosynth-pubsub/google-cloud-testing/google-cloud-bigtable-emulator/src/main/java/com/google/cloud/bigtable/emulator/v2/BigtableEmulatorRule.java‎

Lines changed: 89 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,89 @@
1+
/*
2+
* Copyright 2018 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+
package com.google.cloud.bigtable.emulator.v2;
17+
18+
import com.google.api.core.BetaApi;
19+
import io.grpc.ManagedChannel;
20+
import org.junit.rules.ExternalResource;
21+
22+
/**
23+
* The BigtableEmulatorRule manages the lifecycle of the Bigtable {@link Emulator}. Before the
24+
* start of a test, the emulator will be started on a random port and will be shutdown after the
25+
* test finishes.
26+
*
27+
* <p>Example usage:
28+
*
29+
* <code>{@code
30+
* {@literal @RunWith(JUnit4.class)}
31+
* public class MyTest {
32+
* {@literal @Rule}
33+
* public final BigtableEmulatorRule bigtableEmulator = BigtableEmulatorRule.create();
34+
*
35+
* {@literal @Test}
36+
* public void testUsingEmulator() {
37+
* ManagedChannel adminChannel = bigtableEmulator.getAdminChannel();
38+
* // Do something with channel
39+
* }
40+
* }
41+
* }</code>
42+
*/
43+
@BetaApi("Surface for Bigtable emulator is not yet stable")
44+
public class BigtableEmulatorRule extends ExternalResource {
45+
private Emulator emulator;
46+
47+
public static BigtableEmulatorRule create() {
48+
return new BigtableEmulatorRule();
49+
}
50+
51+
private BigtableEmulatorRule() { }
52+
53+
/** Initializes the Bigtable emulator before a test runs. */
54+
@Override
55+
protected void before() throws Throwable {
56+
emulator = Emulator.createBundled();
57+
emulator.start();
58+
}
59+
60+
/** Stops the Bigtable emulator after a test finishes. */
61+
@Override
62+
protected void after() {
63+
emulator.stop();
64+
emulator = null;
65+
}
66+
67+
/**
68+
* Gets a {@link ManagedChannel} connected to the Emulator. The channel is configured for data
69+
* operations.
70+
*/
71+
public ManagedChannel getDataChannel() {
72+
return emulator.getDataChannel();
73+
}
74+
75+
/**
76+
* Gets a {@link ManagedChannel} connected to the Emulator. This channel should be used for admin
77+
* operations.
78+
*/
79+
public ManagedChannel getAdminChannel() {
80+
return emulator.getAdminChannel();
81+
}
82+
83+
/**
84+
* Gets the port of the emulator, allowing the caller to create their own {@link ManagedChannel}.
85+
*/
86+
public int getPort() {
87+
return emulator.getPort();
88+
}
89+
}

0 commit comments

Comments
 (0)