MCPcopy
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
32func (t *BeginOnlyOnce) Done() {
33 t.done = true
34 if t.parent != nil {
35 t.parent.subTxInProgress = false
36 }
37}
38
39func (t *BeginOnlyOnce) IsDone() bool { return t.done }

Callers 15

TestBeginOnlyOnceFunction · 0.95
WorkMethod · 0.80
newPilotWithPluginFunction · 0.80
fetchAndRunLoopMethod · 0.80
fetchPollLoopMethod · 0.80
heartbeatLogLoopMethod · 0.80
pollForSettingChangesMethod · 0.80
reportQueueStatusLoopMethod · 0.80
WorkMethod · 0.80

Calls

no outgoing calls

Tested by 15

TestBeginOnlyOnceFunction · 0.76
WorkMethod · 0.64
newPilotWithPluginFunction · 0.64
WorkMethod · 0.64
makeAwaitWorkerFunction · 0.64
Test_Client_CommonFunction · 0.64
Test_Client_Stop_CommonFunction · 0.64