action

Documentation

Index

• type ActionHandler
  • func NewActionHandler(log zerolog.Logger, e *etcd.Store, readDB *readdb.ReadDB, ...) *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) DeleteExecutor(ctx context.Context, executorID string) error
  • func (h *ActionHandler) Export(ctx context.Context, w io.Writer) error
  • func (h *ActionHandler) GetExecutorTask(ctx context.Context, etID string) (*types.ExecutorTask, error)
  • func (h *ActionHandler) GetExecutorTasks(ctx context.Context, executorID string) ([]*types.ExecutorTask, error)
  • func (h *ActionHandler) Import(ctx context.Context, r io.Reader) error
  • func (h *ActionHandler) MaintenanceMode(ctx context.Context, enable bool) error
  • func (h *ActionHandler) RunTaskSetAnnotations(ctx context.Context, req *RunTaskSetAnnotationsRequest) error
  • func (h *ActionHandler) SetMaintenanceMode(maintenanceMode bool)
  • func (h *ActionHandler) StopRun(ctx context.Context, req *RunStopRequest) error
• 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, e *etcd.Store, readDB *readdb.ReadDB, ost *objectstorage.ObjStorage, dm *datamanager.DataManager) *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) DeleteExecutor

func (h *ActionHandler) DeleteExecutor(ctx context.Context, executorID string) error

func (*ActionHandler) Export

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

func (*ActionHandler) GetExecutorTask

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

func (*ActionHandler) GetExecutorTasks

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

func (*ActionHandler) Import

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

func (*ActionHandler) MaintenanceMode

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

func (*ActionHandler) RunTaskSetAnnotations

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

func (*ActionHandler) SetMaintenanceMode

func (h *ActionHandler) SetMaintenanceMode(maintenanceMode bool)

func (*ActionHandler) StopRun

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

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
}