generators

package

v0.3.5 Latest Latest Go to latest Published: Jan 24, 2023 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CycleGen struct {
	Gens []jepsen.Generator
	// contains filtered or unexported fields
}

func Cycle(gens ...jepsen.Generator) *CycleGen

func (c *CycleGen) Actions() *types.Channel[*strategies.Action]

func (c *CycleGen) Done() chan struct{}

func (c *CycleGen) Reset(ctx *strategies.Context) error

func (c *CycleGen) Start(ctx *strategies.Context) error

func (c *CycleGen) Stop(ctx *strategies.Context) error

type StaggeredGen struct {
	jepsen.Generator
	StaggeredDuration time.Duration
	// contains filtered or unexported fields
}

func Staggered(d time.Duration, gen jepsen.Generator) *StaggeredGen

func (s *StaggeredGen) Actions() *types.Channel[*strategies.Action]

func (s *StaggeredGen) Reset(c *strategies.Context) error

func (s *StaggeredGen) Start(c *strategies.Context) error

type TimeLimitGen struct {
	Limit time.Duration
	jepsen.Generator
	// contains filtered or unexported fields
}

func TimeLimit(d time.Duration, gen jepsen.Generator) *TimeLimitGen

func (t *TimeLimitGen) Done() chan struct{}

func (t *TimeLimitGen) Reset(c *strategies.Context) error

func (t *TimeLimitGen) Start(c *strategies.Context) error

func (t *TimeLimitGen) Stop(c *strategies.Context) error