ee6e1a6363
# Conflicts: # account/Makefile # account/go.mod # docs/account-admin-settings.md # docs/account-svc-plus.md
73 lines
1.2 KiB
Go
73 lines
1.2 KiB
Go
package agentmode
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
type syncTracker struct {
|
|
mu sync.RWMutex
|
|
clients int
|
|
revision string
|
|
lastFetch time.Time
|
|
lastSuccess time.Time
|
|
lastError string
|
|
lastErrorAt time.Time
|
|
}
|
|
|
|
func newSyncTracker() *syncTracker {
|
|
return &syncTracker{}
|
|
}
|
|
|
|
func (t *syncTracker) UpdateFetch(count int, revision string, when time.Time) {
|
|
t.mu.Lock()
|
|
defer t.mu.Unlock()
|
|
|
|
t.clients = count
|
|
t.revision = revision
|
|
t.lastFetch = when
|
|
}
|
|
|
|
func (t *syncTracker) MarkSuccess(at time.Time) {
|
|
t.mu.Lock()
|
|
defer t.mu.Unlock()
|
|
|
|
t.lastSuccess = at
|
|
t.lastError = ""
|
|
t.lastErrorAt = time.Time{}
|
|
}
|
|
|
|
func (t *syncTracker) MarkError(err error, at time.Time) {
|
|
if err == nil {
|
|
return
|
|
}
|
|
t.mu.Lock()
|
|
defer t.mu.Unlock()
|
|
|
|
t.lastError = err.Error()
|
|
t.lastErrorAt = at
|
|
}
|
|
|
|
type trackerSnapshot struct {
|
|
Clients int
|
|
Revision string
|
|
LastFetch time.Time
|
|
LastSuccess time.Time
|
|
LastError string
|
|
LastErrorAt time.Time
|
|
}
|
|
|
|
func (t *syncTracker) Snapshot() trackerSnapshot {
|
|
t.mu.RLock()
|
|
defer t.mu.RUnlock()
|
|
|
|
return trackerSnapshot{
|
|
Clients: t.clients,
|
|
Revision: t.revision,
|
|
LastFetch: t.lastFetch,
|
|
LastSuccess: t.lastSuccess,
|
|
LastError: t.lastError,
|
|
LastErrorAt: t.lastErrorAt,
|
|
}
|
|
}
|