diff options
Diffstat (limited to 'grpc/src/cpp/ext/filters/census/views.cc')
-rw-r--r-- | grpc/src/cpp/ext/filters/census/views.cc | 154 |
1 files changed, 152 insertions, 2 deletions
diff --git a/grpc/src/cpp/ext/filters/census/views.cc b/grpc/src/cpp/ext/filters/census/views.cc index 2c0c5f72..926e8425 100644 --- a/grpc/src/cpp/ext/filters/census/views.cc +++ b/grpc/src/cpp/ext/filters/census/views.cc @@ -18,13 +18,13 @@ #include <grpc/support/port_platform.h> -#include "src/cpp/ext/filters/census/grpc_plugin.h" - #include "absl/time/time.h" #include "opencensus/stats/internal/aggregation_window.h" #include "opencensus/stats/internal/set_aggregation_window.h" #include "opencensus/stats/stats.h" +#include "src/cpp/ext/filters/census/grpc_plugin.h" + namespace grpc { using ::opencensus::stats::Aggregation; @@ -158,6 +158,56 @@ const ViewDescriptor& ClientReceivedMessagesPerRpcCumulative() { return descriptor; } +const ViewDescriptor& ClientRetriesPerCallCumulative() { + const static ViewDescriptor descriptor = + ViewDescriptor() + .set_name("grpc.io/client/retries_per_call/cumulative") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetriesCumulative() { + const static ViewDescriptor descriptor = + ViewDescriptor() + .set_name("grpc.io/client/retries/cumulative") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesPerCallCumulative() { + const static ViewDescriptor descriptor = + ViewDescriptor() + .set_name("grpc.io/client/transparent_retries_per_call/cumulative") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesCumulative() { + const static ViewDescriptor descriptor = + ViewDescriptor() + .set_name("grpc.io/client/transparent_retries/cumulative") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetryDelayPerCallCumulative() { + const static ViewDescriptor descriptor = + ViewDescriptor() + .set_name("grpc.io/client/retry_delay_per_call/cumulative") + .set_measure(kRpcClientRetryDelayPerCallMeasureName) + .set_aggregation(MillisDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + // server cumulative const ViewDescriptor& ServerSentBytesPerRpcCumulative() { const static ViewDescriptor descriptor = @@ -292,6 +342,56 @@ const ViewDescriptor& ClientReceivedMessagesPerRpcMinute() { return descriptor; } +const ViewDescriptor& ClientRetriesPerCallMinute() { + const static ViewDescriptor descriptor = + MinuteDescriptor() + .set_name("grpc.io/client/retries_per_call/minute") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetriesMinute() { + const static ViewDescriptor descriptor = + MinuteDescriptor() + .set_name("grpc.io/client/retries/minute") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesPerCallMinute() { + const static ViewDescriptor descriptor = + MinuteDescriptor() + .set_name("grpc.io/client/transparent_retries_per_call/minute") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesMinute() { + const static ViewDescriptor descriptor = + MinuteDescriptor() + .set_name("grpc.io/client/transparent_retries/minute") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetryDelayPerCallMinute() { + const static ViewDescriptor descriptor = + MinuteDescriptor() + .set_name("grpc.io/client/retry_delay_per_call/minute") + .set_measure(kRpcClientRetryDelayPerCallMeasureName) + .set_aggregation(MillisDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + // server minute const ViewDescriptor& ServerSentBytesPerRpcMinute() { const static ViewDescriptor descriptor = @@ -426,6 +526,56 @@ const ViewDescriptor& ClientReceivedMessagesPerRpcHour() { return descriptor; } +const ViewDescriptor& ClientRetriesPerCallHour() { + const static ViewDescriptor descriptor = + HourDescriptor() + .set_name("grpc.io/client/retries_per_call/hour") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetriesHour() { + const static ViewDescriptor descriptor = + HourDescriptor() + .set_name("grpc.io/client/retries/hour") + .set_measure(kRpcClientRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesPerCallHour() { + const static ViewDescriptor descriptor = + HourDescriptor() + .set_name("grpc.io/client/transparent_retries_per_call/hour") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(CountDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientTransparentRetriesHour() { + const static ViewDescriptor descriptor = + HourDescriptor() + .set_name("grpc.io/client/transparent_retries/hour") + .set_measure(kRpcClientTransparentRetriesPerCallMeasureName) + .set_aggregation(Aggregation::Sum()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + +const ViewDescriptor& ClientRetryDelayPerCallHour() { + const static ViewDescriptor descriptor = + HourDescriptor() + .set_name("grpc.io/client/retry_delay_per_call/hour") + .set_measure(kRpcClientRetryDelayPerCallMeasureName) + .set_aggregation(MillisDistributionAggregation()) + .add_column(ClientMethodTagKey()); + return descriptor; +} + // server hour const ViewDescriptor& ServerSentBytesPerRpcHour() { const static ViewDescriptor descriptor = |