Method Combine

pkg/model/v2/object_decoder.go:56–97

(objs ...[]byte)

}

func (d *ObjectDecoder) Combine(objs ...[]byte) ([]byte, error) {
	var minStart, maxEnd uint32
	minStart = math.MaxUint32

	c := trace.NewCombiner(0, false)
	for i, obj := range objs {
		t, err := d.PrepareForRead(obj)
		if err != nil {
			return nil, fmt.Errorf("error unmarshaling trace: %w", err)
		}

		if len(obj) != 0 {
			start, end, err := d.FastRange(obj)
			if err != nil {
				return nil, fmt.Errorf("error getting range: %w", err)
			}

			if start < minStart {
				minStart = start
			}
			if end > maxEnd {
				maxEnd = end
			}
		}

		_, err = c.ConsumeWithFinal(t, i == len(objs)-1)
		if err != nil {
			return nil, fmt.Errorf("error combining trace: %w", err)
		}
	}

	combinedTrace, _ := c.Result()

	traceBytes := &tempopb.TraceBytes{}
	bytes, err := proto.Marshal(combinedTrace)
	if err != nil {
		return nil, fmt.Errorf("error marshaling traceBytes: %w", err)
	}
	traceBytes.Traces = append(traceBytes.Traces, bytes)

	return marshalWithStartEnd(traceBytes, minStart, maxEnd)
}

func (d *ObjectDecoder) FastRange(buff []byte) (uint32, uint32, error) {
	_, start, end, err := stripStartEnd(buff)