docker

package
v0.1.149 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 23, 2025 License: MIT Imports: 45 Imported by: 0

Documentation

Index

Constants

View Source
const (

	// DefaultImageTTL is the default time to live for images in the Docker runtime
	// after which they are pruned if not used.
	DefaultImageTTL = time.Hour * 72 // 3 days
)

defaultWorkdir is the directory where `Task.File`s are written to by default, should `Task.Workdir` not be set

Variables

This section is empty.

Functions

func NewTempArchive added in v0.1.72

func NewTempArchive() (*archive, error)

Types

type BindConfig added in v0.1.19

type BindConfig struct {
	Allowed bool
	Sources []string
}

type BindMounter added in v0.1.19

type BindMounter struct {
	// contains filtered or unexported fields
}

func NewBindMounter added in v0.1.19

func NewBindMounter(cfg BindConfig) *BindMounter

func (*BindMounter) Mount added in v0.1.19

func (m *BindMounter) Mount(ctx context.Context, mnt *tork.Mount) error

func (*BindMounter) Unmount added in v0.1.19

func (m *BindMounter) Unmount(ctx context.Context, mnt *tork.Mount) error

type DockerRuntime

type DockerRuntime struct {
	// contains filtered or unexported fields
}

func NewDockerRuntime

func NewDockerRuntime(opts ...Option) (*DockerRuntime, error)

func (*DockerRuntime) HealthCheck

func (rt *DockerRuntime) HealthCheck(ctx context.Context) error

func (*DockerRuntime) Run

func (rt *DockerRuntime) Run(ctx context.Context, t *tork.Task) error

type KubernetesConfig added in v0.1.31

type KubernetesConfig struct {
	AllNamespaces string `json:"allNamespaces,omitempty"`
}

KubernetesConfig contains Kubernetes orchestrator settings

type Option

type Option = func(rt *DockerRuntime)

func WithBroker added in v0.1.63

func WithBroker(broker broker.Broker) Option

func WithConfig added in v0.1.31

func WithConfig(config string) Option

func WithImageTTL added in v0.1.121

func WithImageTTL(ttl time.Duration) Option

func WithImageVerify added in v0.1.133

func WithImageVerify(verify bool) Option

func WithMounter

func WithMounter(mounter runtime.Mounter) Option

func WithPrivileged added in v0.1.119

func WithPrivileged(privileged bool) Option

type TmpfsMounter added in v0.1.20

type TmpfsMounter struct {
}

func NewTmpfsMounter added in v0.1.20

func NewTmpfsMounter() *TmpfsMounter

func (*TmpfsMounter) Mount added in v0.1.20

func (m *TmpfsMounter) Mount(ctx context.Context, mnt *tork.Mount) error

func (*TmpfsMounter) Unmount added in v0.1.20

func (m *TmpfsMounter) Unmount(ctx context.Context, mnt *tork.Mount) error

type VolumeMounter added in v0.1.19

type VolumeMounter struct {
	// contains filtered or unexported fields
}

func NewVolumeMounter added in v0.1.19

func NewVolumeMounter() (*VolumeMounter, error)

func (*VolumeMounter) Mount added in v0.1.19

func (m *VolumeMounter) Mount(ctx context.Context, mn *tork.Mount) error

func (*VolumeMounter) Unmount added in v0.1.19

func (m *VolumeMounter) Unmount(ctx context.Context, mn *tork.Mount) error

Jump to

Keyboard shortcuts

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