Function NewStore

modules/generator/processor/servicegraphs/store/store.go:42–58

NewStore creates a Store to build service graphs. The store caches edges, each representing a request between two services. Once an edge is complete its metrics can be collected. Edges that have not found their pair are deleted after ttl time.

(ttl time.Duration, maxItems int, onComplete, onExpire Callback, droppedSpanSideOverflowCounter prometheus.Counter)

// request between two services. Once an edge is complete its metrics can be collected. Edges that
// have not found their pair are deleted after ttl time.
func NewStore(ttl time.Duration, maxItems int, onComplete, onExpire Callback, droppedSpanSideOverflowCounter prometheus.Counter) Store {
	s := &store{
		l: list.New(),
		m: make(map[string]*list.Element),
		d: make(map[droppedSpanSideKey]int64),

		onComplete: onComplete,
		onExpire:   onExpire,

		ttl:      ttl,
		maxItems: maxItems,

		droppedSpanSideOverflowCounter: droppedSpanSideOverflowCounter,
	}

	return s
}

func (s *store) len() int {
	s.mtx.Lock()