Function NewCombiner

pkg/model/trace/combine.go:37–43

It creates a new Trace combiner. If maxSizeBytes is 0, the final trace size is not checked when allowPartialTrace is set to true a partial trace that exceed the max size may be returned

(maxSizeBytes int, allowPartialTrace bool)

// It creates a new Trace combiner. If maxSizeBytes is 0, the final trace size is not checked
// when allowPartialTrace is set to true a partial trace that exceed the max size may be returned
func NewCombiner(maxSizeBytes int, allowPartialTrace bool) *Combiner {
	return &Combiner{
		mtx:               sync.Mutex{},
		maxSizeBytes:      maxSizeBytes,
		allowPartialTrace: allowPartialTrace,
	}
}

// Consume the given trace and destructively combines its contents.
func (c *Combiner) Consume(tr *tempopb.Trace) (int, error) {