jepsen

Documentation

Index

• type Config
  • func (c Config) Validate() error
• type Runner
  • func NewRunner(ctx context.Context, config Config) *Runner
  • func (r *Runner) Start(ctx context.Context) error
  • func (r *Runner) Stop()

Types

type Config

type Config struct {
	RunId           int           `validate:"required"`
	ClusterName     string        `validate:"required,maxLen:100"`
	SocketPath      string        `validate:"exists:socket"`
	OutputDir       string        `validate:"notExists"`
	Concurrency     int           `validate:"min:1"`
	Duration        time.Duration `validate:"min:1s"`
	ReadWriteRatio  float64       `validate:"min:0.1,max:10"`
	RequestRate     int           `validate:"min:1,max:1000"` // per second
	RequestMinKeys  int           `validate:"min:1,max:100"`
	RequestMaxKeys  int           `validate:"min:1,max:100"`
	NemesisDelay    time.Duration `validate:"min:1s"`
	NemesisInterval time.Duration `validate:"min:1s"`
	SlowDown        time.Duration `validate:"min:1ms"`
	NemesisEnabled  []string
	TruncateLogs    bool
}

func (Config) Validate

func (c Config) Validate() error

type Runner

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

func NewRunner

func NewRunner(ctx context.Context, config Config) *Runner

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) error

func (*Runner) Stop

func (r *Runner) Stop()