2727import  io .opentelemetry .sdk .metrics .InstrumentType ;
2828import  io .opentelemetry .sdk .metrics .View ;
2929import  java .util .Collection ;
30+ import  java .util .List ;
3031import  java .util .Map ;
3132import  java .util .Set ;
3233import  java .util .stream .Collectors ;
@@ -39,6 +40,9 @@ public class BuiltInMetricsConstant {
3940  static  final  String  SPANNER_METER_NAME  = "spanner-java" ;
4041  static  final  String  GRPC_METER_NAME  = "grpc-java" ;
4142  static  final  String  GFE_LATENCIES_NAME  = "gfe_latencies" ;
43+   static  final  String  AFE_LATENCIES_NAME  = "afe_latencies" ;
44+   static  final  String  GFE_CONNECTIVITY_ERROR_NAME  = "gfe_connectivity_error_count" ;
45+   static  final  String  AFE_CONNECTIVITY_ERROR_NAME  = "afe_connectivity_error_count" ;
4246  static  final  String  OPERATION_LATENCIES_NAME  = "operation_latencies" ;
4347  static  final  String  ATTEMPT_LATENCIES_NAME  = "attempt_latencies" ;
4448  static  final  String  OPERATION_LATENCY_NAME  = "operation_latency" ;
@@ -52,7 +56,10 @@ public class BuiltInMetricsConstant {
5256              ATTEMPT_LATENCIES_NAME ,
5357              OPERATION_COUNT_NAME ,
5458              ATTEMPT_COUNT_NAME ,
55-               GFE_LATENCIES_NAME )
59+               GFE_LATENCIES_NAME ,
60+               AFE_LATENCIES_NAME ,
61+               GFE_CONNECTIVITY_ERROR_NAME ,
62+               AFE_CONNECTIVITY_ERROR_NAME )
5663          .stream ()
5764          .map (m  -> METER_NAME  + '/'  + m )
5865          .collect (Collectors .toSet ());
@@ -110,14 +117,14 @@ public class BuiltInMetricsConstant {
110117  static  final  Set <String > GRPC_LB_RLS_ATTRIBUTES  =
111118      ImmutableSet .of ("grpc.lb.rls.data_plane_target" , "grpc.lb.pick_result" );
112119
120+   static  List <Double > BUCKET_BOUNDARIES  =
121+       ImmutableList .of (
122+           0.0 , 0.5 , 1.0 , 2.0 , 3.0 , 4.0 , 5.0 , 6.0 , 7.0 , 8.0 , 9.0 , 10.0 , 11.0 , 12.0 , 13.0 , 14.0 , 15.0 ,
123+           16.0 , 17.0 , 18.0 , 19.0 , 20.0 , 25.0 , 30.0 , 40.0 , 50.0 , 65.0 , 80.0 , 100.0 , 130.0 , 160.0 ,
124+           200.0 , 250.0 , 300.0 , 400.0 , 500.0 , 650.0 , 800.0 , 1000.0 , 2000.0 , 5000.0 , 10000.0 , 20000.0 ,
125+           50000.0 , 100000.0 , 200000.0 , 400000.0 , 800000.0 , 1600000.0 , 3200000.0 );
113126  static  Aggregation  AGGREGATION_WITH_MILLIS_HISTOGRAM  =
114-       Aggregation .explicitBucketHistogram (
115-           ImmutableList .of (
116-               0.0 , 0.5 , 1.0 , 2.0 , 3.0 , 4.0 , 5.0 , 6.0 , 7.0 , 8.0 , 9.0 , 10.0 , 11.0 , 12.0 , 13.0 , 14.0 ,
117-               15.0 , 16.0 , 17.0 , 18.0 , 19.0 , 20.0 , 25.0 , 30.0 , 40.0 , 50.0 , 65.0 , 80.0 , 100.0 , 130.0 ,
118-               160.0 , 200.0 , 250.0 , 300.0 , 400.0 , 500.0 , 650.0 , 800.0 , 1000.0 , 2000.0 , 5000.0 ,
119-               10000.0 , 20000.0 , 50000.0 , 100000.0 , 200000.0 , 400000.0 , 800000.0 , 1600000.0 ,
120-               3200000.0 ));
127+       Aggregation .explicitBucketHistogram (BUCKET_BOUNDARIES );
121128
122129  static  final  Collection <String > GRPC_METRICS_ENABLED_BY_DEFAULT  =
123130      ImmutableList .of (
@@ -145,14 +152,6 @@ static Map<InstrumentSelector, View> getAllViews() {
145152        BuiltInMetricsConstant .AGGREGATION_WITH_MILLIS_HISTOGRAM ,
146153        InstrumentType .HISTOGRAM ,
147154        "ms" );
148-     defineView (
149-         views ,
150-         BuiltInMetricsConstant .SPANNER_METER_NAME ,
151-         BuiltInMetricsConstant .GFE_LATENCIES_NAME ,
152-         BuiltInMetricsConstant .GFE_LATENCIES_NAME ,
153-         BuiltInMetricsConstant .AGGREGATION_WITH_MILLIS_HISTOGRAM ,
154-         InstrumentType .HISTOGRAM ,
155-         "ms" );
156155    defineView (
157156        views ,
158157        BuiltInMetricsConstant .GAX_METER_NAME ,
0 commit comments