summaryrefslogtreecommitdiff
path: root/grpc/src/cpp/ext/filters/census/views.cc
diff options
context:
space:
mode:
Diffstat (limited to 'grpc/src/cpp/ext/filters/census/views.cc')
-rw-r--r--grpc/src/cpp/ext/filters/census/views.cc154
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 =