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"`
	URL                string        `env:"URL"`
	Driver             string        `env:"DRIVER"`
	Duration           time.Duration `env:"DURATION"`
	Retries            int           `env:"RETRIES"`
	QueryTimeout       time.Duration `env:"QUERY_TIMEOUT"`
	Debug              bool          `env:"DEBUG"`
	Sensitive          bool          `env:"SENSITIVE"`
	AverageWindowSize  int           `env:"AVERAGE_WINDOW_SIZE"`
	NoColor            bool          `env:"NO_COLOR"`
	ConnectionLifetime time.Duration `env:"CONNECTION_LIFETIME"`
}

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

type FieldMissingErr struct {
	Name string
}

type LatLon struct {
	Lat float64
	Lon float64
}

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"`
}