MCPcopy
hub / github.com/grafana/tempo / Wait

Method Wait

modules/frontend/pipeline/async_sharding.go:14–14  ·  modules/frontend/pipeline/async_sharding.go::waitGroup.Wait
()

Source from the content-addressed store, hash-verified

12 Add(int)
13 Done()
14 Wait()
15}
16
17// NewAsyncSharderFunc creates a new AsyncResponse that shards requests to the next AsyncRoundTripper[combiner.PipelineResponse]. It creates one

Callers 15

NewAsyncSharderFuncFunction · 0.95
RetainWithConfigMethod · 0.65
TestPollNotificationFunction · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
ListBlocksMethod · 0.65
ListBlocksMethod · 0.65
RunJobsMethod · 0.65
TestGoingHamFunction · 0.65
TestOverloadingASmallPoolFunction · 0.65
DoMethod · 0.65

Implementers 1

BoundedWaitGrouppkg/boundedwaitgroup/boundedwaitgroup.

Calls

no outgoing calls

Tested by 15

TestPollNotificationFunction · 0.52
TestWalBlockRaceConditionCheckFunction · 0.52
TestWalBlockRaceConditionCheckFunction · 0.52
TestWalBlockRaceConditionCheckFunction · 0.52
TestGoingHamFunction · 0.52
TestOverloadingASmallPoolFunction · 0.52
Test_counter_concurrencyCorrectnessFunction · 0.52
TestDrainSanitizer_ConcurrentAccessFunction · 0.52
TestPerLabelLimiter_ConcurrentAccessFunction · 0.52
TestCardinalityConcurrentInsertEstimateFunction · 0.52
Test_histogram_concurrencyCorrectnessFunction · 0.52
Test_gauge_concurrencyCorrectnessFunction · 0.52