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

Method EmitAllBatches

pkg/util/trace_info.go:140–156  ·  pkg/util/trace_info.go::TraceInfo.EmitAllBatches

EmitAllBatches sends all the batches that would normally be sent at some interval when using EmitBatches.

(c JaegerClient)

Source from the content-addressed store, hash-verified

138// EmitAllBatches sends all the batches that would normally be sent at some
139// interval when using EmitBatches.
140func (t *TraceInfo) EmitAllBatches(c JaegerClient) error {
141 err := t.EmitBatches(context.Background(), c)
142 if err != nil {
143 return err
144 }
145
146 for t.LongWritesRemaining() > 0 {
147 t.Done()
148
149 err := t.EmitBatches(context.Background(), c)
150 if err != nil {
151 return err
152 }
153 }
154
155 return nil
156}
157
158func (t *TraceInfo) generateRandomInt(min, max int64) int64 {
159 min++

Callers 2

WriteTraceInfoMethod · 0.80
writeValidationTraceMethod · 0.80

Calls 3

EmitBatchesMethod · 0.95
LongWritesRemainingMethod · 0.95
DoneMethod · 0.95

Tested by

no test coverage detected