docker

package

v0.3.26 Latest Latest Go to latest Published: Apr 13, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bacalhau-project/bacalhau

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewBidStrategy(client *docker.Client) bidstrategy.BidStrategy
type Executor
- func NewExecutor(_ context.Context, cm *system.CleanupManager, id string, ...) (*Executor, 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 (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)

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 ¶ added in v0.3.24

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL