adapter

Documentation

Index

• func IdentityMount(path string, opts ...MountOption) specs.Mount
• func Mount(from, to string, opts ...MountOption) specs.Mount
• type GlobFunc
• type MountOption
  • func AllowExec() MountOption
  • func AllowWrites() MountOption
  • func WithRecursiveBind() MountOption
• type MountShare
• type RuncAdapter
  • func NewRuncAdapter(features sysfeat.Features, glob GlobFunc, mountSharer MountShare, ...) *RuncAdapter
  • func (a *RuncAdapter) BuildSpec(logger lager.Logger, bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig, ...) (specs.Spec, error)
  • func (a *RuncAdapter) CreateJobPrerequisites(bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig, user specs.User) (*os.File, *os.File, error)
• type VolumeLocker

Functions

func IdentityMount

func IdentityMount(path string, opts ...MountOption) specs.Mount

IdentityMount provides a shorthand for Mount which has the same from and to.

func Mount

func Mount(from, to string, opts ...MountOption) specs.Mount

Mount creates a bind mount description with "to" as the destination and "from" as the source. Various MountOptions can be specified to modify the mount options. By default, the most restrictive set of mount options are used.

Types

type GlobFunc

type GlobFunc func(string) ([]string, error)

GlobFunc is a function which when given a file path pattern returns a list of paths or an error if the search failed.

type MountOption

type MountOption func(*mountOptions)

MountOption can be used to alter the mount options to Mount or IdentityMount.

func AllowExec

func AllowExec() MountOption

AllowExec allows binaries to be executed from a mount. It maps to the exec/noexec mount option.

func AllowWrites

func AllowWrites() MountOption

AllowWrites allows writes to a mount. It maps to the ro/rw mount option.

func WithRecursiveBind

func WithRecursiveBind() MountOption

WithRecursiveBind mounts other bind mounts in the source to the destination recursively. It maps to the bind/rbind mount option.

type MountShare

type MountShare func(string) error

type RuncAdapter

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

func NewRuncAdapter

func NewRuncAdapter(features sysfeat.Features, glob GlobFunc, mountSharer MountShare, locker VolumeLocker) *RuncAdapter

func (*RuncAdapter) BuildSpec

func (a *RuncAdapter) BuildSpec(
	logger lager.Logger,
	bpmCfg *config.BPMConfig,
	procCfg *config.ProcessConfig,
	user specs.User,
) (specs.Spec, error)

func (*RuncAdapter) CreateJobPrerequisites

func (a *RuncAdapter) CreateJobPrerequisites(
	bpmCfg *config.BPMConfig,
	procCfg *config.ProcessConfig,
	user specs.User,
) (*os.File, *os.File, error)

type VolumeLocker

type VolumeLocker interface {
	LockVolume(string) (hostlock.LockedLock, error)
}