tracker

type Config struct {
	MaxFlows   int  // maximum number of active (non-filtered) flows allowed at a time
	MinSamples int  // minimum number of samples required to return ended flows for further processing
	Log        bool // if true, logging is enabled
}

type Flow struct {
	ID             sampler.ID     // flow ID
	Data           []sampler.Data // flow data
	StartTime      time.Time      // start time (use only when wall time needed, otherwise use monotonic timestamps in Data)
	EndTime        time.Time      // end time (use only when wall time needed, otherwise use monotonic timestamps in Data)
	Filtered       bool           // true if flow will be tracked but data not recorded/returned
	Sampled        bool           // true if flow was sampled during current track operation
	PreExisting    bool           // true if flow already existed on startup
	Partial        bool           // true if flow was pre-existing or no final sample was seen
	SamplesDeduped int            // number of samples de-duped
	EndTstampNs    uint64         // monotonic nsec time of last sample, even if it was de-duped
}

type Metrics struct {
	StartTime        time.Time
	TrackTimes       metrics.DurationStats
	TrackedFlows     int
	PriorEndedFlows  uint64
	PriorTrackerTime time.Time
	EndedFlows       uint64
	InstChurnRate    float64
	sync.RWMutex
}

type Tracker struct {
	Config
	// contains filtered or unexported fields
}