oppi.li
bnewbold.net
+7
cmd/sonar/sonar.go
+7
cmd/sonar/sonar.go
···
109
109
case xe.RepoCommit != nil:
110
110
eventsProcessedCounter.WithLabelValues("repo_commit", s.SocketURL).Inc()
111
111
return s.HandleRepoCommit(ctx, xe.RepoCommit)
112
+
case xe.RepoSync != nil:
113
+
eventsProcessedCounter.WithLabelValues("sync", s.SocketURL).Inc()
114
+
now := time.Now()
115
+
s.ProgMux.Lock()
116
+
s.Progress.LastSeq = xe.RepoSync.Seq
117
+
s.Progress.LastSeqProcessedAt = now
118
+
s.ProgMux.Unlock()
112
119
case xe.RepoIdentity != nil:
113
120
eventsProcessedCounter.WithLabelValues("identity", s.SocketURL).Inc()
114
121
now := time.Now()