provideroptimizer

Oct 17, 2024

Changes in this version

type ProviderOptimizer

+ func (po *ProviderOptimizer) CalculateQoSScoresForMetrics(allAddresses []string, ignoredProviders map[string]struct{}, cu uint64, ...) []*metrics.OptimizerQoSReport

type SelectionTier

+ GetRawScores func() []Entry

type SelectionTierInst

+ func (st *SelectionTierInst) GetRawScores() []Entry

Sep 15, 2024

Changes in this version

+ var ATierChance = 0.75

+ var LastTierChance = 0.0

+ var MinimumEntries = 5

+ var OptimizerNumTiers = 4

+ type Entry struct

+ Address string

+ Part float64

+ Score float64

+ type Exploration struct

type ProviderOptimizer

+ OptimizerNumTiers int

+ func (po *ProviderOptimizer) CalculateSelectionTiers(allAddresses []string, ignoredProviders map[string]struct{}, cu uint64, ...) (SelectionTier, Exploration)

+ func (po *ProviderOptimizer) UpdateWeights(weights map[string]int64)

+ type SelectionTier interface

+ AddScore func(entry string, score float64)

+ GetTier func(tier int, numTiers int, minimumEntries int) []Entry

+ ScoresCount func() int

+ SelectTierRandomly func(numTiers int, tierChances map[int]float64) int

+ ShiftTierChance func(numTiers int, initialYierChances map[int]float64) map[int]float64

+ func NewSelectionTier() SelectionTier

+ type SelectionTierInst struct

+ func (st *SelectionTierInst) AddScore(entry string, score float64)

+ func (st *SelectionTierInst) GetTier(tier int, numTiers int, minimumEntries int) []Entry

+ func (st *SelectionTierInst) ScoresCount() int

+ func (st *SelectionTierInst) SelectTierRandomly(numTiers int, tierChances map[int]float64) int

+ func (st *SelectionTierInst) ShiftTierChance(numTiers int, initialTierChances map[int]float64) map[int]float64

+ type SelectionWeighter interface

+ SetWeights func(weights map[string]int64)

+ Weight func(address string) int64

+ WeightedChoice func(possibilities []Entry) string

+ func NewSelectionWeighter() SelectionWeighter

Sep 1, 2024

Changes in this version

+ const COST_EXPLORATION_CHANCE

+ const CacheMaxCost

+ const CacheNumCounters

+ const DEFAULT_EXPLORATION_CHANCE

+ const HALF_LIFE_TIME

+ const INITIAL_DATA_STALENESS

+ const MAX_HALF_TIME

+ const PROBE_UPDATE_WEIGHT

+ const RELAY_UPDATE_WEIGHT

+ const WANTED_PRECISION

+ func CumulativeProbabilityFunctionForPoissonDist(k_events uint64, lambda float64) float64

+ type ConcurrentBlockStore struct

+ Block uint64

+ Lock sync.Mutex

+ Time time.Time

+ type ProviderData struct

+ Availability score.ScoreStore

+ Latency score.ScoreStore

+ LatencyRaw score.ScoreStore

+ Sync score.ScoreStore

+ SyncBlock uint64

+ SyncRaw score.ScoreStore

+ type ProviderOptimizer struct

+ func NewProviderOptimizer(strategy Strategy, averageBlockTIme, baseWorldLatency time.Duration, ...) *ProviderOptimizer

+ func (po *ProviderOptimizer) AppendProbeRelayData(providerAddress string, latency time.Duration, success bool)

+ func (po *ProviderOptimizer) AppendRelayData(providerAddress string, latency time.Duration, isHangingApi bool, ...)

+ func (po *ProviderOptimizer) AppendRelayFailure(providerAddress string)

+ func (po *ProviderOptimizer) CalculateProbabilityOfBlockError(requestedBlock int64, providerData ProviderData) float64

+ func (po *ProviderOptimizer) CalculateProbabilityOfTimeout(availabilityScore score.ScoreStore) float64

+ func (po *ProviderOptimizer) ChooseProvider(allAddresses []string, ignoredProviders map[string]struct{}, cu uint64, ...) (addresses []string)

+ func (po *ProviderOptimizer) GetExcellenceQoSReportForProvider(providerAddress string) (qosReport *pairingtypes.QualityOfServiceReport, ...)

+ func (po *ProviderOptimizer) Strategy() Strategy

+ type Strategy int

+ const STRATEGY_ACCURACY

+ const STRATEGY_BALANCED

+ const STRATEGY_COST

+ const STRATEGY_DISTRIBUTED

+ const STRATEGY_LATENCY

+ const STRATEGY_PRIVACY

+ const STRATEGY_SYNC_FRESHNESS