Method flush

pkg/event/stackwalk.go:202–241

flush pushes events to the event queue if they have been living in the queue more than the maximum allowed TTL period.

()

// been living in the queue more than the maximum allowed
// TTL period.
func (s *StackwalkDecorator) flush() []error {
	s.mux.Lock()
	defer s.mux.Unlock()

	if len(s.buckets) == 0 {
		return nil
	}

	errs := make([]error, 0)

	for id, q := range s.buckets {
		n := make([]*Event, 0, len(q))
		for _, evt := range q {
			if time.Since(evt.Timestamp) < maxQueueTTLPeriod {
				n = append(n, evt)
				continue
			}

			stackwalkFlushes.Add(1)
			err := s.q.push(evt)
			if err != nil {
				errs = append(errs, err)
			}
			if stackwalkEnqueued.Value() > 0 {
				stackwalkEnqueued.Add(-1)
			}
			if evt.PS != nil {
				stackwalkFlushesProcs.Add(evt.PS.Name, 1)
			}
			stackwalkFlushesEvents.Add(evt.Name, 1)
		}
		if len(n) == 0 {
			delete(s.buckets, id)
		} else {
			s.buckets[id] = n
		}
	}

	return errs
}