report_buffer.go

package lightstep

import (
	"time"
)

type reportBuffer struct {
	rawSpans             []RawSpan
	droppedSpanCount     int64
	logEncoderErrorCount int64
	reportStart          time.Time
	reportEnd            time.Time
}

func newSpansBuffer(size int) (b reportBuffer) {
	b.rawSpans = make([]RawSpan, 0, size)
	b.reportStart = time.Time{}
	b.reportEnd = time.Time{}
	return
}

func (b *reportBuffer) isHalfFull() bool {
	return len(b.rawSpans) > cap(b.rawSpans)/2
}

func (b *reportBuffer) setCurrent(now time.Time) {
	b.reportStart = now
	b.reportEnd = now
}

func (b *reportBuffer) setFlushing(now time.Time) {
	b.reportEnd = now
}

func (b *reportBuffer) clear() {
	b.rawSpans = b.rawSpans[:0]
	b.reportStart = time.Time{}
	b.reportEnd = time.Time{}
	b.droppedSpanCount = 0
	b.logEncoderErrorCount = 0
}

func (b *reportBuffer) addSpan(span RawSpan) {
	if len(b.rawSpans) == cap(b.rawSpans) {
		b.droppedSpanCount++
		return
	}
	b.rawSpans = append(b.rawSpans, span)
}

// mergeFrom combines the spans and metadata in `from` with `into`,
// returning with `from` empty and `into` having a subset of the
// combined data.
func (b *reportBuffer) mergeFrom(from *reportBuffer) {
	b.droppedSpanCount += from.droppedSpanCount
	b.logEncoderErrorCount += from.logEncoderErrorCount
	if from.reportStart.Before(b.reportStart) {
		b.reportStart = from.reportStart
	}
	if from.reportEnd.After(b.reportEnd) {
		b.reportEnd = from.reportEnd
	}

	// Note: Somewhat arbitrarily dropping the spans that won't
	// fit; could be more principled here to avoid bias.
	have := len(b.rawSpans)
	space := cap(b.rawSpans) - have
	unreported := len(from.rawSpans)

	if space > unreported {
		space = unreported
	}

	b.rawSpans = append(b.rawSpans, from.rawSpans[0:space]...)

	b.droppedSpanCount += int64(unreported - space)

	from.clear()
}