Introducing pipedstat model

BUILD.bazel

@@ -62,6 +62,7 @@ genrule(
 # gazelle:exclude pkg/model/logblock.pb.validate.go
 # gazelle:exclude pkg/model/notificationevent.pb.validate.go
 # gazelle:exclude pkg/model/piped.pb.validate.go
+# gazelle:exclude pkg/model/piped_stat.pb.validate.go
 # gazelle:exclude pkg/model/piped_stats.pb.validate.go
 # gazelle:exclude pkg/model/planpreview.pb.validate.go
 # gazelle:exclude pkg/model/project.pb.validate.go

pkg/app/api/grpcapi/piped_api.go

@@ -16,6 +16,7 @@ package grpcapi
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
 	"time"
 
@@ -98,7 +99,18 @@ func (a *PipedAPI) ReportStat(ctx context.Context, req *pipedservice.ReportStatR
 	if err != nil {
 		return nil, err
 	}
-	if err := a.pipedStatCache.Put(pipedID, req.PipedStats); err != nil {
+
+	now := time.Now().Unix()
+	val, err := json.Marshal(model.PipedStat{Timestamp: now, Stats: req.PipedStats})
+	if err != nil {
+		a.logger.Error("failed to store the reported piped stat",
+			zap.String("piped-id", pipedID),
+			zap.Error(err),
+		)
+		return nil, status.Error(codes.Internal, "failed to encode the reported piped stat")
+	}
+
+	if err := a.pipedStatCache.Put(pipedID, val); err != nil {
 		a.logger.Error("failed to store the reported piped stat",
 			zap.String("piped-id", pipedID),
 			zap.Error(err),

pkg/datastore/pipedstatsstore.go

@@ -27,6 +27,7 @@ var pipedStatsFactory = func() interface{} {
 	return &model.PipedStats{}
 }
 
+// Deprecated: PipedStats model is deprecated, along with its store interface.
 type PipedStatsStore interface {
 	AddPipedStats(ctx context.Context, ps *model.PipedStats) error
 	ListPipedStatss(ctx context.Context, opts ListOptions) ([]model.PipedStats, error)
@@ -37,6 +38,7 @@ type pipedStatsStore struct {
 	nowFunc func() time.Time
 }
 
+// Deprecated: PipedStats model is deprecated, along with its store interface.
 func NewPipedStatsStore(ds DataStore) PipedStatsStore {
 	return &pipedStatsStore{
 		backend: backend{

pkg/model/BUILD.bazel

@@ -16,6 +16,7 @@ proto_library(
         "logblock.proto",
         "notificationevent.proto",
         "piped.proto",
+        "piped_stat.proto",
         "piped_stats.proto",
         "planpreview.proto",
         "project.proto",

pkg/model/piped_stat.proto

@@ -0,0 +1,25 @@
+// Copyright 2021 The PipeCD Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+
+package pipe.model;
+option go_package = "github.com/pipe-cd/pipe/pkg/model";
+
+import "validate/validate.proto";
+
+message PipedStat {
+    int64 timestamp = 1 [(validate.rules).int64.gt = 0];
+    bytes stats = 2;
+}

pkg/model/piped_stats.proto

@@ -39,6 +39,7 @@ message PrometheusMetrics {
 }
 
 message PipedStats {
+    option deprecated = true;
     string version = 1 [(validate.rules).string.min_len = 1];
     int64 timestamp = 2 [(validate.rules).int64.gt = 0];
     repeated PrometheusMetrics prometheus_metrics = 3;