Documentation
¶
Index ¶
- Variables
- type Orca
- func (o *Orca) DestroyTask(ctx context.Context, taskId ulid.ULID, force bool) error
- func (o *Orca) InspectTask(ctx context.Context, taskId ulid.ULID) (*arkd.Task, error)
- func (o *Orca) ListTasks(ctx context.Context) ([]arkd.Task, error)
- func (o *Orca) StartTask(ctx context.Context, taskDef arkd.TaskDefinition) ([]byte, error)
- func (o *Orca) StopTask(ctx context.Context, taskId ulid.ULID, signal string) error
- func (o *Orca) WakeTask(ctx context.Context, taskId ulid.ULID) error
- type Orchestrator
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInsufficientResourcesAvailable = errors.New("orca: cannot schedule task, insufficient resources available")
Functions ¶
This section is empty.
Types ¶
type Orca ¶
type Orca struct {
// contains filtered or unexported fields
}
func (*Orca) DestroyTask ¶
func (*Orca) InspectTask ¶
type Orchestrator ¶
type Orchestrator interface { ListTasks(ctx context.Context) ([]arkd.Task, error) InspectTask(ctx context.Context, taskId ulid.ULID) (*arkd.Task, error) StartTask(ctx context.Context, taskDef arkd.TaskDefinition) ([]byte, error) StopTask(ctx context.Context, taskId ulid.ULID, signal string) error WakeTask(ctx context.Context, taskId ulid.ULID) error DestroyTask(ctx context.Context, taskId ulid.ULID, force bool) error }
Click to show internal directories.
Click to hide internal directories.