Add message prefix

gcp/observability/opencensus.go

@@ -39,13 +39,13 @@ var (
 		opencensus.ClientStartedRPCsView,
 		opencensus.ClientCompletedRPCsView,
 		opencensus.ClientRoundtripLatencyView,
-		opencensus.ClientSentCompressedBytesPerRPCView,
-		opencensus.ClientReceivedCompressedBytesPerRPCView,
+		opencensus.ClientSentCompressedMessageBytesPerRPCView,
+		opencensus.ClientReceivedCompressedMessageBytesPerRPCView,
 		opencensus.ClientAPILatencyView,
 		opencensus.ServerStartedRPCsView,
 		opencensus.ServerCompletedRPCsView,
-		opencensus.ServerSentCompressedBytesPerRPCView,
-		opencensus.ServerReceivedCompressedBytesPerRPCView,
+		opencensus.ServerSentCompressedMessageBytesPerRPCView,
+		opencensus.ServerReceivedCompressedMessageBytesPerRPCView,
 		opencensus.ServerLatencyView,
 	}
 )

stats/opencensus/client_metrics.go

@@ -72,12 +72,12 @@ var (
 		TagKeys:     []tag.Key{keyClientMethod},
 		Aggregation: bytesDistribution,
 	}
-	// ClientSentCompressedBytesPerRPCView is the distribution of compressed
-	// sent bytes per RPC, keyed on method.
-	ClientSentCompressedBytesPerRPCView = &view.View{
+	// ClientSentCompressedMessageBytesPerRPCView is the distribution of
+	// compressed sent message bytes per RPC, keyed on method.
+	ClientSentCompressedMessageBytesPerRPCView = &view.View{
 		Measure:     clientSentCompressedBytesPerRPC,
-		Name:        "grpc.io/client/sent_compressed_bytes_per_rpc",
-		Description: "Distribution of sent compressed bytes per RPC, by method.",
+		Name:        "grpc.io/client/sent_compressed_message_bytes_per_rpc",
+		Description: "Distribution of sent compressed message bytes per RPC, by method.",
 		TagKeys:     []tag.Key{keyClientMethod},
 		Aggregation: bytesDistribution,
 	}
@@ -90,12 +90,12 @@ var (
 		TagKeys:     []tag.Key{keyClientMethod},
 		Aggregation: bytesDistribution,
 	}
-	// ClientReceivedCompressedBytesPerRPCView is the distribution of compressed
-	// received bytes per RPC, keyed on method.
-	ClientReceivedCompressedBytesPerRPCView = &view.View{
+	// ClientReceivedCompressedMessageBytesPerRPCView is the distribution of
+	// compressed received message bytes per RPC, keyed on method.
+	ClientReceivedCompressedMessageBytesPerRPCView = &view.View{
 		Measure:     clientReceivedCompressedBytesPerRPC,
-		Name:        "grpc.io/client/received_compressed_bytes_per_rpc",
-		Description: "Distribution of received compressed bytes per RPC, by method.",
+		Name:        "grpc.io/client/received_compressed_message_bytes_per_rpc",
+		Description: "Distribution of received compressed message bytes per RPC, by method.",
 		TagKeys:     []tag.Key{keyClientMethod},
 		Aggregation: bytesDistribution,
 	}

stats/opencensus/e2e_test.go

@@ -236,13 +236,13 @@ func (s) TestAllMetricsOneFunction(t *testing.T) {
 		ClientCompletedRPCsView,
 		ServerCompletedRPCsView,
 		ClientSentBytesPerRPCView,
-		ClientSentCompressedBytesPerRPCView,
+		ClientSentCompressedMessageBytesPerRPCView,
 		ServerSentBytesPerRPCView,
-		ServerSentCompressedBytesPerRPCView,
+		ServerSentCompressedMessageBytesPerRPCView,
 		ClientReceivedBytesPerRPCView,
-		ClientReceivedCompressedBytesPerRPCView,
+		ClientReceivedCompressedMessageBytesPerRPCView,
 		ServerReceivedBytesPerRPCView,
-		ServerReceivedCompressedBytesPerRPCView,
+		ServerReceivedCompressedMessageBytesPerRPCView,
 		ClientSentMessagesPerRPCView,
 		ServerSentMessagesPerRPCView,
 		ClientReceivedMessagesPerRPCView,
@@ -505,7 +505,7 @@ func (s) TestAllMetricsOneFunction(t *testing.T) {
 			},
 		},
 		{
-			metric: ClientSentCompressedBytesPerRPCView,
+			metric: ClientSentCompressedMessageBytesPerRPCView,
 			wantVI: &viewInformation{
 				aggType:    view.AggTypeDistribution,
 				aggBuckets: bytesDistributionBounds,
@@ -579,7 +579,7 @@ func (s) TestAllMetricsOneFunction(t *testing.T) {
 			},
 		},
 		{
-			metric: ServerSentCompressedBytesPerRPCView,
+			metric: ServerSentCompressedMessageBytesPerRPCView,
 			wantVI: &viewInformation{
 				aggType:    view.AggTypeDistribution,
 				aggBuckets: bytesDistributionBounds,
@@ -653,7 +653,7 @@ func (s) TestAllMetricsOneFunction(t *testing.T) {
 			},
 		},
 		{
-			metric: ClientReceivedCompressedBytesPerRPCView,
+			metric: ClientReceivedCompressedMessageBytesPerRPCView,
 			wantVI: &viewInformation{
 				aggType:    view.AggTypeDistribution,
 				aggBuckets: bytesDistributionBounds,
@@ -727,7 +727,7 @@ func (s) TestAllMetricsOneFunction(t *testing.T) {
 			},
 		},
 		{
-			metric: ServerReceivedCompressedBytesPerRPCView,
+			metric: ServerReceivedCompressedMessageBytesPerRPCView,
 			wantVI: &viewInformation{
 				aggType:    view.AggTypeDistribution,
 				aggBuckets: bytesDistributionBounds,

stats/opencensus/server_metrics.go

@@ -69,11 +69,11 @@ var (
 		TagKeys:     []tag.Key{keyServerMethod},
 		Aggregation: bytesDistribution,
 	}
-	// ServerSentCompressedBytesPerRPCView is the distribution of received
-	// compressed bytes per RPC, keyed on method.
-	ServerSentCompressedBytesPerRPCView = &view.View{
-		Name:        "grpc.io/server/sent_compressed_bytes_per_rpc",
-		Description: "Distribution of sent compressed bytes per RPC, by method.",
+	// ServerSentCompressedMessageBytesPerRPCView is the distribution of
+	// received compressed message bytes per RPC, keyed on method.
+	ServerSentCompressedMessageBytesPerRPCView = &view.View{
+		Name:        "grpc.io/server/sent_compressed_message_bytes_per_rpc",
+		Description: "Distribution of sent compressed message bytes per RPC, by method.",
 		Measure:     serverSentCompressedBytesPerRPC,
 		TagKeys:     []tag.Key{keyServerMethod},
 		Aggregation: bytesDistribution,
@@ -87,11 +87,11 @@ var (
 		TagKeys:     []tag.Key{keyServerMethod},
 		Aggregation: bytesDistribution,
 	}
-	// ServerReceivedCompressedBytesPerRPCView is the distribution of sent bytes
-	// per RPC, keyed on method.
-	ServerReceivedCompressedBytesPerRPCView = &view.View{
-		Name:        "grpc.io/server/received_compressed_bytes_per_rpc",
-		Description: "Distribution of received compressed bytes per RPC, by method.",
+	// ServerReceivedCompressedMessageBytesPerRPCView is the distribution of
+	// sent compressed message bytes per RPC, keyed on method.
+	ServerReceivedCompressedMessageBytesPerRPCView = &view.View{
+		Name:        "grpc.io/server/received_compressed_message_bytes_per_rpc",
+		Description: "Distribution of received compressed message bytes per RPC, by method.",
 		Measure:     serverReceivedCompressedBytesPerRPC,
 		TagKeys:     []tag.Key{keyServerMethod},
 		Aggregation: bytesDistribution,