We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8b54022 commit d2e3e6eCopy full SHA for d2e3e6e
1 file changed
internal/sync/engine.go
@@ -122,6 +122,11 @@ func (e *Engine) SetSyncMetricsRecorder(recorder SyncMetricsRecorder) {
122
e.syncRepo = recorder
123
}
124
125
+// HasMetricsRecorder reports whether a sync metrics recorder has been attached.
126
+func (e *Engine) HasMetricsRecorder() bool {
127
+ return e.syncRepo != nil
128
+}
129
+
130
// GetCurrentRun returns the current sync run being tracked (thread-safe).
131
func (e *Engine) GetCurrentRun() *BroadcastSyncRun {
132
e.currentRunMu.RLock()
0 commit comments