Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + var BadSpec = errors.New("invalid service spec") + type Action int + const TaskCancel + const TaskCreate + const TaskDestroy + const TaskInspect + const TaskJobVolumeCreate + const TaskKedaScaledObjectApply + const TaskKedaScaledObjectCancel + const TaskKedaScaledObjectCreate + const TaskKedaScaledObjectReApply + const TaskKillPod + const TaskPrecheck + const TaskRemove + const TaskScale + const TaskStatus + const TaskUpdate + const TaskVPAObjectApply + const TaskVPAObjectCancel + const TaskVPAObjectReApply + func (a *Action) String() string + type Result interface + Wait func(ctx context.Context) TaskResponse + type Sched struct + func NewSched() (*Sched, error) + func (s *Sched) FindExecutor(name, kind string) (executortypes.Executor, error) + func (s *Sched) ListExecutors() []executortypes.Executor + func (s *Sched) PrintPoolUsage() + func (s *Sched) Return(ctx context.Context, t *Task, resp TaskResponse) + func (s *Sched) Send(ctx context.Context, req TaskRequest) (Result, error) + type Task struct + func (t *Task) Run(ctx context.Context) TaskResponse + func (t *Task) String() string + func (t *Task) Wait(ctx context.Context) TaskResponse + type TaskRequest struct + Action Action + ExecutorKind string + ExecutorName string + ID string + Spec interface{} + type TaskResponse struct + Extra interface{} + func (tr *TaskResponse) Err() error + func (tr *TaskResponse) Status() apistructs.StatusDesc
Go to main page