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

Method Done

modules/livestore/partition_reader.go:28–28  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

26type recordIter interface {
27 Next() *kgo.Record
28 Done() bool
29}
30
31type consumeFn func(context.Context, recordIter, time.Time) (*kadm.Offset, error)

Callers 15

retentionLoopMethod · 0.65
RetainWithConfigMethod · 0.65
retainTenantMethod · 0.65
compactWhileOwnsMethod · 0.65
doForAtLeastFunction · 0.65
TestPollNotificationFunction · 0.65
PollNotificationMethod · 0.65
pollingLoopMethod · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
TestWalBlockRaceConditionCheckFunction · 0.65
ListBlocksMethod · 0.65

Implementers 1

testRecordItermodules/livestore/live_store_test.go

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