Method Collect

pkg/collector/scoped_distinct_string.go:55–93

Collect adds a new value to the distinct string collector. returns true when it reaches the limits and can't fit more values. can be used to stop early during Collect without calling Exceeded.

(scope string, val string)

// returns true when it reaches the limits and can't fit more values.
// can be used to stop early during Collect without calling Exceeded.
func (d *ScopedDistinctString) Collect(scope string, val string) (exceeded bool) {
	d.mtx.Lock()
	defer d.mtx.Unlock()

	if d.limExceeded {
		return true
	}

	valueLen := len(val)
	// can it fit?
	if d.maxDataSize > 0 && d.currDataSize+valueLen > d.maxDataSize {
		// No
		d.limExceeded = true
		return true
	}

	// get or create collector
	col, ok := d.cols[scope]
	if !ok {
		if scope == IntrinsicScope {
			col = d.newCol(0, 0, 0)
		} else {
			col = d.newCol(0, d.maxTagsPerScope, d.maxCacheHits)
		}
		d.cols[scope] = col
	}

	// add valueLen if we successfully added the value
	if col.Collect(val) {
		d.currDataSize += valueLen
	}
	if col.Exceeded() {
		// we stop if one of the scopes exceed the limit
		d.limExceeded = true
		d.stopReason = col.stopReason
		return true
	}
	return false
}

// Strings returns the final list of distinct values collected and sorted.
func (d *ScopedDistinctString) Strings() map[string][]string {