Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/riverqueue/river
/ Done
Method
Done
rivershared/util/savepointutil/savepoint_util.go:32–37 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
30
}
31
32
func
(t *BeginOnlyOnce) Done() {
33
t.done = true
34
if
t.parent != nil {
35
t.parent.subTxInProgress = false
36
}
37
}
38
39
func
(t *BeginOnlyOnce) IsDone() bool {
return
t.done }
Callers
15
TestBeginOnlyOnce
Function · 0.95
Work
Method · 0.80
newPilotWithPlugin
Function · 0.80
handleControlNotification
Method · 0.80
fetchAndRunLoop
Method · 0.80
fetchPollLoop
Method · 0.80
heartbeatLogLoop
Method · 0.80
pollForSettingChanges
Method · 0.80
reportProducerStatusLoop
Method · 0.80
reportQueueStatusLoop
Method · 0.80
Example_gracefulShutdownStopAndCancel
Function · 0.80
Work
Method · 0.80
Calls
no outgoing calls
Tested by
15
TestBeginOnlyOnce
Function · 0.76
Work
Method · 0.64
newPilotWithPlugin
Function · 0.64
Example_gracefulShutdownStopAndCancel
Function · 0.64
Work
Method · 0.64
makeAwaitWorker
Function · 0.64
Test_Client_Common
Function · 0.64
Test_Client_Stop_Common
Function · 0.64
Test_Client_StopAndCancel
Function · 0.64
Test_Client_SoftStopTimeout
Function · 0.64
Test_Client_JobContextInheritsFromProvidedContext
Function · 0.64
Test_Client_InsertTriggersImmediateWork
Function · 0.64