Skip to content

Commit f90cdc2

Browse files
committed
changes
1 parent 0f14584 commit f90cdc2

File tree

3 files changed

+18
-13
lines changed

3 files changed

+18
-13
lines changed

google-cloud-spanner/src/main/java/com/google/cloud/spanner/BuiltInMetricsConstant.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,14 @@ static Map<InstrumentSelector, View> getAllViews() {
176176
BuiltInMetricsConstant.AGGREGATION_WITH_MILLIS_HISTOGRAM,
177177
InstrumentType.HISTOGRAM,
178178
"ms");
179+
defineView(
180+
views,
181+
BuiltInMetricsConstant.SPANNER_METER_NAME,
182+
BuiltInMetricsConstant.AFE_LATENCIES_NAME,
183+
BuiltInMetricsConstant.AFE_LATENCIES_NAME,
184+
BuiltInMetricsConstant.AGGREGATION_WITH_MILLIS_HISTOGRAM,
185+
InstrumentType.HISTOGRAM,
186+
"ms");
179187
defineGRPCView(views);
180188
return views.build();
181189
}

google-cloud-spanner/src/main/java/com/google/cloud/spanner/BuiltInMetricsProvider.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import static com.google.cloud.opentelemetry.detection.GCPPlatformDetector.SupportedPlatform.GOOGLE_KUBERNETES_ENGINE;
2020
import static com.google.cloud.spanner.BuiltInMetricsConstant.CLIENT_HASH_KEY;
21+
import static com.google.cloud.spanner.BuiltInMetricsConstant.CLIENT_NAME_KEY;
2122
import static com.google.cloud.spanner.BuiltInMetricsConstant.CLIENT_UID_KEY;
2223
import static com.google.cloud.spanner.BuiltInMetricsConstant.INSTANCE_CONFIG_ID_KEY;
2324
import static com.google.cloud.spanner.BuiltInMetricsConstant.INSTANCE_ID_KEY;
@@ -26,6 +27,7 @@
2627
import static com.google.cloud.spanner.BuiltInMetricsConstant.SPANNER_RESOURCE_TYPE;
2728

2829
import com.google.api.core.ApiFunction;
30+
import com.google.api.gax.core.GaxProperties;
2931
import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
3032
import com.google.auth.Credentials;
3133
import com.google.cloud.opentelemetry.detection.AttributeKeys;
@@ -75,6 +77,9 @@ OpenTelemetry getOrCreateOpenTelemetry(
7577
try {
7678
if (this.openTelemetry == null) {
7779
SdkMeterProviderBuilder sdkMeterProviderBuilder = SdkMeterProvider.builder();
80+
// BuiltInMetricsView.registerBuiltinMetrics(
81+
// SpannerCloudMonitoringExporter.create(projectId, credentials, monitoringHost),
82+
// sdkMeterProviderBuilder);
7883

7984
// Use GoogleCloudMetricExporter with service time series as the current custom exporter
8085
// does not export exemplars
@@ -153,8 +158,9 @@ Attributes createResourceAttributes(String projectId) {
153158

154159
Map<String, String> createClientAttributes() {
155160
Map<String, String> clientAttributes = new HashMap<>();
156-
String clientUid = getDefaultTaskValue();
157-
clientAttributes.put(CLIENT_UID_KEY.getKey(), clientUid);
161+
clientAttributes.put(
162+
CLIENT_NAME_KEY.getKey(), "spanner-java/" + GaxProperties.getLibraryVersion(getClass()));
163+
clientAttributes.put(CLIENT_UID_KEY.getKey(), getDefaultTaskValue());
158164
return clientAttributes;
159165
}
160166

google-cloud-spanner/src/main/java/com/google/cloud/spanner/BuiltInMetricsTracer.java

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -42,24 +42,17 @@ class BuiltInMetricsTracer extends MetricsTracer implements ApiTracer {
4242
private Float gfeLatency = null;
4343
private Float afeLatency = null;
4444

45-
private final TraceWrapper traceWrapper;
45+
private TraceWrapper traceWrapper;
4646
private long gfeHeaderMissingCount = 0;
4747
private long afeHeaderMissingCount = 0;
4848
private ISpan currentSpan;
4949

5050
BuiltInMetricsTracer(
5151
MethodName methodName,
52-
BuiltInMetricsRecorder builtInOpenTelemetryMetricsRecorder,
53-
TraceWrapper traceWrapper) {
52+
BuiltInMetricsRecorder builtInOpenTelemetryMetricsRecorder) {
5453
super(methodName, builtInOpenTelemetryMetricsRecorder);
5554
this.builtInOpenTelemetryMetricsRecorder = builtInOpenTelemetryMetricsRecorder;
5655
this.attributes.put(METHOD_ATTRIBUTE, methodName.toString());
57-
// Metrics attributes which are filtered from metrics views are sent to exemplars as
58-
// filtered_attributes.
59-
// Below testmetric attribute will be available in exemplar as we have added a attributefilter
60-
// for our metric views.
61-
this.attributes.put("testmetric", "testm");
62-
this.traceWrapper = traceWrapper;
6356
}
6457

6558
BuiltInMetricsTracer(
@@ -85,8 +78,6 @@ class BuiltInMetricsTracer extends MetricsTracer implements ApiTracer {
8578
*/
8679
@Override
8780
public void attemptSucceeded() {
88-
AttributesBuilder builder = Attributes.builder();
89-
builder.put("test1", "abc");
9081
try (IScope s = this.traceWrapper.withSpan(this.currentSpan)) {
9182
super.attemptSucceeded();
9283
attributes.put(STATUS_ATTRIBUTE, StatusCode.Code.OK.toString());

0 commit comments

Comments
 (0)