MCPcopy Create free account
hub / github.com/cloudbase/garm / Done

Method Done

websocket/client.go:120–122  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

118}
119
120func (c *Client) Done() <-chan struct{} {
121 return c.done
122}
123
124func (c *Client) SetMessageHandler(handler HandleWebsocketMessage) {
125 c.mux.Lock()

Callers 15

runWatcherMethod · 0.95
MetricsHandlerMethod · 0.95
WSHandlerMethod · 0.95
LockWithContextMethod · 0.45
GetControllerInfoMethod · 0.45
WaitMethod · 0.45
CollectObjectMetricFunction · 0.45
startLoopForFunctionMethod · 0.45
waitForErrorGroupOrContextCancelledMethod · 0.45
waitForTimeoutOrCancelledMethod · 0.45
sleepWithCancelMethod · 0.45
StartMethod · 0.45

Calls

no outgoing calls

Tested by 3

TestConcurrentQueuedJobsMethod · 0.36
TestConcurrentWebhooksForSameJobMethod · 0.36
TestCreateInstanceConcurrentMaxRunnersRaceConditionMethod · 0.36