schedule

Documentation

Index

• func NewComposite(scheds ...core.Schedule) core.Schedule
• func NewCompositeConf(conf CompositeConf) core.Schedule
• func NewConst(ops float64, duration time.Duration) core.Schedule
• func NewConstConf(conf ConstConfig) core.Schedule
• func NewDoAtSchedule(duration time.Duration, n int64, doAt DoAt) core.Schedule
• func NewInstanceStep(from, to int64, step int64, stepDuration time.Duration) core.Schedule
• func NewInstanceStepConf(conf InstanceStepConfig) core.Schedule
• func NewLine(from, to float64, duration time.Duration) core.Schedule
• func NewLineConf(conf LineConfig) core.Schedule
• func NewOnce(n int64) core.Schedule
• func NewOnceConf(conf OnceConfig) core.Schedule
• func NewStep(from, to float64, step int64, duration time.Duration) core.Schedule
• func NewStepConf(conf StepConfig) core.Schedule
• func NewUnlimited(duration time.Duration) core.Schedule
• func NewUnlimitedConf(conf UnlimitedConfig) core.Schedule
• type CompositeConf
• type ConstConfig
• type DoAt
• type InstanceStepConfig
• type LineConfig
• type OnceConfig
• type StartSync
  • func (s *StartSync) IsStarted() bool
  • func (s *StartSync) MarkStarted()
• type StepConfig
• type UnlimitedConfig

Functions

func NewComposite

func NewComposite(scheds ...core.Schedule) core.Schedule

func NewCompositeConf

func NewCompositeConf(conf CompositeConf) core.Schedule

func NewConst

func NewConst(ops float64, duration time.Duration) core.Schedule

func NewConstConf

func NewConstConf(conf ConstConfig) core.Schedule

func NewDoAtSchedule

func NewDoAtSchedule(duration time.Duration, n int64, doAt DoAt) core.Schedule

func NewInstanceStep

func NewInstanceStep(from, to int64, step int64, stepDuration time.Duration) core.Schedule

func NewInstanceStepConf

func NewInstanceStepConf(conf InstanceStepConfig) core.Schedule

func NewLine

func NewLine(from, to float64, duration time.Duration) core.Schedule

func NewLineConf

func NewLineConf(conf LineConfig) core.Schedule

func NewOnce

func NewOnce(n int64) core.Schedule

NewOnce returns schedule that emits all passed operation token at start time. That is, is schedule for zero duration, unlimited RPS, and n operations.

func NewOnceConf

func NewOnceConf(conf OnceConfig) core.Schedule

func NewStep

func NewStep(from, to float64, step int64, duration time.Duration) core.Schedule

func NewStepConf

func NewStepConf(conf StepConfig) core.Schedule

func NewUnlimited

func NewUnlimited(duration time.Duration) core.Schedule

NewUnlimited returns schedule that generates unlimited ops for passed duration.

func NewUnlimitedConf

func NewUnlimitedConf(conf UnlimitedConfig) core.Schedule

Types

type CompositeConf

type CompositeConf struct {
	Nested []core.Schedule `config:"nested"`
}

type ConstConfig

type ConstConfig struct {
	Ops      float64       `validate:"min=0"`
	Duration time.Duration `validate:"min-time=1ms"`
}

type DoAt

type DoAt func(i int64) time.Duration

DoAt returns when i'th operation should be performed, assuming that schedule started at 0.

type InstanceStepConfig

type InstanceStepConfig struct {
	From         int64         `validate:"min=0"`
	To           int64         `validate:"min=0"`
	Step         int64         `validate:"min=1"`
	StepDuration time.Duration `validate:"min-time=1ms"`
}

type LineConfig

type LineConfig struct {
	From     float64       `validate:"min=0"`
	To       float64       `validate:"min=0"`
	Duration time.Duration `validate:"min-time=1ms"`
}

type OnceConfig

type OnceConfig struct {
	Times int64 `validate:"min=1"` // N is decoded like bool
}

type StartSync

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

StartSync is util to make schedule start goroutine safe. See doAtSchedule as example.

func (*StartSync) IsStarted

func (s *StartSync) IsStarted() bool

func (*StartSync) MarkStarted

func (s *StartSync) MarkStarted()

type StepConfig

type StepConfig struct {
	From     float64       `validate:"min=0"`
	To       float64       `validate:"min=0"`
	Step     int64         `validate:"min=1"`
	Duration time.Duration `validate:"min-time=1ms"`
}

type UnlimitedConfig

type UnlimitedConfig struct {
	Duration time.Duration `validate:"min-time=1ms"`
}