Searched refs:RpcMeasureConstants (Results 1 – 8 of 8) sorted by relevance
31 assertThat(RpcMeasureConstants.RPC_STATUS).isNotNull(); in testConstants()32 assertThat(RpcMeasureConstants.RPC_METHOD).isNotNull(); in testConstants()33 assertThat(RpcMeasureConstants.GRPC_CLIENT_METHOD).isNotNull(); in testConstants()34 assertThat(RpcMeasureConstants.GRPC_SERVER_METHOD).isNotNull(); in testConstants()35 assertThat(RpcMeasureConstants.GRPC_CLIENT_STATUS).isNotNull(); in testConstants()36 assertThat(RpcMeasureConstants.GRPC_SERVER_STATUS).isNotNull(); in testConstants()39 assertThat(RpcMeasureConstants.RPC_CLIENT_ERROR_COUNT).isNotNull(); in testConstants()40 assertThat(RpcMeasureConstants.RPC_CLIENT_ROUNDTRIP_LATENCY).isNotNull(); in testConstants()41 assertThat(RpcMeasureConstants.RPC_CLIENT_REQUEST_BYTES).isNotNull(); in testConstants()42 assertThat(RpcMeasureConstants.RPC_CLIENT_RESPONSE_BYTES).isNotNull(); in testConstants()[all …]
20 import io.opencensus.contrib.grpc.metrics.RpcMeasureConstants;61 .put(RpcMeasureConstants.RPC_CLIENT_STARTED_COUNT, 1) in recordExampleData()62 .put(RpcMeasureConstants.RPC_CLIENT_FINISHED_COUNT, 1) in recordExampleData()63 .put(RpcMeasureConstants.RPC_CLIENT_ROUNDTRIP_LATENCY, 1.0) in recordExampleData()64 .put(RpcMeasureConstants.RPC_CLIENT_REQUEST_COUNT, 1) in recordExampleData()65 .put(RpcMeasureConstants.RPC_CLIENT_RESPONSE_COUNT, 1) in recordExampleData()66 .put(RpcMeasureConstants.RPC_CLIENT_REQUEST_BYTES, 1e5) in recordExampleData()67 .put(RpcMeasureConstants.RPC_CLIENT_RESPONSE_BYTES, 1e5) in recordExampleData()68 .put(RpcMeasureConstants.RPC_CLIENT_UNCOMPRESSED_REQUEST_BYTES, 1e5) in recordExampleData()69 .put(RpcMeasureConstants.RPC_CLIENT_UNCOMPRESSED_RESPONSE_BYTES, 1e5) in recordExampleData()[all …]
66 import io.opencensus.contrib.grpc.metrics.RpcMeasureConstants;282 TagValue methodTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in testClientInterceptors()316 methodTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in testClientInterceptors()318 TagValue statusTag = record.tags.get(RpcMeasureConstants.RPC_STATUS); in testClientInterceptors()368 TagValue methodTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in subtestClientBasicStatsDefaultContext()370 assertEquals(1, record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_CLIENT_STARTED_COUNT)); in subtestClientBasicStatsDefaultContext()402 TagValue methodTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in subtestClientBasicStatsDefaultContext()404 TagValue statusTag = record.tags.get(RpcMeasureConstants.RPC_STATUS); in subtestClientBasicStatsDefaultContext()406 assertEquals(1, record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_CLIENT_FINISHED_COUNT)); in subtestClientBasicStatsDefaultContext()407 assertNull(record.getMetric(RpcMeasureConstants.RPC_CLIENT_ERROR_COUNT)); in subtestClientBasicStatsDefaultContext()[all …]
19 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_METHOD;20 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_RECEIVED_BYTES_PER…21 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_RECEIVED_MESSAGES_…22 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_ROUNDTRIP_LATENCY;23 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_SENT_BYTES_PER_RPC;24 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_SENT_MESSAGES_PER_…25 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_SERVER_LATENCY;26 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_STARTED_RPCS;27 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_CLIENT_STATUS;28 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.GRPC_SERVER_METHOD;[all …]
29 public final class RpcMeasureConstants { class494 private RpcMeasureConstants() {} in RpcMeasureConstants() method in RpcMeasureConstants
39 import io.opencensus.contrib.grpc.metrics.RpcMeasureConstants;330 .put(RpcMeasureConstants.RPC_METHOD, TagValue.create(fullMethodName)).build(); in ClientCallTracer()334 module.statsRecorder.newMeasureMap().put(RpcMeasureConstants.RPC_CLIENT_STARTED_COUNT, 1) in ClientCallTracer()390 .put(RpcMeasureConstants.RPC_CLIENT_FINISHED_COUNT, 1) in callEnded()392 .put(RpcMeasureConstants.RPC_CLIENT_ROUNDTRIP_LATENCY, roundtripNanos / NANOS_PER_MILLI) in callEnded()393 .put(RpcMeasureConstants.RPC_CLIENT_REQUEST_COUNT, tracer.outboundMessageCount) in callEnded()394 .put(RpcMeasureConstants.RPC_CLIENT_RESPONSE_COUNT, tracer.inboundMessageCount) in callEnded()395 .put(RpcMeasureConstants.RPC_CLIENT_REQUEST_BYTES, tracer.outboundWireSize) in callEnded()396 .put(RpcMeasureConstants.RPC_CLIENT_RESPONSE_BYTES, tracer.inboundWireSize) in callEnded()398 RpcMeasureConstants.RPC_CLIENT_UNCOMPRESSED_REQUEST_BYTES, in callEnded()[all …]
20 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.RPC_CLIENT_ERROR_COUNT;21 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.RPC_CLIENT_REQUEST_BYTES;22 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.RPC_CLIENT_ROUNDTRIP_LATENCY;23 import static io.opencensus.contrib.grpc.metrics.RpcMeasureConstants.RPC_SERVER_SERVER_LATENCY;
97 import io.opencensus.contrib.grpc.metrics.RpcMeasureConstants;1957 TagValue methodNameTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in checkStartTags()1965 TagValue methodNameTag = record.tags.get(RpcMeasureConstants.RPC_METHOD); in checkEndTags()1968 TagValue statusTag = record.tags.get(RpcMeasureConstants.RPC_STATUS); in checkEndTags()2022 record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_SERVER_REQUEST_COUNT)); in checkCensus()2025 record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_SERVER_RESPONSE_COUNT)); in checkCensus()2028 record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_SERVER_UNCOMPRESSED_REQUEST_BYTES)); in checkCensus()2031 record.getMetricAsLongOrFail(RpcMeasureConstants.RPC_SERVER_UNCOMPRESSED_RESPONSE_BYTES)); in checkCensus()2032 assertNotNull(record.getMetric(RpcMeasureConstants.RPC_SERVER_SERVER_LATENCY)); in checkCensus()2035 assertNotNull(record.getMetric(RpcMeasureConstants.RPC_SERVER_REQUEST_BYTES)); in checkCensus()[all …]