Merge pull request #1436 from memphisdev/RND-194-report-total-invocat…

…ions-total-duration-to-firestore-stigg

from cloud

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"`
+}

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()

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())
 }