add collectedAt

coder · defelmnq · Feb 14, 2025 · Feb 4, 2025 · Feb 10, 2025 · Feb 10, 2025
commit 3bec3247b51659b2ed6bccaf76b275b78625cbfc
@@ -1,12 +1,17 @@
 package resourcesmonitor
 
 import (
+	"time"
+
+	"google.golang.org/protobuf/types/known/timestamppb"
+
 	"github.com/coder/coder/v2/agent/proto"
 )
 
 type Datapoint struct {
-	Memory  *MemoryDatapoint
-	Volumes []*VolumeDatapoint
+	CollectedAt time.Time
+	Memory      *MemoryDatapoint
+	Volumes     []*VolumeDatapoint
 }
 
 type MemoryDatapoint struct {
@@ -55,7 +60,9 @@ func (q *Queue) ItemsAsProto() []*proto.PushResourcesMonitoringUsageRequest_Data
 	items := make([]*proto.PushResourcesMonitoringUsageRequest_Datapoint, 0, len(q.items))
 
 	for _, item := range q.items {
-		protoItem := &proto.PushResourcesMonitoringUsageRequest_Datapoint{}
+		protoItem := &proto.PushResourcesMonitoringUsageRequest_Datapoint{
+			CollectedAt: timestamppb.New(item.CollectedAt),
+		}
 		if item.Memory != nil {
 			protoItem.Memory = &proto.PushResourcesMonitoringUsageRequest_Datapoint_MemoryUsage{
 				Total: item.Memory.Total,

@@ -37,7 +37,8 @@ type datapointsPusher interface {
 func (m *monitor) Start(ctx context.Context) error {
 	m.clock.TickerFunc(ctx, time.Duration(m.config.Config.CollectionIntervalSeconds)*time.Second, func() error {
 		datapoint := Datapoint{
-			Volumes: make([]*VolumeDatapoint, 0, len(m.config.Volumes)),
+			CollectedAt: m.clock.Now(),
+			Volumes:     make([]*VolumeDatapoint, 0, len(m.config.Volumes)),
 		}
 
 		if m.config.Memory != nil && m.config.Memory.Enabled {