docker

Documentation

Index

• type BindConfig
• type BindMounter
  • func NewBindMounter(cfg BindConfig) *BindMounter
  • func (m *BindMounter) Mount(ctx context.Context, mnt *types.Mount) error
  • func (m *BindMounter) Unmount(ctx context.Context, mnt *types.Mount) error
• type KubernetesConfig
• type Option
  • func WithConfig(config string) Option
  • func WithMounter(mounter runtime.Mounter) Option
• type Runtime
  • func NewRuntime(opts ...Option) (*Runtime, error)
  • func (d *Runtime) HealthCheck(ctx context.Context) error
  • func (d *Runtime) Run(ctx context.Context, t *types.Task) error
  • func (d *Runtime) Stop(ctx context.Context, t *types.Task) error
• type TmpfsMounter
  • func NewTmpfsMounter() *TmpfsMounter
  • func (m *TmpfsMounter) Mount(ctx context.Context, mnt *types.Mount) error
  • func (m *TmpfsMounter) Unmount(ctx context.Context, mnt *types.Mount) error
• type VolumeMounter
  • func NewVolumeMounter() (*VolumeMounter, error)
  • func (m *VolumeMounter) Mount(ctx context.Context, mn *types.Mount) error
  • func (m *VolumeMounter) Unmount(ctx context.Context, mn *types.Mount) error

Types

type BindConfig

type BindConfig struct {
	Allowed bool
}

type BindMounter

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

func NewBindMounter

func NewBindMounter(cfg BindConfig) *BindMounter

func (*BindMounter) Mount

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

func (*BindMounter) Unmount

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

type KubernetesConfig

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

KubernetesConfig contains Kubernetes orchestrator settings

type Option

type Option = func(rt *Runtime)

func WithConfig

func WithConfig(config string) Option

func WithMounter

func WithMounter(mounter runtime.Mounter) Option

type Runtime

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

func NewRuntime

func NewRuntime(opts ...Option) (*Runtime, error)

func (*Runtime) HealthCheck

func (d *Runtime) HealthCheck(ctx context.Context) error

func (*Runtime) Run

func (d *Runtime) Run(ctx context.Context, t *types.Task) error

func (*Runtime) Stop

func (d *Runtime) Stop(ctx context.Context, t *types.Task) error

type TmpfsMounter

type TmpfsMounter struct {
}

func NewTmpfsMounter

func NewTmpfsMounter() *TmpfsMounter

func (*TmpfsMounter) Mount

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

func (*TmpfsMounter) Unmount

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

type VolumeMounter

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

func NewVolumeMounter

func NewVolumeMounter() (*VolumeMounter, error)

func (*VolumeMounter) Mount

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

func (*VolumeMounter) Unmount

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