Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
Index your code
hub
/
github.com/nutsdb/nutsdb
/ Run
Method
Run
watcher.go:28–41 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
26
}
27
28
func
(w *Watcher) Run() error {
29
w.muReady.Lock()
30
31
if
w.isReady {
32
w.muReady.Unlock()
33
return
nil
34
}
35
36
w.isReady = true
37
close(w.readyCh)
38
w.muReady.Unlock()
39
40
return
w.watchingFunc()
41
}
Callers
15
TestWatcher_Run
Function · 0.95
TestWatcher_WaitReady
Function · 0.95
TestWatcher_ThreadSafety
Function · 0.95
TestWatcher_Integration
Function · 0.95
BenchmarkIterator_Next
Function · 0.80
BenchmarkIterator_Prev
Function · 0.80
TestWatchManager_SubscribeAndSendMessage
Function · 0.80
TestWatchManager_SubscribeAndUnsubscribe
Function · 0.80
TestWatchManager_StartDistributor
Function · 0.80
TestWatchManager_DeleteBucket
Function · 0.80
TestWatchManager_SendMessage
Function · 0.80
TestWatchManager_Stop
Function · 0.80
Calls
no outgoing calls
Tested by
15
TestWatcher_Run
Function · 0.76
TestWatcher_WaitReady
Function · 0.76
TestWatcher_ThreadSafety
Function · 0.76
TestWatcher_Integration
Function · 0.76
BenchmarkIterator_Next
Function · 0.64
BenchmarkIterator_Prev
Function · 0.64
TestWatchManager_SubscribeAndSendMessage
Function · 0.64
TestWatchManager_SubscribeAndUnsubscribe
Function · 0.64
TestWatchManager_StartDistributor
Function · 0.64
TestWatchManager_DeleteBucket
Function · 0.64
TestWatchManager_SendMessage
Function · 0.64
TestWatchManager_Stop
Function · 0.64