execdriver

Documentation

Index

• Variables
• func RegisterInitFunc(name string, fct InitFunc) error
• type Driver
• type Info
• type InitArgs
• type InitFunc
  • func GetInitFunc(name string) (InitFunc, error)
• type Network
• type Process
  • func (c *Process) GetExitCode() int
  • func (c *Process) Pid() int
• type StartCallback

Variables

var (
	ErrNotRunning              = errors.New("Process could not be started")
	ErrWaitTimeoutReached      = errors.New("Wait timeout reached")
	ErrDriverAlreadyRegistered = errors.New("A driver already registered this docker init function")
	ErrDriverNotFound          = errors.New("The requested docker init has not been found")
)

Functions

func RegisterInitFunc

func RegisterInitFunc(name string, fct InitFunc) error

Types

type Driver

type Driver interface {
	Run(c *Process, startCallback StartCallback) (int, error) // Run executes the process and blocks until the process exits and returns the exit code
	Kill(c *Process, sig int) error
	Wait(id string) error // Wait on an out of process...process - lxc ghosts TODO: Rename to reattach, reconnect
	Name() string         // Driver name
	Info(id string) Info  // "temporary" hack (until we move state from core to plugins)
}

type Info

type Info interface {
	IsRunning() bool
}

Driver specific information based on processes registered with the driver

type InitArgs

type InitArgs struct {
	User       string
	Gateway    string
	Ip         string
	WorkDir    string
	Privileged bool
	Env        []string
	Args       []string
	Mtu        int
	Driver     string
}

Args provided to the init function for a driver

type InitFunc

type InitFunc func(i *InitArgs) error

func GetInitFunc

func GetInitFunc(name string) (InitFunc, error)

type Network

type Network struct {
	Gateway     string `json:"gateway"`
	IPAddress   string `json:"ip"`
	Bridge      string `json:"bridge"`
	IPPrefixLen int    `json:"ip_prefix_len"`
	Mtu         int    `json:"mtu"`
}

Network settings of the container

type Process

type Process struct {
	exec.Cmd

	ID         string          `json:"id"`
	Privileged bool            `json:"privileged"`
	User       string          `json:"user"`
	Rootfs     string          `json:"rootfs"`   // root fs of the container
	InitPath   string          `json:"initpath"` // dockerinit
	Entrypoint string          `json:"entrypoint"`
	Arguments  []string        `json:"arguments"`
	WorkingDir string          `json:"working_dir"`
	ConfigPath string          `json:"config_path"` // this should be able to be removed when the lxc template is moved into the driver
	Tty        bool            `json:"tty"`
	Network    *Network        `json:"network"` // if network is nil then networking is disabled
	Config     []string        `json:"config"`  //  generic values that specific drivers can consume
	Cgroups    *cgroups.Values `json:"cgroups"`
}

Process wrapps an os/exec.Cmd to add more metadata TODO: Rename to Command

func (*Process) GetExitCode

func (c *Process) GetExitCode() int

Return the exit code of the process if the process has not exited -1 will be returned

func (*Process) Pid

func (c *Process) Pid() int

Return the pid of the process If the process is nil -1 will be returned

type StartCallback

type StartCallback func(*Process)