tieredhashing

type NodeInfo struct {
	ID            string  `json:"id"`
	IP            string  `json:"ip"`
	Distance      float32 `json:"distance"`
	Weight        int     `json:"weight"`
	ComplianceCid string  `json:"complianceCid"`
	Core          bool    `json:"core"`
}

type NodePerf struct {
	LatencyDigest  *rolling.PointPolicy
	NLatencyDigest float64

	CorrectnessDigest  *rolling.PointPolicy
	NCorrectnessDigest float64

	Tier

	// Node Info
	NodeInfo
	// contains filtered or unexported fields
}

type Option func(config *TieredHashingConfig)

type PoolMetrics struct {
	Unknown int
	Main    int
	Total   int
}

type RemovedNode struct {
	Node string
	Tier
	Reason              string
	ConnErrors          int
	NetworkErrors       int
	ResponseCodes       int
	MainToUnknownChange int
	UnknownToMainChange int
	ResponseCodesMap    map[int]int
}

type ResponseMetrics struct {
	ConnFailure  bool
	NetworkError bool
	ResponseCode int

	Success bool

	TTFBMs     float64
	SpeedPerMs float64
}

type Tier string

type TieredHashing struct {
	StartAt time.Time

	OverAllCorrectnessDigest  *rolling.PointPolicy
	NOverAllCorrectnessDigest float64
	AverageCorrectnessPct     float64

	LastAverageCalcAt time.Time
	// contains filtered or unexported fields
}

type TieredHashingConfig struct {
	MaxPoolSize           int
	AlwaysMainFirst       bool
	FailureDebounce       time.Duration
	LatencyWindowSize     int
	CorrectnessWindowSize int
	MaxMainTierSize       int
	NoRemove              bool
	CorrectnessThreshold  float64
}