Versions in this module Expand all Collapse all v0 v0.0.2 Dec 9, 2023 Changes in this version + const DefaultIterations + const DefaultMaxConcurrent + func GetScenarios() map[string]*Scenario + func MustRegisterScenario(scenario Scenario) + func TaskQueueForRun(scenarioName, runID string) string + func VisibilityCountIsEventually(ctx context.Context, client client.Client, ...) error + type Executor interface + Run func(context.Context, ScenarioInfo) error + type ExecutorFunc func(context.Context, ScenarioInfo) error + func (e ExecutorFunc) Run(ctx context.Context, info ScenarioInfo) error + type FileOrArgs struct + Args []string + FilePath string + type FuzzExecutor struct + DefaultConfiguration RunConfiguration + InitInputs func(context.Context, ScenarioInfo) FileOrArgs + func (k FuzzExecutor) GetDefaultConfiguration() RunConfiguration + func (k FuzzExecutor) Run(ctx context.Context, info ScenarioInfo) error + type GenericExecutor struct + DefaultConfiguration RunConfiguration + Execute func(context.Context, *Run) error + func (g *GenericExecutor) GetDefaultConfiguration() RunConfiguration + func (g *GenericExecutor) Run(ctx context.Context, info ScenarioInfo) error + type HasDefaultConfiguration interface + GetDefaultConfiguration func() RunConfiguration + type KitchenSinkExecutor struct + DefaultConfiguration RunConfiguration + PrepareTestInput func(context.Context, ScenarioInfo, *kitchensink.TestInput) error + TestInput *kitchensink.TestInput + UpdateWorkflowOptions func(context.Context, *Run, *KitchenSinkWorkflowOptions) error + func (k KitchenSinkExecutor) GetDefaultConfiguration() RunConfiguration + func (k KitchenSinkExecutor) Run(ctx context.Context, info ScenarioInfo) error + type KitchenSinkWorkflowOptions struct + Params *kitchensink.TestInput + StartOptions client.StartWorkflowOptions + type Run struct + Iteration int + Logger *zap.SugaredLogger + func (r *Run) DefaultKitchenSinkWorkflowOptions() KitchenSinkWorkflowOptions + func (r *Run) DefaultStartWorkflowOptions() client.StartWorkflowOptions + func (r *Run) ExecuteAnyWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) error + func (r *Run) ExecuteKitchenSinkWorkflow(ctx context.Context, options *KitchenSinkWorkflowOptions) error + func (r *Run) TaskQueue() string + type RunConfiguration struct + Duration time.Duration + Iterations int + MaxConcurrent int + func (r *RunConfiguration) ApplyDefaults() + type Scenario struct + Description string + Executor Executor + func GetScenario(name string) *Scenario + type ScenarioInfo struct + Client client.Client + Configuration RunConfiguration + Logger *zap.SugaredLogger + MetricsHandler client.MetricsHandler + Namespace string + RootPath string + RunID string + ScenarioName string + ScenarioOptions map[string]string + func (s *ScenarioInfo) NewRun(iteration int) *Run + func (s *ScenarioInfo) ScenarioOptionInt(name string, defaultValue int) int