analyzer

type Analyzer struct {
	Config
	FlowDurations metrics.DurationHistogram
	// contains filtered or unexported fields
}

type Config struct {
	SamplerInterval        time.Duration     // sampler interval (for quantile and correlation weights)
	CumulantKind           stat.CumulantKind // cumulant for quantile calculations
	UnweightedCorrelations bool              // if true, correlations are unweighted
	UnweightedQuantiles    bool              // if true, quantiles are unweighted
	AdjustedCC1            bool              // if true, use adjusted correlation r_adj = r * (1 + (1-r^2)/2n)
	AdjustedCC2            bool              // if true, use adjusted correlation r_adj = sqrt(1 - ((1-r^2)*(n-1)) / (n-2))
	Log                    bool              // if true, logging is enabled
}

type FlowStats struct {
	ID                        ID            // flow ID
	StartTime                 time.Time     // start time
	EndTime                   time.Time     // end time
	Duration                  time.Duration // duration from first to last sample
	Samples                   int           // number of unique samples
	SamplesDeduped            int           // number of samples de-duped
	Partial                   bool          // true if flow was pre-existing or had no last sample on shutdown
	Timestamps                bool          // true if flow had timestamps enabled (TCPI_OPT_TIMESTAMPS)
	SACK                      bool          // true if flow had SACK enabled (TCPI_OPT_SACK)
	ECN                       bool          // true if flow had ECN enabled (TCPI_OPT_ECN)
	ECNSeen                   bool          // true if at least one packet _received_ with ECT (TCPI_OPT_ECN_SEEN)
	MinRTTKernelms            float64       // minimum RTT as tracked by the kernel, in milliseconds
	MinRTTObservedms          float64       // minimum RTT in the observed samples
	MaxPacingRateKernelMbps   float64       // maximum pacing rate as tracked by the kernel, in Mbps
	MaxPacingRateObservedMbps float64       // maximum pacing rate in the observed samples
	RTTSummary                [7]float64    // RTT seven number summary
	RTTVarSummary             [7]float64    // RTT variance seven number summary
	CorrRTTCwnd               float64       // correlation between RTT and cwnd
	CorrRetransCwnd           float64       // correlation between retransmit rate and cwnd
	CorrPacingCwnd            float64       // correlation between pacing rate and cwnd
	TotalRetransmits          uint32        // the value of tcpi_total_retrans from the kernel on the last sample
	BytesAcked                uint64        // bytes acked
	// delivery stats only available in 4.18 and later
	//Delivered                 uint32        // packets delivered
	//DeliveredCE               uint32        // packets delivered and acked with ECE
	SendThroughputMbps float64 // mean send throughput in Mbps
}

type ID struct {
	SrcIP         net.IP
	SrcPort       uint16
	DstIP         net.IP
	DstPort       uint16
	TstampStartNs uint64
}

type Metrics struct {
	AnalyzeTimes metrics.DurationStats
	sync.RWMutex
}