model

type Arg struct {
	Type string `yaml:"type"`
	// contains filtered or unexported fields
}

type Drk struct {
	GlobalArgs  map[string]Arg        `yaml:"args"`
	EnvMappings map[string]EnvMapping `yaml:"arg_mappings"`
	Workflows   map[string]Workflow   `yaml:"workflows"`
	Activities  map[string]Query      `yaml:"activities"`
}

type EnvMapping map[string]string

type EnvironmentVariables struct {
	Config            string        `env:"CONFIG,required"`
	URL               string        `env:"URL,required"`
	Driver            string        `env:"DRIVER"`
	Duration          time.Duration `env:"DURATION"`
	Retries           int           `env:"RETRIES"`
	QueryTimeout      time.Duration `env:"QUERY_TIMEOUT"`
	Debug             bool          `env:"DEBUG"`
	AverageWindowSize int           `env:"AVERAGE_WINDOW_SIZE"`
}

type Event struct {
	Workflow string
	Name     string
	Duration time.Duration
	Err      error
}

type FieldMissingErr struct {
	Name string
}

type Query struct {
	Type  string `yaml:"type"`
	Args  []Arg  `yaml:"args"`
	Query string `yaml:"query"`
}

type Rate struct {
	Times    int
	Interval time.Duration
	// contains filtered or unexported fields
}

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

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

type Workflow struct {
	Vus          int             `yaml:"vus"`
	SetupQueries []string        `yaml:"setup_queries"`
	Queries      []WorkflowQuery `yaml:"queries"`
	RunAfter     time.Duration   `yaml:"run_after"`
	RunFor       time.Duration   `yaml:"run_for"`
	RampFor      time.Duration   `yaml:"ramp_for"`
}

type WorkflowQuery struct {
	Name string `yaml:"name"`
	Rate Rate   `yaml:"rate"`
}