handler

Documentation

Index

• type ChaosExperimentHandler
  • func NewChaosExperimentHandler(chaosExperimentService ops.Service, ...) *ChaosExperimentHandler
  • func (c *ChaosExperimentHandler) CreateChaosExperiment(ctx context.Context, request *model.ChaosExperimentRequest, projectID string) (*model.ChaosExperimentResponse, error)
  • func (c *ChaosExperimentHandler) DeleteChaosExperiment(ctx context.Context, projectID string, workflowID string, ...) (bool, error)
  • func (c *ChaosExperimentHandler) DisableCronExperiment(username string, experiment dbChaosExperiment.ChaosExperimentRequest, ...) error
  • func (c *ChaosExperimentHandler) GetDBExperiment(query bson.D) (dbChaosExperiment.ChaosExperimentRequest, error)
  • func (c *ChaosExperimentHandler) GetExperiment(ctx context.Context, projectID string, experimentID string) (*model.GetExperimentResponse, error)
  • func (c *ChaosExperimentHandler) GetExperimentStats(ctx context.Context, projectID string) (*model.GetExperimentStatsResponse, error)
  • func (c *ChaosExperimentHandler) GetKubeObjData(reqID string, kubeObject model.KubeObjectRequest, r store.StateData)
  • func (c *ChaosExperimentHandler) GetLogs(reqID string, pod model.PodLogRequest, r store.StateData)
  • func (c *ChaosExperimentHandler) GetProbesInExperimentRun(ctx context.Context, projectID string, experimentRunID string, ...) ([]*model.GetProbesInExperimentRunResponse, error)
  • func (c *ChaosExperimentHandler) ListExperiment(projectID string, request model.ListExperimentRequest) (*model.ListExperimentResponse, error)
  • func (c *ChaosExperimentHandler) SaveChaosExperiment(ctx context.Context, request model.SaveChaosExperimentRequest, ...) (string, error)
  • func (c *ChaosExperimentHandler) StopExperimentRuns(ctx context.Context, projectID string, experimentID string, ...) (bool, error)
  • func (c *ChaosExperimentHandler) UpdateChaosExperiment(ctx context.Context, request model.ChaosExperimentRequest, projectID string, ...) (*model.ChaosExperimentResponse, error)
  • func (c *ChaosExperimentHandler) UpdateCronExperimentState(ctx context.Context, workflowID string, disable bool, projectID string, ...) (bool, error)

Types

type ChaosExperimentHandler

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

ChaosExperimentHandler is the handler for chaos experiment

func NewChaosExperimentHandler

func NewChaosExperimentHandler(
	chaosExperimentService ops.Service,
	chaosExperimentRunService chaosExperimentRun.Service,
	infrastructureService chaos_infrastructure.Service,
	gitOpsService gitops.Service,
	chaosExperimentOperator *dbChaosExperiment.Operator,
	chaosExperimentRunOperator *dbChaosExperimentRun.Operator,
	mongodbOperator mongodb.MongoOperator,
) *ChaosExperimentHandler

NewChaosExperimentHandler returns a new instance of ChaosWorkflowHandler

func (*ChaosExperimentHandler) CreateChaosExperiment

func (c *ChaosExperimentHandler) CreateChaosExperiment(ctx context.Context, request *model.ChaosExperimentRequest, projectID string) (*model.ChaosExperimentResponse, error)

func (*ChaosExperimentHandler) DeleteChaosExperiment

func (c *ChaosExperimentHandler) DeleteChaosExperiment(ctx context.Context, projectID string, workflowID string, workflowRunID *string, r *store.StateData) (bool, error)

func (*ChaosExperimentHandler) DisableCronExperiment

func (c *ChaosExperimentHandler) DisableCronExperiment(username string, experiment dbChaosExperiment.ChaosExperimentRequest, projectID string, r *store.StateData) error

func (*ChaosExperimentHandler) GetDBExperiment

func (c *ChaosExperimentHandler) GetDBExperiment(query bson.D) (dbChaosExperiment.ChaosExperimentRequest, error)

func (*ChaosExperimentHandler) GetExperiment

func (c *ChaosExperimentHandler) GetExperiment(ctx context.Context, projectID string, experimentID string) (*model.GetExperimentResponse, error)

GetExperiment returns details of the requested experiment

func (*ChaosExperimentHandler) GetExperimentStats

func (c *ChaosExperimentHandler) GetExperimentStats(ctx context.Context, projectID string) (*model.GetExperimentStatsResponse, error)

func (*ChaosExperimentHandler) GetKubeObjData

func (c *ChaosExperimentHandler) GetKubeObjData(reqID string, kubeObject model.KubeObjectRequest, r store.StateData)

func (*ChaosExperimentHandler) GetLogs

func (c *ChaosExperimentHandler) GetLogs(reqID string, pod model.PodLogRequest, r store.StateData)

GetLogs query is used to fetch the logs from the cluster

func (*ChaosExperimentHandler) GetProbesInExperimentRun

func (c *ChaosExperimentHandler) GetProbesInExperimentRun(ctx context.Context, projectID string, experimentRunID string, faultName string) ([]*model.GetProbesInExperimentRunResponse, error)

func (*ChaosExperimentHandler) ListExperiment

func (c *ChaosExperimentHandler) ListExperiment(projectID string, request model.ListExperimentRequest) (*model.ListExperimentResponse, error)

ListExperiment returns all the workflows for matching identifiers from the DB

func (*ChaosExperimentHandler) SaveChaosExperiment

func (c *ChaosExperimentHandler) SaveChaosExperiment(ctx context.Context, request model.SaveChaosExperimentRequest, projectID string, r *store.StateData) (string, error)

func (*ChaosExperimentHandler) StopExperimentRuns

func (c *ChaosExperimentHandler) StopExperimentRuns(ctx context.Context, projectID string, experimentID string, experimentRunID *string, r *store.StateData) (bool, error)

func (*ChaosExperimentHandler) UpdateChaosExperiment

func (c *ChaosExperimentHandler) UpdateChaosExperiment(ctx context.Context, request model.ChaosExperimentRequest, projectID string, r *store.StateData) (*model.ChaosExperimentResponse, error)

func (*ChaosExperimentHandler) UpdateCronExperimentState

func (c *ChaosExperimentHandler) UpdateCronExperimentState(ctx context.Context, workflowID string, disable bool, projectID string, r *store.StateData) (bool, error)