reputation

Mar 12, 2026

Changes in this version

type ReputationService

+ GetArchivalEndpoints func(ctx context.Context, serviceID protocol.ServiceID) []EndpointKey

+ GetEndpointBlockHeights func(ctx context.Context, serviceID protocol.ServiceID) map[protocol.EndpointAddr]uint64

+ GetPerceivedBlockNumber func(ctx context.Context, serviceID protocol.ServiceID) uint64

+ IsArchivalCapable func(ctx context.Context, key EndpointKey) bool

+ RankEndpointsByScore func(ctx context.Context, keys []EndpointKey) ([]EndpointKey, error)

+ RemoveEndpointBlockHeights func(ctx context.Context, serviceID protocol.ServiceID, ...) error

+ SetArchivalStatus func(ctx context.Context, key EndpointKey, isArchival bool, ...) error

+ SetEndpointBlockHeight func(ctx context.Context, serviceID protocol.ServiceID, ...) error

+ SetPerceivedBlockNumber func(ctx context.Context, serviceID protocol.ServiceID, blockNumber uint64) error

type Score

+ ArchivalExpiresAt time.Time

+ IsArchival bool

+ func (s Score) ArchivalRemaining() time.Duration

+ func (s Score) IsArchivalCapable() bool

type Storage

+ GetEndpointBlockHeights func(ctx context.Context, serviceID protocol.ServiceID) (map[protocol.EndpointAddr]uint64, error)

+ GetPerceivedBlockNumber func(ctx context.Context, serviceID protocol.ServiceID) (uint64, error)

+ RemoveEndpointBlockHeights func(ctx context.Context, serviceID protocol.ServiceID, ...) error

+ SetEndpointBlockHeight func(ctx context.Context, serviceID protocol.ServiceID, ...) error

+ SetPerceivedBlockNumber func(ctx context.Context, serviceID protocol.ServiceID, blockNumber uint64) error

Jan 22, 2026

Changes in this version

+ const DefaultBaseCooldown

+ const DefaultMaxCooldown

+ const DefaultStrikeThreshold

type Score

+ CooldownUntil time.Time

+ CriticalStrikes int

+ func (s Score) CooldownRemaining() time.Duration

+ func (s Score) IsInCooldown() bool

Jan 13, 2026

Changes in this version

+ const DefaultFastBonus

+ const DefaultLatencyFastThreshold

+ const DefaultLatencyNormalThreshold

+ const DefaultLatencyPenaltyThreshold

+ const DefaultLatencySevereThreshold

+ const DefaultLatencySlowThreshold

+ const DefaultSlowPenalty

+ const DefaultVerySlowPenalty

+ const LatencyProfileCosmos

+ const LatencyProfileEVM

+ const LatencyProfileGeneric

+ const LatencyProfileLLM

+ const LatencyProfileSolana

+ func DefaultLatencyProfiles() map[string]LatencyProfile

type Config

+ Latency LatencyConfig

+ SignalImpacts SignalImpactsConfig

+ func (c *Config) ResolveRecoveryConflict(healthChecksEnabled bool)

+ func (c *Config) ValidateRecoveryConfig(healthChecksEnabled bool) RecoveryConflictResult

type EndpointKey

+ RPCType sharedtypes.RPCType

+ type LatencyConfig struct

+ Enabled bool

+ FastBonus float64

+ FastThreshold time.Duration

+ NormalThreshold time.Duration

+ PenaltyThreshold time.Duration

+ ServiceProfiles map[string]LatencyProfile

+ SevereThreshold time.Duration

+ SlowPenalty float64

+ SlowThreshold time.Duration

+ VerySlowPenalty float64

+ func DefaultLatencyConfig() LatencyConfig

+ func (c *LatencyConfig) GetProfileForService(serviceID, profileName string) LatencyProfile

+ func (l *LatencyConfig) HydrateDefaults()

+ type LatencyImpactResult struct

+ BaseImpact float64

+ Config LatencyConfig

+ FinalImpact float64

+ Latency time.Duration

+ LatencyCategory string

+ Modifier float64

+ type LatencyMetrics struct

+ AvgLatency time.Duration

+ LastLatency time.Duration

+ LastUpdated time.Time

+ MaxLatency time.Duration

+ MinLatency time.Duration

+ SampleCount int64

+ func (m *LatencyMetrics) UpdateLatency(latency time.Duration)

+ type LatencyProfile struct

+ Description string

+ FastThreshold time.Duration

+ Name string

+ NormalThreshold time.Duration

+ PenaltyThreshold time.Duration

+ SevereThreshold time.Duration

+ SlowThreshold time.Duration

+ func (p LatencyProfile) ToLatencyConfig(baseConfig LatencyConfig) LatencyConfig

+ type ProbationConfig struct

+ Enabled bool

+ RecoveryMultiplier float64

+ Threshold float64

+ TrafficPercent float64

+ type RecoveryConflictResult struct

+ HasConflict bool

+ HasNoRecovery bool

+ Message string

+ OriginalRecoveryTimeout time.Duration

type ReputationService

+ GetInitialScoreForService func(serviceID protocol.ServiceID) float64

+ GetLatencyConfigForService func(serviceID protocol.ServiceID) LatencyConfig

+ GetMinThresholdForService func(serviceID protocol.ServiceID) float64

+ SetLatencyProfile func(serviceID protocol.ServiceID, latencyConfig LatencyConfig)

+ SetLogger func(logger polylog.Logger)

+ SetServiceConfig func(serviceID protocol.ServiceID, config ServiceConfig)

type Score

+ LatencyMetrics LatencyMetrics

type ServiceConfig

+ HealthChecksEnabled bool

+ InitialScore float64

+ MinThreshold float64

+ ProbationEnabled bool

+ RecoveryTimeout time.Duration

type Signal

+ func NewSlowResponseSignal(latency time.Duration) Signal

+ func NewVerySlowResponseSignal(latency time.Duration) Signal

+ func (s Signal) CalculateLatencyAwareImpact(config LatencyConfig) float64

+ func (s Signal) CalculateLatencyAwareImpactWithConfig(config LatencyConfig, baseImpact float64) LatencyImpactResult

+ func (s Signal) CalculateLatencyAwareImpactWithDetails(config LatencyConfig) LatencyImpactResult

+ func (s Signal) GetRecoveryMultiplier() float64

+ func (s Signal) WithMultiplier(multiplier float64) Signal

+ type SignalImpactsConfig struct

+ CriticalError float64

+ FatalError float64

+ MajorError float64

+ MinorError float64

+ RecoverySuccess float64

+ SlowResponse float64

+ Success float64

+ VerySlowResponse float64

+ func DefaultSignalImpacts() SignalImpactsConfig

+ func (c *SignalImpactsConfig) GetImpact(signalType SignalType) float64

type SignalType

+ const SignalTypeSlowResponse

+ const SignalTypeVerySlowResponse

+ func ClassifyLatency(latency time.Duration, config LatencyConfig) *SignalType

type TieredSelectionConfig

+ Probation ProbationConfig

type TieredSelector

+ func NewTieredSelectorWithLogger(logger polylog.Logger, config TieredSelectionConfig, minThreshold float64) *TieredSelector

+ func (s *TieredSelector) IsInProbation(key EndpointKey) bool

+ func (s *TieredSelector) SetLogger(logger polylog.Logger)

+ func (s *TieredSelector) ShouldRouteToProbation() bool

+ func (s *TieredSelector) UpdateProbationStatus(endpoints map[EndpointKey]float64) []EndpointKey

Dec 4, 2025

Changes in this version

+ const DefaultTier1Threshold

+ const DefaultTier2Threshold

+ var ErrNoEndpointsAvailable = errors.New("no endpoints available for selection")

type Config

+ TieredSelection TieredSelectionConfig

+ type TieredSelectionConfig struct

+ Enabled bool

+ Tier1Threshold float64

+ Tier2Threshold float64

+ func DefaultTieredSelectionConfig() TieredSelectionConfig

+ func (t *TieredSelectionConfig) HydrateDefaults()

+ func (t *TieredSelectionConfig) Validate(minThreshold float64) error

+ type TieredSelector struct

+ func NewTieredSelector(config TieredSelectionConfig, minThreshold float64) *TieredSelector

+ func (s *TieredSelector) Config() TieredSelectionConfig

+ func (s *TieredSelector) GroupByTier(endpoints map[EndpointKey]float64) (tier1, tier2, tier3 []EndpointKey)

+ func (s *TieredSelector) MinThreshold() float64

+ func (s *TieredSelector) SelectEndpoint(endpoints map[EndpointKey]float64) (EndpointKey, int, error)

+ func (s *TieredSelector) TierForScore(score float64) int

Dec 4, 2025

Changes in this version

+ const KeyGranularityDomain

+ const KeyGranularityEndpoint

+ const KeyGranularitySupplier

type Config

+ KeyGranularity string

+ ServiceOverrides map[string]ServiceConfig

+ type DomainKeyBuilder struct

+ func (b *DomainKeyBuilder) BuildKey(serviceID protocol.ServiceID, endpointAddr protocol.EndpointAddr) EndpointKey

+ type EndpointKeyBuilder struct

+ func (b *EndpointKeyBuilder) BuildKey(serviceID protocol.ServiceID, endpointAddr protocol.EndpointAddr) EndpointKey

+ type KeyBuilder interface

+ BuildKey func(serviceID protocol.ServiceID, endpointAddr protocol.EndpointAddr) EndpointKey

+ func NewKeyBuilder(granularity string) KeyBuilder

type ReputationService

+ KeyBuilderForService func(serviceID protocol.ServiceID) KeyBuilder

+ type ServiceConfig struct

+ KeyGranularity string

+ type SupplierKeyBuilder struct

+ func (b *SupplierKeyBuilder) BuildKey(serviceID protocol.ServiceID, endpointAddr protocol.EndpointAddr) EndpointKey

Dec 2, 2025

Changes in this version

+ const DefaultFlushInterval

+ const DefaultMinThreshold

+ const DefaultRecoveryTimeout

+ const DefaultRefreshInterval

+ const DefaultWriteBufferSize

+ const InitialScore

+ const MaxScore

+ const MinScore

+ var ErrNotFound = errors.New("endpoint score not found")

+ var ErrStorageClosed = errors.New("storage is closed")

+ func GetScoreImpact(t SignalType) float64

+ type Cleaner interface

+ Cleanup func()

+ type Config struct

+ Enabled bool

+ InitialScore float64

+ MinThreshold float64

+ RecoveryTimeout time.Duration

+ Redis *RedisConfig

+ StorageType string

+ SyncConfig SyncConfig

+ func DefaultConfig() Config

+ func (c *Config) HydrateDefaults()

+ func (c *Config) Validate() error

+ type EndpointKey struct

+ EndpointAddr protocol.EndpointAddr

+ ServiceID protocol.ServiceID

+ func NewEndpointKey(serviceID protocol.ServiceID, endpointAddr protocol.EndpointAddr) EndpointKey

+ func (k EndpointKey) String() string

+ type RedisConfig struct

+ Address string

+ DB int

+ DialTimeout time.Duration

+ KeyPrefix string

+ Password string

+ PoolSize int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func DefaultRedisConfig() RedisConfig

+ func (c *RedisConfig) HydrateDefaults()

+ type ReputationService interface

+ FilterByScore func(ctx context.Context, keys []EndpointKey, minThreshold float64) ([]EndpointKey, error)

+ GetScore func(ctx context.Context, key EndpointKey) (Score, error)

+ GetScores func(ctx context.Context, keys []EndpointKey) (map[EndpointKey]Score, error)

+ RecordSignal func(ctx context.Context, key EndpointKey, signal Signal) error

+ ResetScore func(ctx context.Context, key EndpointKey) error

+ Start func(ctx context.Context) error

+ Stop func() error

+ func NewService(config Config, store Storage) ReputationService

+ type Score struct

+ ErrorCount int64

+ LastUpdated time.Time

+ SuccessCount int64

+ Value float64

+ func (s Score) IsValid() bool

+ type Signal struct

+ Latency time.Duration

+ Metadata map[string]string

+ Reason string

+ Timestamp time.Time

+ Type SignalType

+ func NewCriticalErrorSignal(reason string, latency time.Duration) Signal

+ func NewFatalErrorSignal(reason string) Signal

+ func NewMajorErrorSignal(reason string, latency time.Duration) Signal

+ func NewMinorErrorSignal(reason string) Signal

+ func NewRecoverySuccessSignal(latency time.Duration) Signal

+ func NewSuccessSignal(latency time.Duration) Signal

+ func (s Signal) GetDefaultImpact() float64

+ func (s Signal) IsNegative() bool

+ func (s Signal) IsPositive() bool

+ type SignalType string

+ const SignalTypeCriticalError

+ const SignalTypeFatalError

+ const SignalTypeMajorError

+ const SignalTypeMinorError

+ const SignalTypeRecoverySuccess

+ const SignalTypeSuccess

+ type Storage interface

+ Close func() error

+ Delete func(ctx context.Context, key EndpointKey) error

+ Get func(ctx context.Context, key EndpointKey) (Score, error)

+ GetMultiple func(ctx context.Context, keys []EndpointKey) (map[EndpointKey]Score, error)

+ List func(ctx context.Context, serviceID string) ([]EndpointKey, error)

+ Set func(ctx context.Context, key EndpointKey, score Score) error

+ SetMultiple func(ctx context.Context, scores map[EndpointKey]Score) error

+ type SyncConfig struct

+ FlushInterval time.Duration

+ RefreshInterval time.Duration

+ WriteBufferSize int

+ func DefaultSyncConfig() SyncConfig

+ func (s *SyncConfig) HydrateDefaults()