staged

Documentation

Index

• func CalculateStagedRate(jitterArg float64, frequency time.Duration, stg string, ...) (*api.Rates, error)
• func Rate() api.Builder
• type RateCalculator
  • func NewRateCalculator(stages []Stage, start *time.Time) *RateCalculator
  • func (s *RateCalculator) MaxDuration() time.Duration
  • func (s *RateCalculator) Rate(now time.Time) int
• type Stage
  • func ParseStages(value string) ([]Stage, error)

Functions

func CalculateStagedRate

func CalculateStagedRate(
	jitterArg float64,
	frequency time.Duration,
	stg string,
	distributionTypeArg string,
	startTime *time.Time,
) (*api.Rates, error)

func Rate

func Rate() api.Builder

Types

type RateCalculator

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

func NewRateCalculator

func NewRateCalculator(stages []Stage, start *time.Time) *RateCalculator

func (*RateCalculator) MaxDuration

func (s *RateCalculator) MaxDuration() time.Duration

func (*RateCalculator) Rate

func (s *RateCalculator) Rate(now time.Time) int

type Stage

type Stage struct {
	StartTarget int
	EndTarget   int
	Duration    time.Duration
}

func ParseStages

func ParseStages(value string) ([]Stage, error)