tieredhashing

Sep 13, 2023

Changes in this version

type NodeInfo

+ Core bool

type TieredHashing

+ func (t *TieredHashing) IsCore(n string) bool

Aug 24, 2023

Changes in this version

type TieredHashing

+ LastAverageCalcAt time.Time

Aug 1, 2023

Changes in this version

type Option

+ func WithCorrectnessThreshold(pct float64) Option

type TieredHashing

+ AverageCorrectnessPct float64

+ NOverAllCorrectnessDigest float64

+ OverAllCorrectnessDigest *rolling.PointPolicy

+ func (t *TieredHashing) UpdateAverageCorrectnessPct()

type TieredHashingConfig

+ CorrectnessThreshold float64

Jul 11, 2023

Changes in this version

+ type NodeInfo struct

+ ComplianceCid string

+ Distance float32

+ ID string

+ IP string

+ Weight int

type TieredHashing

+ func (t *TieredHashing) GetComplianceCid(ip string) (string, error)

May 24, 2023

Changes in this version

+ const PMaxLatencyWithoutWindowing

+ const TierMain

+ const TierUnknown

type Option

+ func WithNoRemove(noRemove bool) Option

+ type Tier string

type TieredHashing

+ func (t *TieredHashing) MoveBestUnknownToMain() int

+ func (t *TieredHashing) NodeTier(node string) Tier

type TieredHashingConfig

+ NoRemove bool

May 2, 2023

Changes in this version

+ const PLatency

+ type NodePerf struct

+ CorrectnessDigest *rolling.PointPolicy

+ LatencyDigest *rolling.PointPolicy

+ NCorrectnessDigest float64

+ NLatencyDigest float64

+ Tier string

+ type Option func(config *TieredHashingConfig)

+ func WithAlwaysMainFirst() Option

+ func WithCorrectnessPct(pct float64) Option

+ func WithCorrectnessWindowSize(n int) Option

+ func WithFailureDebounce(n time.Duration) Option

+ func WithLatencyWindowSize(n int) Option

+ func WithMaxMainTierSize(n int) Option

+ func WithMaxPoolSize(n int) Option

+ type PoolMetrics struct

+ Main int

+ Total int

+ Unknown int

+ type RemovedNode struct

+ ConnErrors int

+ MainToUnknownChange int

+ NetworkErrors int

+ Node string

+ Reason string

+ ResponseCodes int

+ ResponseCodesMap map[int]int

+ Tier string

+ UnknownToMainChange int

+ type ResponseMetrics struct

+ ConnFailure bool

+ NetworkError bool

+ ResponseCode int

+ SpeedPerMs float64

+ Success bool

+ TTFBMs float64

+ type TieredHashing struct

+ StartAt time.Time

+ func New(opts ...Option) *TieredHashing

+ func (t *TieredHashing) AddOrchestratorNodes(nodes []string) (added, alreadyRemoved int)

+ func (t *TieredHashing) DoRefresh() bool

+ func (t *TieredHashing) GetNodes(key string, n int) []string

+ func (t *TieredHashing) GetPerf() map[string]*NodePerf

+ func (t *TieredHashing) GetPoolMetrics() PoolMetrics

+ func (t *TieredHashing) IsInitDone() bool

+ func (t *TieredHashing) RecordFailure(node string, rm ResponseMetrics) *RemovedNode

+ func (t *TieredHashing) RecordSuccess(node string, rm ResponseMetrics)

+ func (t *TieredHashing) UpdateMainTierWithTopN() (mainToUnknown, unknownToMain int)

+ type TieredHashingConfig struct

+ AlwaysMainFirst bool

+ CorrectnessPct float64

+ CorrectnessWindowSize int

+ FailureDebounce time.Duration

+ LatencyWindowSize int

+ MaxMainTierSize int

+ MaxPoolSize int