chore: add catalog summary materialized view referesh jobs

jobs/catalog.go

@@ -0,0 +1,29 @@
+package jobs
+
+import (
+	"github.com/flanksource/duty/job"
+)
+
+var RefreshCatalogAnaylsisChangeCount7dView = &job.Job{
+	Name:       "RefreshCatalogAnaylsisChangeCount7dView",
+	Schedule:   "@every 10m",
+	Retention:  job.RetentionFew,
+	Singleton:  true,
+	JobHistory: true,
+	RunNow:     true,
+	Fn: func(ctx job.JobRuntime) error {
+		return job.RefreshConfigItemAnalysisChangeCount7d(ctx.Context)
+	},
+}
+
+var RefreshCatalogAnaylsisChangeCount30dView = &job.Job{
+	Name:       "RefreshCatalogAnaylsisChangeCount30dView",
+	Schedule:   "@every 1h",
+	Retention:  job.RetentionFew,
+	Singleton:  true,
+	JobHistory: true,
+	RunNow:     true,
+	Fn: func(ctx job.JobRuntime) error {
+		return job.RefreshConfigItemAnalysisChangeCount30d(ctx.Context)
+	},
+}

jobs/jobs.go

@@ -69,6 +69,14 @@ func Start(ctx context.Context) {
 		logger.Errorf("Failed to schedule job for syncing config cache: %v", err)
 	}
 
+	for _, job := range []*job.Job{RefreshCatalogAnaylsisChangeCount7dView, RefreshCatalogAnaylsisChangeCount30dView} {
+		j := job
+		j.Context = ctx
+		if err := j.AddToScheduler(FuncScheduler); err != nil {
+			logger.Errorf("Failed to schedule %s: %v", j, err)
+		}
+	}
+
 	if api.UpstreamConf.Valid() {
 		for _, job := range agentJobs {
 			j := job