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

Method pushBytes

modules/blockbuilder/partition_writer.go:24–24  ·  view source on GitHub ↗
(ts time.Time, tenant string, req *tempopb.PushBytesRequest)

Source from the content-addressed store, hash-verified

22
23type partitionSectionWriter interface {
24 pushBytes(ts time.Time, tenant string, req *tempopb.PushBytesRequest) error
25 flush(ctx context.Context, r tempodb.Reader, w tempodb.Writer, c tempodb.Compactor) error
26}
27

Callers 15

TestPushBytesFunction · 0.65
pushTracesMethod · 0.65
pushTraceFunction · 0.65
TestMetrics_PushBytesTrackingFunction · 0.65
TestMetrics_CompletionFlowFunction · 0.65
TestMetrics_EmptyPushBytesRequestFunction · 0.65
consumeMethod · 0.65
PushBytesMethod · 0.65
TestSearchTagsV2LimitsFunction · 0.65
pushTracesToInstanceFunction · 0.65
writeTracesForSearchFunction · 0.65
TestInstanceSearchDoesNotRaceFunction · 0.65

Implementers 1

writermodules/blockbuilder/partition_writer.

Calls

no outgoing calls

Tested by 12

TestPushBytesFunction · 0.52
pushTraceFunction · 0.52
TestMetrics_PushBytesTrackingFunction · 0.52
TestMetrics_CompletionFlowFunction · 0.52
TestMetrics_EmptyPushBytesRequestFunction · 0.52
TestSearchTagsV2LimitsFunction · 0.52
pushTracesToInstanceFunction · 0.52
writeTracesForSearchFunction · 0.52
TestInstanceSearchDoesNotRaceFunction · 0.52
TestInstanceSearchMetricsFunction · 0.52
TestInstanceFindByTraceIDWithSizeLimitsFunction · 0.52
TestLiveStoreQueryRangeFunction · 0.52