Add CWService interface

nyaruka · Dec 13, 2024 · f660897 · f660897
1 parent c430b1e
commit f660897
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/aws/cwatch/base.go b/aws/cwatch/base.go
@@ -0,0 +1,15 @@
+package cwatch
+
+import (
+	"sync"
+
+	"github.com/aws/aws-sdk-go-v2/service/cloudwatch"
+	"github.com/aws/aws-sdk-go-v2/service/cloudwatch/types"
+)
+
+type CWService interface {
+	Queue(d types.MetricDatum)
+	StartQueue(wg *sync.WaitGroup)
+	StopQueue()
+	Prepare(data []types.MetricDatum) *cloudwatch.PutMetricDataInput
+}
diff --git a/aws/cwatch/service.go b/aws/cwatch/service.go
@@ -71,3 +71,5 @@ func (s *Service) processBatch(batch []types.MetricDatum) {
 		slog.Error("error sending metrics to cloudwatch", "error", err, "count", len(batch))
 	}
 }
+
+var _ CWService = (*Service)(nil)
-Original file line number
+Diff line change
@@ Expand Up / @@ -71,3 +71,5 @@ func (s *Service) processBatch(batch []types.MetricDatum) { @@
     		slog.Error("error sending metrics to cloudwatch", "error", err, "count", len(batch))
     	}
     }
+    var _ CWService = (*Service)(nil)