rate

Documentation

Index

• Constants
• type AnnounceRateControl
  • func NewAnnounceRateControl(target float64, grace int, penalty float64) *AnnounceRateControl
  • func (arc *AnnounceRateControl) AllowAnnounce(destHash string) bool
• type IngressControl
  • func NewIngressControl(enabled bool) *IngressControl
  • func (ic *IngressControl) ProcessAnnounce(announceHash string, announceData []byte, isNewDest bool) bool
  • func (ic *IngressControl) ReleaseHeldAnnounce() (string, []byte, bool)
• type Limiter
  • func NewLimiter(rate float64, interval time.Duration) *Limiter
  • func (l *Limiter) Allow() bool

Constants

const (
	DefaultAnnounceRateTarget  = 3600.0 // Default 1 hour between announces
	DefaultAnnounceRateGrace   = 3      // Default number of grace announces
	DefaultAnnounceRatePenalty = 7200.0 // Default 2 hour penalty
	DefaultBurstFreqNew        = 3.5    // Default announces/sec for new interfaces
	DefaultBurstFreq           = 12.0   // Default announces/sec for established interfaces
	DefaultBurstHold           = 60     // Default seconds to hold after burst
	DefaultBurstPenalty        = 300    // Default seconds penalty after burst
	DefaultMaxHeldAnnounces    = 256    // Default max announces in hold queue
	DefaultHeldReleaseInterval = 30     // Default seconds between releasing held announces
)

Types

type AnnounceRateControl

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

AnnounceRateControl handles per-destination announce rate limiting

func NewAnnounceRateControl

func NewAnnounceRateControl(target float64, grace int, penalty float64) *AnnounceRateControl

func (*AnnounceRateControl) AllowAnnounce

func (arc *AnnounceRateControl) AllowAnnounce(destHash string) bool

type IngressControl

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

IngressControl handles new destination announce rate limiting

func NewIngressControl

func NewIngressControl(enabled bool) *IngressControl

func (*IngressControl) ProcessAnnounce

func (ic *IngressControl) ProcessAnnounce(announceHash string, announceData []byte, isNewDest bool) bool

func (*IngressControl) ReleaseHeldAnnounce

func (ic *IngressControl) ReleaseHeldAnnounce() (string, []byte, bool)

type Limiter

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

func NewLimiter

func NewLimiter(rate float64, interval time.Duration) *Limiter

func (*Limiter) Allow

func (l *Limiter) Allow() bool