Skip to content
This repository was archived by the owner on Apr 7, 2026. It is now read-only.

Added Resource Based Routing Support #40

Closed
mbril wants to merge 10 commits into from
Closed

Added Resource Based Routing Support #40

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
e640b13
Initial import of Resource Based Routing Impl from old repo
mbril Jan 22, 2020
44ee822
reorder
mbril Jan 22, 2020
aee6992
Applied formatting
mbril Jan 22, 2020
87d76fd
Merge branch 'master' of github.com:googleapis/java-spanner into mb.a…
mbril Jan 22, 2020
cf0d792
Moved InstanceConfigRpcCache to v1 package per comment
mbril Jan 22, 2020
db780c9
Added feature flag
mbril Jan 22, 2020
cee129c
Merge branch 'master' of github.com:googleapis/java-spanner into mb.a…
mbril Jan 29, 2020
37d1424
Adapted clirr
mbril Jan 29, 2020
0472136
Merge branch 'master' of github.com:googleapis/java-spanner into mb.a…
mbril Feb 1, 2020
8041e08
Addressed comments per spec
mbril Feb 3, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Moved InstanceConfigRpcCache to v1 package per comment 
Changed to package private
  • Loading branch information
@mbril
mbril committed Jan 22, 2020
commit cf0d792e95a14c3422d3e68a868564dbb0cbfa55
1 change: 0 additions & 1 deletion google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@
import com.google.api.gax.rpc.WatchdogProvider;
import com.google.api.pathtemplate.PathTemplate;
import com.google.cloud.grpc.GrpcTransportOptions;
import com.google.cloud.spanner.InstanceConfigRpcCache;
import com.google.cloud.spanner.SpannerException;
import com.google.cloud.spanner.SpannerExceptionFactory;
import com.google.cloud.spanner.SpannerOptions;
Expand Down
18 changes: 10 additions & 8 deletions ...cloud/spanner/InstanceConfigRpcCache.java → ...panner/spi/v1/InstanceConfigRpcCache.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,12 @@
* limitations under the License.
*/

package com.google.cloud.spanner;
package com.google.cloud.spanner.spi.v1;

import com.google.cloud.spanner.spi.v1.GapicSpannerRpc;
import com.google.cloud.spanner.spi.v1.SpannerRpc;
import com.google.cloud.spanner.ErrorCode;
import com.google.cloud.spanner.SpannerException;
import com.google.cloud.spanner.SpannerExceptionFactory;
import com.google.cloud.spanner.SpannerOptions;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
Expand All @@ -31,14 +33,14 @@
import java.util.logging.Level;
import java.util.logging.Logger;

public class InstanceConfigRpcCache {
class InstanceConfigRpcCache {

private final LoadingCache<InstanceName, SpannerRpc> cache;

private Logger logger = Logger.getLogger(InstanceConfigRpcCache.class.getName());
private final GapicSpannerRpc projectClient;

public InstanceConfigRpcCache(final GapicSpannerRpc projectClient) {
InstanceConfigRpcCache(final GapicSpannerRpc projectClient) {
this.projectClient = projectClient;
cache =
CacheBuilder.newBuilder()
Expand Down Expand Up @@ -85,13 +87,13 @@ public SpannerRpc load(InstanceName instanceName) throws SpannerException {
});
}

public SpannerRpc get(SessionName sessionName) {
SpannerRpc get(SessionName sessionName) {
InstanceName instanceName =
InstanceName.of(sessionName.getProject(), sessionName.getInstance());
return get(instanceName);
}

public SpannerRpc get(DatabaseName databaseName) {
SpannerRpc get(DatabaseName databaseName) {
InstanceName instanceName =
InstanceName.of(databaseName.getProject(), databaseName.getInstance());
return get(instanceName);
Expand All @@ -111,7 +113,7 @@ private SpannerRpc get(InstanceName instanceName) {
}
}

public void invalidateAll() {
void invalidateAll() {
for (SpannerRpc rpc : cache.asMap().values()) {
if (rpc == this.projectClient) continue;
rpc.shutdown();
Expand Down