Documentation ¶
Index ¶
- type ChaosExperimentRunHandler
- func (c *ChaosExperimentRunHandler) ChaosExperimentRunEvent(event model.ExperimentRunRequest) (string, error)
- func (c *ChaosExperimentRunHandler) GetExperimentRun(ctx context.Context, projectID string, experimentRunID *string, ...) (*model.ExperimentRun, error)
- func (c *ChaosExperimentRunHandler) GetExperimentRunStats(ctx context.Context, projectID string) (*model.GetExperimentRunStatsResponse, error)
- func (c *ChaosExperimentRunHandler) ListExperimentRun(projectID string, request model.ListExperimentRunRequest) (*model.ListExperimentRunResponse, error)
- func (c *ChaosExperimentRunHandler) RunChaosWorkFlow(ctx context.Context, projectID string, ...) (*model.RunChaosExperimentResponse, error)
- func (c *ChaosExperimentRunHandler) RunCronExperiment(ctx context.Context, projectID string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChaosExperimentRunHandler ¶
type ChaosExperimentRunHandler struct {
// contains filtered or unexported fields
}
ChaosExperimentRunHandler is the handler for chaos experiment
func NewChaosExperimentRunHandler ¶
func NewChaosExperimentRunHandler( chaosExperimentRunService types.Service, infrastructureService chaos_infrastructure.Service, gitOpsService gitops.Service, chaosExperimentOperator *dbChaosExperiment.Operator, chaosExperimentRunOperator *dbChaosExperimentRun.Operator, mongodbOperator mongodb.MongoOperator, ) *ChaosExperimentRunHandler
NewChaosExperimentRunHandler returns a new instance of ChaosWorkflowHandler
func (*ChaosExperimentRunHandler) ChaosExperimentRunEvent ¶
func (c *ChaosExperimentRunHandler) ChaosExperimentRunEvent(event model.ExperimentRunRequest) (string, error)
func (*ChaosExperimentRunHandler) GetExperimentRun ¶
func (c *ChaosExperimentRunHandler) GetExperimentRun(ctx context.Context, projectID string, experimentRunID *string, notifyID *string) (*model.ExperimentRun, error)
GetExperimentRun returns details of a requested experiment run
func (*ChaosExperimentRunHandler) GetExperimentRunStats ¶
func (c *ChaosExperimentRunHandler) GetExperimentRunStats(ctx context.Context, projectID string) (*model.GetExperimentRunStatsResponse, error)
func (*ChaosExperimentRunHandler) ListExperimentRun ¶
func (c *ChaosExperimentRunHandler) ListExperimentRun(projectID string, request model.ListExperimentRunRequest) (*model.ListExperimentRunResponse, error)
ListExperimentRun returns all the workflow runs for matching identifiers from the DB
func (*ChaosExperimentRunHandler) RunChaosWorkFlow ¶
func (c *ChaosExperimentRunHandler) RunChaosWorkFlow(ctx context.Context, projectID string, workflow dbChaosExperiment.ChaosExperimentRequest, r *store.StateData) (*model.RunChaosExperimentResponse, error)
RunChaosWorkFlow sends workflow run request(single run workflow only) to chaos_infra on workflow re-run request
func (*ChaosExperimentRunHandler) RunCronExperiment ¶
func (c *ChaosExperimentRunHandler) RunCronExperiment(ctx context.Context, projectID string, workflow dbChaosExperiment.ChaosExperimentRequest, r *store.StateData) error
Click to show internal directories.
Click to hide internal directories.