throughput_v2

Documentation

Index

• type PathEMAMock
  • func (p *PathEMAMock) GetEMAOrDefault(fp oracle.PathFingerprint, def float64) float64
  • func (p *PathEMAMock) Update(val float64, fp oracle.PathFingerprint)
• type PathEMAService
  • func NewPathEMAService(smoothing float64, logger *zap.SugaredLogger) PathEMAService
  • func (p *PathEMAService) GetEMAOrDefault(fp oracle.PathFingerprint, def float64) float64
  • func (p *PathEMAService) Update(val float64, fp oracle.PathFingerprint)
• type PathEMAServiceI
• type ScoringService
  • func New(moniRouter *mux.Router, connector querier.PathQuerier, ...) *ScoringService
  • func (s *ScoringService) GetScores(dst addr.IA) services.PathScorings
  • func (s *ScoringService) Name() services.ServiceName
  • func (s *ScoringService) OnStatsReceived(report oracle.Report, path snet.Path)

Types

type PathEMAMock

type PathEMAMock struct {
	mock.Mock
}

func (*PathEMAMock) GetEMAOrDefault

func (p *PathEMAMock) GetEMAOrDefault(fp oracle.PathFingerprint, def float64) float64

func (*PathEMAMock) Update

func (p *PathEMAMock) Update(val float64, fp oracle.PathFingerprint)

type PathEMAService

type PathEMAService struct {
	// contains filtered or unexported fields
}

func NewPathEMAService

func NewPathEMAService(smoothing float64, logger *zap.SugaredLogger) PathEMAService

func (*PathEMAService) GetEMAOrDefault

func (p *PathEMAService) GetEMAOrDefault(fp oracle.PathFingerprint, def float64) float64

func (*PathEMAService) Update

func (p *PathEMAService) Update(val float64, fp oracle.PathFingerprint)

type PathEMAServiceI

type PathEMAServiceI interface {
	Update(val float64, fp oracle.PathFingerprint)
	GetEMAOrDefault(fp oracle.PathFingerprint, def float64) float64
}

type ScoringService

type ScoringService struct {
	// contains filtered or unexported fields
}

func New

func New(moniRouter *mux.Router, connector querier.PathQuerier, slogger *zap.SugaredLogger) *ScoringService

func (*ScoringService) GetScores

func (s *ScoringService) GetScores(dst addr.IA) services.PathScorings

func (*ScoringService) Name

func (s *ScoringService) Name() services.ServiceName

func (*ScoringService) OnStatsReceived

func (s *ScoringService) OnStatsReceived(report oracle.Report, path snet.Path)