MCPcopy
hub / github.com/grafana/dskit / Done

Method Done

gate/gate.go:29–29  ·  view source on GitHub ↗

Done finishes a query.

()

Source from the content-addressed store, hash-verified

27 Start(ctx context.Context) error
28 // Done finishes a query.
29 Done()
30}
31
32// NewNoop creates a Gate implementation that doesn't enforce any limit.

Callers 15

asyncQueueProcessLoopMethod · 0.65
SetMethod · 0.65
AddMethod · 0.65
DeleteMethod · 0.65
incrDecrMethod · 0.65
TouchMethod · 0.65
CompareAndSwapMethod · 0.65
FlushAllMethod · 0.65
waitMethod · 0.65
getMultiBatchedMethod · 0.65
doWithBatchFunction · 0.65
runningMethod · 0.65

Implementers 4

noopGategate/gate.go
instrumentedGategate/gate.go
rejectingGategate/gate.go
blockingGategate/gate.go

Calls

no outgoing calls

Tested by 15

TestDoUntilQuorumWithoutSuccessfulContextCancellation_CancelsEntireZoneImmediatelyOnSingleFailureFunction · 0.52
TestDoUntilQuorumWithoutSuccessfulContextCancellation_RunsCallsInParallelFunction · 0.52
TestDoUntilQuorumWithoutSuccessfulContextCancellation_ParentContextHandling_WithoutMinimizeRequestsFunction · 0.52
TestDoUntilQuorumWithoutSuccessfulContextCancellation_ParentContextHandling_WithMinimizeRequestsFunction · 0.52
TestDoUntilQuorumWithoutSuccessfulContextCancellation_Hedging_ZoneAwareFunction · 0.52
TestDoUntilQuorumWithoutSuccessfulContextCancellation_Hedging_NonZoneAwareFunction · 0.52
TestDoMultiUntilQuorumWithoutSuccessfulContextCancellationFunction · 0.52
executeScenarioFunction · 0.52
TestDoBatchWithOptionsContextCancellationFunction · 0.52
TestDoBatch_QuorumErrorFunction · 0.52
TestRing_ShuffleShardWithLookback_CachingConcurrencyFunction · 0.52
TestZoneAwareResultTracker_StartMinimumRequests_MaxUnavailableZonesIsNumberOfZonesFunction · 0.52