docker

Documentation

Index

• Constants
• type Executor
  • func NewExecutor(_ context.Context, cm *system.CleanupManager, id string, ...) (*Executor, error)
  • func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (e *Executor) GetResourceBidStrategy(context.Context) (bidstrategy.ResourceBidStrategy, error)
  • func (e *Executor) GetSemanticBidStrategy(context.Context) (bidstrategy.SemanticBidStrategy, 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

const NanoCPUCoefficient = 1000000000

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) GetOutputStream

func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)

func (*Executor) GetResourceBidStrategy

func (e *Executor) GetResourceBidStrategy(context.Context) (bidstrategy.ResourceBidStrategy, error)

func (*Executor) GetSemanticBidStrategy

func (e *Executor) GetSemanticBidStrategy(context.Context) (bidstrategy.SemanticBidStrategy, error)

GetBidStrategy implements executor.Executor

func (*Executor) GetVolumeSize

func (e *Executor) GetVolumeSize(ctx context.Context, volume model.StorageSpec) (uint64, error)

func (*Executor) HasStorageLocally

func (e *Executor) HasStorageLocally(ctx context.Context, volume model.StorageSpec) (bool, error)

func (*Executor) IsInstalled

func (e *Executor) IsInstalled(ctx context.Context) (bool, error)

IsInstalled checks if docker itself is installed.

func (*Executor) Run

func (e *Executor) Run(
	ctx context.Context,
	executionID string,
	job model.Job,
	jobResultsDir string,
) (*model.RunCommandResult, error)