Documentation ¶
Index ¶
- Constants
- func NewBidStrategy(client *docker.Client) bidstrategy.BidStrategy
- type Executor
- func (e *Executor) GetBidStrategy(context.Context) (bidstrategy.BidStrategy, error)
- func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
- func (e *Executor) GetVolumeSize(ctx context.Context, volume model.StorageSpec) (uint64, error)
- func (e *Executor) HasStorageLocally(ctx context.Context, volume model.StorageSpec) (bool, error)
- func (e *Executor) IsInstalled(ctx context.Context) (bool, error)
- func (e *Executor) Run(ctx context.Context, executionID string, job model.Job, jobResultsDir string) (*model.RunCommandResult, error)
Constants ¶
View Source
const NanoCPUCoefficient = 1000000000
Variables ¶
This section is empty.
Functions ¶
func NewBidStrategy ¶ added in v0.3.24
func NewBidStrategy(client *docker.Client) bidstrategy.BidStrategy
Types ¶
type Executor ¶
type Executor struct { // used to allow multiple docker executors to run against the same docker server ID string // the storage providers we can implement for a job StorageProvider storage.StorageProvider // contains filtered or unexported fields }
func NewExecutor ¶
func NewExecutor( _ context.Context, cm *system.CleanupManager, id string, storageProvider storage.StorageProvider, ) (*Executor, error)
func (*Executor) GetBidStrategy ¶ added in v0.3.24
func (e *Executor) GetBidStrategy(context.Context) (bidstrategy.BidStrategy, error)
GetBidStrategy implements executor.Executor
func (*Executor) GetOutputStream ¶ added in v0.3.25
func (*Executor) GetVolumeSize ¶
func (*Executor) HasStorageLocally ¶
func (*Executor) IsInstalled ¶
IsInstalled checks if docker itself is installed.
Click to show internal directories.
Click to hide internal directories.