from cloud

superstreamlabs · Nov 21, 2023 · 8155820 · 8155820
1 parent 2dda870
commit 8155820
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/models/functions.go b/models/functions.go
@@ -89,3 +89,9 @@ type ScheduledFunctionWorker struct {
 	OrderingMatter     bool   `json:"ordering_matter"`
 	AttachedFunctionID int    `json:"attached_function_id"`
 }
+
+type FunctionCounterMsg struct {
+	TenantName       string `json:"tenant_name"`
+	TotalInvocations int64  `json:"total_invocations"`
+	TotalDuration    int64  `json:"total_duration"`
+}
diff --git a/server/background_tasks.go b/server/background_tasks.go
@@ -330,6 +330,11 @@ func (s *Server) StartBackgroundTasks() error {
 		return errors.New("Failed to subscribing for cloud cache updates" + err.Error())
 	}
 
+	err = s.ListenToFunctionsCounterUpdates()
+	if err != nil {
+		return errors.New("Failed to subscribing for functions counter updates" + err.Error())
+	}
+
 	go s.ConsumeSchemaverseDlsMessages()
 	go s.ConsumeUnackedMsgs()
 	go s.ConsumeFunctionsDlsMessages()

diff --git a/server/memphis_cloud.go b/server/memphis_cloud.go
@@ -2219,6 +2219,10 @@ func (s *Server) ListenForCloudCacheUpdates() error {
 	return nil
 }
 
+func (s *Server) ListenToFunctionsCounterUpdates() error {
+	return nil
+}
+
 func (c *client) AccountConnExceeded() {
 	c.sendErrAndErr(ErrTooManyAccountConnections.Error())
 }