driver

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2015 License: MPL-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BuiltinDrivers = map[string]Factory{
	"docker":   NewDockerDriver,
	"exec":     NewExecDriver,
	"raw_exec": NewRawExecDriver,
	"java":     NewJavaDriver,
	"qemu":     NewQemuDriver,
	"rkt":      NewRktDriver,
}

BuiltinDrivers contains the built in registered drivers which are available for allocation handling

Functions

func TaskEnvironmentVariables 

func TaskEnvironmentVariables(ctx *ExecContext, task *structs.Task) environment.TaskEnvironment

TaskEnvironmentVariables converts exec context and task configuration into a TaskEnvironment.

Types

type DockerDriver 

type DockerDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

func (*DockerDriver) Fingerprint 

func (d *DockerDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*DockerDriver) Open 

func (d *DockerDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*DockerDriver) Start 

func (d *DockerDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

type DockerDriverAuth added in v0.2.0 

type DockerDriverAuth struct {
	Username      string `mapstructure:"username"`       // username for the registry
	Password      string `mapstructure:"password"`       // password to access the registry
	Email         string `mapstructure:"email"`          // email address of the user who is allowed to access the registry
	ServerAddress string `mapstructure:"server_address"` // server address of the registry
}

type DockerDriverConfig added in v0.2.0 

type DockerDriverConfig struct {
	ImageName        string              `mapstructure:"image"`              // Container's Image Name
	Command          string              `mapstructure:"command"`            // The Command/Entrypoint to run when the container starts up
	Args             []string            `mapstructure:"args"`               // The arguments to the Command/Entrypoint
	NetworkMode      string              `mapstructure:"network_mode"`       // The network mode of the container - host, net and none
	PortMapRaw       []map[string]int    `mapstructure:"port_map"`           //
	PortMap          map[string]int      `mapstructure:"-"`                  // A map of host port labels and the ports exposed on the container
	Privileged       bool                `mapstructure:"privileged"`         // Flag to run the container in priviledged mode
	DNSServers       []string            `mapstructure:"dns_servers"`        // DNS Server for containers
	DNSSearchDomains []string            `mapstructure:"dns_search_domains"` // DNS Search domains for containers
	Hostname         string              `mapstructure:"hostname"`           // Hostname for containers
	LabelsRaw        []map[string]string `mapstructure:"labels"`             //
	Labels           map[string]string   `mapstructure:"-"`                  // Labels to set when the container starts up
	Auth             []DockerDriverAuth  `mapstructure:"auth"`               // Authentication credentials for a private Docker registry
}

func (*DockerDriverConfig) Validate added in v0.2.0 

func (c *DockerDriverConfig) Validate() error

type DockerHandle added in v0.2.1 

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

func (*DockerHandle) ContainerID added in v0.2.1 

func (h *DockerHandle) ContainerID() string

func (*DockerHandle) ID added in v0.2.1 

func (h *DockerHandle) ID() string

func (*DockerHandle) Kill added in v0.2.1 

func (h *DockerHandle) Kill() error

Kill is used to terminate the task. This uses docker stop -t 5

func (*DockerHandle) Update added in v0.2.1 

func (h *DockerHandle) Update(task *structs.Task) error

func (*DockerHandle) WaitCh added in v0.2.1 

func (h *DockerHandle) WaitCh() chan *cstructs.WaitResult

type Driver 

type Driver interface {
	// Drivers must support the fingerprint interface for detection
	fingerprint.Fingerprint

	// Start is used to being task execution
	Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

	// Open is used to re-open a handle to a task
	Open(ctx *ExecContext, handleID string) (DriverHandle, error)
}

Driver is used for execution of tasks. This allows Nomad to support many pluggable implementations of task drivers. Examples could include LXC, Docker, Qemu, etc.

func NewDockerDriver 

func NewDockerDriver(ctx *DriverContext) Driver

func NewDriver 

func NewDriver(name string, ctx *DriverContext) (Driver, error)

NewDriver is used to instantiate and return a new driver given the name and a logger

func NewExecDriver 

func NewExecDriver(ctx *DriverContext) Driver

NewExecDriver is used to create a new exec driver

func NewJavaDriver 

func NewJavaDriver(ctx *DriverContext) Driver

NewJavaDriver is used to create a new exec driver

func NewQemuDriver 

func NewQemuDriver(ctx *DriverContext) Driver

NewQemuDriver is used to create a new exec driver

func NewRawExecDriver added in v0.2.0 

func NewRawExecDriver(ctx *DriverContext) Driver

NewRawExecDriver is used to create a new raw exec driver

func NewRktDriver added in v0.2.0 

func NewRktDriver(ctx *DriverContext) Driver

NewRktDriver is used to create a new exec driver

type DriverContext 

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

DriverContext is a means to inject dependencies such as loggers, configs, and node attributes into a Driver without having to change the Driver interface each time we do it. Used in conjection with Factory, above.

func NewDriverContext 

func NewDriverContext(taskName string, config *config.Config, node *structs.Node, logger *log.Logger) *DriverContext

NewDriverContext initializes a new DriverContext with the specified fields. This enables other packages to create DriverContexts but keeps the fields private to the driver. If we want to change this later we can gorename all of the fields in DriverContext.

type DriverHandle 

type DriverHandle interface {
	// Returns an opaque handle that can be used to re-open the handle
	ID() string

	// WaitCh is used to return a channel used wait for task completion
	WaitCh() chan *cstructs.WaitResult

	// Update is used to update the task if possible
	Update(task *structs.Task) error

	// Kill is used to stop the task
	Kill() error
}

DriverHandle is an opaque handle into a driver used for task manipulation

type ExecContext 

type ExecContext struct {
	sync.Mutex

	// AllocDir contains information about the alloc directory structure.
	AllocDir *allocdir.AllocDir

	// Alloc ID
	AllocID string
}

ExecContext is shared between drivers within an allocation

func NewExecContext 

func NewExecContext(alloc *allocdir.AllocDir, allocID string) *ExecContext

NewExecContext is used to create a new execution context

type ExecDriver 

type ExecDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

ExecDriver fork/execs tasks using as many of the underlying OS's isolation features.

func (*ExecDriver) Fingerprint 

func (d *ExecDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*ExecDriver) Open 

func (d *ExecDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*ExecDriver) Start 

func (d *ExecDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

type ExecDriverConfig added in v0.2.0 

type ExecDriverConfig struct {
	ArtifactSource string   `mapstructure:"artifact_source"`
	Checksum       string   `mapstructure:"checksum"`
	Command        string   `mapstructure:"command"`
	Args           []string `mapstructure:"args"`
}

type Factory 

type Factory func(*DriverContext) Driver

Factory is used to instantiate a new Driver

type JavaDriver 

type JavaDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

JavaDriver is a simple driver to execute applications packaged in Jars. It literally just fork/execs tasks with the java command.

func (*JavaDriver) Fingerprint 

func (d *JavaDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*JavaDriver) Open 

func (d *JavaDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*JavaDriver) Start 

func (d *JavaDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

type JavaDriverConfig added in v0.2.0 

type JavaDriverConfig struct {
	JvmOpts        []string `mapstructure:"jvm_options"`
	ArtifactSource string   `mapstructure:"artifact_source"`
	Checksum       string   `mapstructure:"checksum"`
	Args           []string `mapstructure:"args"`
}

type QemuDriver 

type QemuDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

QemuDriver is a driver for running images via Qemu We attempt to chose sane defaults for now, with more configuration available planned in the future

func (*QemuDriver) Fingerprint 

func (d *QemuDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*QemuDriver) Open 

func (d *QemuDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*QemuDriver) Start 

func (d *QemuDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

Run an existing Qemu image. Start() will pull down an existing, valid Qemu image and save it to the Drivers Allocation Dir

type QemuDriverConfig added in v0.2.0 

type QemuDriverConfig struct {
	ArtifactSource string           `mapstructure:"artifact_source"`
	Checksum       string           `mapstructure:"checksum"`
	Accelerator    string           `mapstructure:"accelerator"`
	PortMap        []map[string]int `mapstructure:"port_map"` // A map of host port labels and to guest ports.
}

type RawExecDriver added in v0.2.0 

type RawExecDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

The RawExecDriver is a privileged version of the exec driver. It provides no resource isolation and just fork/execs. The Exec driver should be preferred and this should only be used when explicitly needed.

func (*RawExecDriver) Fingerprint added in v0.2.0 

func (d *RawExecDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*RawExecDriver) Open added in v0.2.0 

func (d *RawExecDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*RawExecDriver) Start added in v0.2.0 

func (d *RawExecDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

type RktDriver added in v0.2.0 

type RktDriver struct {
	DriverContext
	fingerprint.StaticFingerprinter
}

RktDriver is a driver for running images via Rkt We attempt to chose sane defaults for now, with more configuration available planned in the future

func (*RktDriver) Fingerprint added in v0.2.0 

func (d *RktDriver) Fingerprint(cfg *config.Config, node *structs.Node) (bool, error)

func (*RktDriver) Open added in v0.2.0 

func (d *RktDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

func (*RktDriver) Start added in v0.2.0 

func (d *RktDriver) Start(ctx *ExecContext, task *structs.Task) (DriverHandle, error)

Run an existing Rkt image.

type RktDriverConfig added in v0.2.0 

type RktDriverConfig struct {
	ImageName string   `mapstructure:"image"`
	Args      []string `mapstructure:"args"`
}

Source Files

View all Source files

Directories

Path Synopsis
Package executor is used to invoke child processes across various operating systems in a way that provides the following features: - Least privilege - Resource constraints - Process isolation An operating system may be something like "windows" or "linux with systemd".
 Package executor is used to invoke child processes across various operating systems in a way that provides the following features: - Least privilege - Resource constraints - Process isolation An operating system may be something like "windows" or "linux with systemd".

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.