action

Documentation

Index

• type ActionHandler
  • func NewActionHandler(log zerolog.Logger, d *db.DB, ost objectstorage.ObjStorage, ...) *ActionHandler
  • func (h *ActionHandler) ApproveRunTask(ctx context.Context, req *RunTaskApproveRequest) error
  • func (h *ActionHandler) ChangeRunPhase(ctx context.Context, req *RunChangePhaseRequest) error
  • func (h *ActionHandler) CreateRun(ctx context.Context, req *RunCreateRequest) (*types.RunBundle, error)
  • func (h *ActionHandler) Export(ctx context.Context, w io.Writer) error
  • func (h *ActionHandler) GetChangeGroupsUpdateTokens(tx *sql.Tx, changeGroupsNames []string) (*types.ChangeGroupsUpdateToken, error)
  • func (h *ActionHandler) GetExecutorTask(ctx context.Context, etID string) (*GetExecutorTaskResponse, error)
  • func (h *ActionHandler) GetExecutorTasks(ctx context.Context, executorID string) ([]*GetExecutorTaskResponse, error)
  • func (h *ActionHandler) GetGroupRuns(ctx context.Context, req *GetGroupRunsRequest) (*GetGroupRunsResponse, error)
  • func (h *ActionHandler) Import(ctx context.Context, r io.Reader) error
  • func (h *ActionHandler) IsMaintenanceEnabled(ctx context.Context) (bool, error)
  • func (h *ActionHandler) IsMaintenanceMode() bool
  • func (h *ActionHandler) RunTaskSetAnnotations(ctx context.Context, req *RunTaskSetAnnotationsRequest) error
  • func (h *ActionHandler) SetMaintenanceEnabled(ctx context.Context, enable bool) error
  • func (h *ActionHandler) SetMaintenanceMode(maintenanceMode bool)
  • func (h *ActionHandler) StopRun(ctx context.Context, req *RunStopRequest) error
  • func (h *ActionHandler) UpdateChangeGroups(tx *sql.Tx, cgt *types.ChangeGroupsUpdateToken) error
• type GetExecutorTaskResponse
• type GetGroupRunsRequest
• type GetGroupRunsResponse
• type RunChangePhaseRequest
• type RunCreateRequest
• type RunStopRequest
• type RunTaskApproveRequest
• type RunTaskSetAnnotationsRequest

Types

type ActionHandler

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

func NewActionHandler

func NewActionHandler(log zerolog.Logger, d *db.DB, ost objectstorage.ObjStorage, lf lock.LockFactory) *ActionHandler

func (*ActionHandler) ApproveRunTask

func (h *ActionHandler) ApproveRunTask(ctx context.Context, req *RunTaskApproveRequest) error

func (*ActionHandler) ChangeRunPhase

func (h *ActionHandler) ChangeRunPhase(ctx context.Context, req *RunChangePhaseRequest) error

func (*ActionHandler) CreateRun

func (h *ActionHandler) CreateRun(ctx context.Context, req *RunCreateRequest) (*types.RunBundle, error)

func (*ActionHandler) Export

func (h *ActionHandler) Export(ctx context.Context, w io.Writer) error

func (*ActionHandler) GetChangeGroupsUpdateTokens

func (h *ActionHandler) GetChangeGroupsUpdateTokens(tx *sql.Tx, changeGroupsNames []string) (*types.ChangeGroupsUpdateToken, error)

func (*ActionHandler) GetExecutorTask

func (h *ActionHandler) GetExecutorTask(ctx context.Context, etID string) (*GetExecutorTaskResponse, error)

func (*ActionHandler) GetExecutorTasks

func (h *ActionHandler) GetExecutorTasks(ctx context.Context, executorID string) ([]*GetExecutorTaskResponse, error)

func (*ActionHandler) GetGroupRuns

func (h *ActionHandler) GetGroupRuns(ctx context.Context, req *GetGroupRunsRequest) (*GetGroupRunsResponse, error)

func (*ActionHandler) Import

func (h *ActionHandler) Import(ctx context.Context, r io.Reader) error

func (*ActionHandler) IsMaintenanceEnabled

func (h *ActionHandler) IsMaintenanceEnabled(ctx context.Context) (bool, error)

func (*ActionHandler) IsMaintenanceMode

func (h *ActionHandler) IsMaintenanceMode() bool

func (*ActionHandler) RunTaskSetAnnotations

func (h *ActionHandler) RunTaskSetAnnotations(ctx context.Context, req *RunTaskSetAnnotationsRequest) error

func (*ActionHandler) SetMaintenanceEnabled

func (h *ActionHandler) SetMaintenanceEnabled(ctx context.Context, enable bool) error

func (*ActionHandler) SetMaintenanceMode

func (h *ActionHandler) SetMaintenanceMode(maintenanceMode bool)

func (*ActionHandler) StopRun

func (h *ActionHandler) StopRun(ctx context.Context, req *RunStopRequest) error

func (*ActionHandler) UpdateChangeGroups

func (h *ActionHandler) UpdateChangeGroups(tx *sql.Tx, cgt *types.ChangeGroupsUpdateToken) error

type GetExecutorTaskResponse

type GetExecutorTaskResponse struct {
	Et         *types.ExecutorTask
	EtSpecData *types.ExecutorTaskSpecData
}

type GetGroupRunsRequest

type GetGroupRunsRequest struct {
	Group string

	Limit         int
	SortDirection types.SortDirection

	ChangeGroups    []string
	StartRunCounter uint64
	PhaseFilter     []types.RunPhase
	ResultFilter    []types.RunResult
}

type GetGroupRunsResponse

type GetGroupRunsResponse struct {
	Runs                    []*types.Run
	ChangeGroupsUpdateToken string

	HasMore bool
}

type RunChangePhaseRequest

type RunChangePhaseRequest struct {
	RunID                   string
	Phase                   types.RunPhase
	ChangeGroupsUpdateToken string
}

type RunCreateRequest

type RunCreateRequest struct {
	RunConfigTasks    map[string]*types.RunConfigTask
	Name              string
	Group             string
	SetupErrors       []string
	StaticEnvironment map[string]string
	CacheGroup        string

	// existing run fields
	RunID      string
	FromStart  bool
	ResetTasks []string

	// common fields
	Environment map[string]string
	Annotations map[string]string

	ChangeGroupsUpdateToken string
}

type RunStopRequest

type RunStopRequest struct {
	RunID                   string
	ChangeGroupsUpdateToken string
}

type RunTaskApproveRequest

type RunTaskApproveRequest struct {
	RunID                   string
	TaskID                  string
	ChangeGroupsUpdateToken string
}

type RunTaskSetAnnotationsRequest

type RunTaskSetAnnotationsRequest struct {
	RunID                   string
	TaskID                  string
	Annotations             map[string]string
	ChangeGroupsUpdateToken string
}