MCPcopy Index your code
hub / github.com/riverqueue/river / Started

Method Started

rivershared/startstop/start_stop.go:27–27  ·  view source on GitHub ↗

Started returns a channel that's closed when a service finishes starting, or if failed to start and is stopped instead. It can be used in conjunction with WaitAllStarted to verify startup of a constellation of services.

()

Source from the content-addressed store, hash-verified

25 // conjunction with WaitAllStarted to verify startup of a constellation of
26 // services.
27 Started() <-chan struct{}
28
29 // Stop stops a service. Services are responsible for making sure their stop
30 // is complete before returning so a caller can wait on this invocation

Callers 15

StartedMethod · 0.65
Test_Client_CommonFunction · 0.65
Test_Client_InsertFunction · 0.65
Test_Client_InsertManyFunction · 0.65
Test_Client_MaintenanceFunction · 0.65
WaitAllStartedCFunction · 0.65
testServiceFunction · 0.65
TestErrStopFunction · 0.65
TestSampleServiceFunction · 0.65

Calls

no outgoing calls

Tested by 15

StartedMethod · 0.52
Test_Client_CommonFunction · 0.52
Test_Client_InsertFunction · 0.52
Test_Client_InsertManyFunction · 0.52
Test_Client_MaintenanceFunction · 0.52
testServiceFunction · 0.52
TestErrStopFunction · 0.52
TestSampleServiceFunction · 0.52
TestStartedFunction · 0.52