Add CWService interface

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

Hide file tree

Showing 2 changed files with 6 additions and 15 deletions.
diff --git a/aws/cwatch/base.go b/aws/cwatch/base.go
diff --git a/aws/cwatch/service.go b/aws/cwatch/service.go
@@ -72,4 +72,10 @@ func (s *Service) processBatch(batch []types.MetricDatum) {
 	}
 }
 
+type CWService interface {
+	Queue(d types.MetricDatum)
+	StartQueue(wg *sync.WaitGroup)
+	StopQueue()
+}
+
 var _ CWService = (*Service)(nil)