Documentation
¶
Index ¶
- Constants
- type ContainerState
- type DockerExecutor
- func (d *DockerExecutor) Cleanup(ctx context.Context, req *types.ExecutionRequest) error
- func (d *DockerExecutor) Close() error
- func (d *DockerExecutor) Execute(ctx context.Context, req *types.ExecutionRequest, workdir string) (string, error)
- func (d *DockerExecutor) PullImage(ctx context.Context, imageName, version string) error
- func (d *DockerExecutor) StopContainer(ctx context.Context, workflowID string) error
Constants ¶
View Source
const (
DockerPullTimeout = 2 * time.Minute
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContainerState ¶
type DockerExecutor ¶
type DockerExecutor struct {
// contains filtered or unexported fields
}
func NewDockerExecutor ¶
func NewDockerExecutor() (*DockerExecutor, error)
func (*DockerExecutor) Cleanup ¶
func (d *DockerExecutor) Cleanup(ctx context.Context, req *types.ExecutionRequest) error
func (*DockerExecutor) Close ¶
func (d *DockerExecutor) Close() error
func (*DockerExecutor) Execute ¶
func (d *DockerExecutor) Execute(ctx context.Context, req *types.ExecutionRequest, workdir string) (string, error)
func (*DockerExecutor) PullImage ¶
func (d *DockerExecutor) PullImage(ctx context.Context, imageName, version string) error
func (*DockerExecutor) StopContainer ¶
func (d *DockerExecutor) StopContainer(ctx context.Context, workflowID string) error
StopContainer stops a container by name, falling back to kill if needed (for cleanup activity)
Click to show internal directories.
Click to hide internal directories.