Method Collect

pkg/collector/distinct_string_collector.go:55–100

Collect adds a new value to the distinct string collector and returns a boolean indicating whether the value was successfully added or not. To check if the limit has been reached, you must call the Exceeded method separately.

(s string)

// and returns a boolean indicating whether the value was successfully added or not.
// To check if the limit has been reached, you must call the Exceeded method separately.
func (d *DistinctString) Collect(s string) (added bool) {
	d.mtx.Lock()
	defer d.mtx.Unlock()

	if d.limExceeded {
		return false
	}
	valueLen := len(s)

	if d.maxDataSize > 0 && d.currDataSize+valueLen >= d.maxDataSize {
		d.stopReason = fmt.Sprintf("Max data exceeded: dataSize %d, maxDataSize %d", d.currDataSize, d.maxDataSize)
		d.limExceeded = true
		return false
	}

	if d.maxValues > 0 && d.currentValuesLen >= d.maxValues {
		d.stopReason = fmt.Sprintf("Max values exceeded: values %d, maxValues %d", d.currentValuesLen, d.maxValues)
		d.limExceeded = true
		return false
	}

	if d.maxCacheHits > 0 && d.currentCacheHits >= d.maxCacheHits {
		d.stopReason = fmt.Sprintf("Max stale values exceeded: cacheHits %d, maxValues %d", d.currentValuesLen, d.maxCacheHits)
		d.limExceeded = true
		return false
	}

	if _, ok := d.values[s]; ok {
		// Already present
		d.currentCacheHits++
		return false
	}
	d.currentCacheHits = 0 // CacheHits reset to 0 when a new value is found

	// Clone instead of referencing original
	s = strings.Clone(s)

	if d.diffEnabled {
		d.new[s] = struct{}{}
	}
	d.values[s] = struct{}{}
	d.currDataSize += valueLen
	d.currentValuesLen++

	return true
}

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