driver

Jan 11, 2019

Changes in this version

+ type DockerBindOptions struct

+ Propagation string

type DockerMount

+ BindOptions []*DockerBindOptions

+ Type string

Jun 11, 2018

Changes in this version

type DockerDriverConfig

+ PidsLimit int64

Apr 12, 2018

Changes in this version

+ const ShutdownPeriodicAfter

+ const ShutdownPeriodicDuration

+ func CheckForMockDriver(t *testing.T)

type DockerDriver

+ func (d *DockerDriver) GetHealthCheckInterval(req *cstructs.HealthCheckIntervalRequest, ...) error

+ func (d *DockerDriver) HealthCheck(req *cstructs.HealthCheckRequest, resp *cstructs.HealthCheckResponse) error

type DockerDriverConfig

+ AdvertiseIPv6Address bool

+ CPUHardLimit bool

+ CapAdd []string

+ CapDrop []string

+ Entrypoint []string

+ ReadonlyRootfs bool

type Driver

+ func NewMockDriver(ctx *DriverContext) Driver

+ type MockDriver struct

+ func (d *MockDriver) Abilities() DriverAbilities

+ func (d *MockDriver) FSIsolation() cstructs.FSIsolation

+ func (d *MockDriver) Prestart(*ExecContext, *structs.Task) (*PrestartResponse, error)

+ func (m *MockDriver) Cleanup(ctx *ExecContext, res *CreatedResources) error

+ func (m *MockDriver) Fingerprint(req *cstructs.FingerprintRequest, resp *cstructs.FingerprintResponse) error

+ func (m *MockDriver) GetHealthCheckInterval(req *cstructs.HealthCheckIntervalRequest, ...) error

+ func (m *MockDriver) HealthCheck(req *cstructs.HealthCheckRequest, resp *cstructs.HealthCheckResponse) error

+ func (m *MockDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, error)

+ func (m *MockDriver) Periodic() (bool, time.Duration)

+ func (m *MockDriver) Start(ctx *ExecContext, task *structs.Task) (*StartResponse, error)

+ func (m *MockDriver) Validate(map[string]interface{}) error

+ type MockDriverConfig struct

+ DriverAdvertise bool

+ DriverIP string

+ DriverPortMap string

+ ExitCode int

+ ExitErrMsg string

+ ExitSignal int

+ KillAfter time.Duration

+ RunFor time.Duration

+ SignalErr string

+ StartBlockFor time.Duration

+ StartErr string

+ StartErrRecoverable bool

+ StdoutRepeat int

+ StdoutRepeatDur time.Duration

+ StdoutString string

type RktDriverConfig — linux/amd64

+ Group string

Dec 20, 2017

Changes in this version

+ type DockerDevice struct

+ CgroupPermissions string

+ ContainerPath string

+ HostPath string

type DockerDriverConfig

+ Devices []DockerDevice

+ Sysctl map[string]string

+ SysctlRaw []map[string]string

+ Ulimit []docker.ULimit

+ UlimitRaw []map[string]string

type QemuDriverConfig

+ GracefulShutdown bool

Aug 28, 2017

Changes in this version

type DockerDriverConfig

+ DNSOptions []string

+ Mounts []DockerMount

+ type DockerMount struct

+ ReadOnly bool

+ Source string

+ Target string

+ VolumeOptions *DockerVolumeOptions

+ type DockerVolumeDriverConfig struct

+ Name string

+ Options map[string]string

+ type DockerVolumeOptions struct

+ DriverConfig DockerVolumeDriverConfig

+ Labels map[string]string

+ NoCopy bool

Jul 26, 2017

Changes in this version

+ func SetEnvvars(envBuilder *env.Builder, fsi cstructs.FSIsolation, taskDir *allocdir.TaskDir, ...)

type CreatedResources

+ func (r *CreatedResources) Hash() []byte

type DockerDriverConfig

+ AuthSoftFail bool

+ ExtraHosts []string

+ IPv4Address string

+ IPv6Address string

+ MacAddress string

+ SecurityOpt []string

type DockerHandle

+ func (h *DockerHandle) Exec(ctx context.Context, cmd string, args []string) ([]byte, int, error)

type DriverAbilities

+ Exec bool

+ type ExecCmdArgs struct

+ Args []string

+ Deadline time.Time

+ Name string

+ type ExecCmdReturn struct

+ Code int

+ Output []byte

type ExecContext

+ TaskEnv *env.TaskEnv

type ExecutorRPC

+ func (e *ExecutorRPC) Exec(deadline time.Time, name string, args []string) ([]byte, int, error)

type ExecutorRPCServer

+ func (e *ExecutorRPCServer) Exec(args ExecCmdArgs, result *ExecCmdReturn) error

+ type PrestartResponse struct

+ CreatedResources *CreatedResources

+ Network *cstructs.DriverNetwork

+ func NewPrestartResponse() *PrestartResponse

type RktDriverConfig

+ InsecureOptions []string

+ NoOverlay bool

+ type ScriptExecutor interface

+ Exec func(ctx context.Context, cmd string, args []string) ([]byte, int, error)

+ type StartResponse struct

+ Handle DriverHandle

+ Network *cstructs.DriverNetwork

Mar 14, 2017

Changes in this version

+ func GetDockerCoordinator(config *dockerCoordinatorConfig) *dockerCoordinator

+ func NewDockerCoordinator(config *dockerCoordinatorConfig) *dockerCoordinator

type DockerDriverConfig

+ LoadImage string

+ VolumeDriver string

type DockerHandle

+ Image string

+ ImageID string

+ type DockerImageClient interface

+ InspectImage func(id string) (*docker.Image, error)

+ PullImage func(opts docker.PullImageOptions, auth docker.AuthConfiguration) error

+ RemoveImage func(id string) error

Jan 30, 2017

Changes in this version

+ var DriverStatsNotImplemented = errors.New("stats not implemented for driver")

+ type CreatedResources struct

+ Resources map[string][]string

+ func NewCreatedResources() *CreatedResources

+ func (r *CreatedResources) Add(k, v string)

+ func (r *CreatedResources) Copy() *CreatedResources

+ func (r *CreatedResources) Merge(o *CreatedResources)

+ func (r *CreatedResources) Remove(k, needle string) bool

type DockerDriver

+ func (d *DockerDriver) Cleanup(_ *ExecContext, res *CreatedResources) error

+ func (d *DockerDriver) FSIsolation() cstructs.FSIsolation

type DockerDriverConfig

+ ForcePull bool

type Driver

+ Cleanup func(*ExecContext, *CreatedResources) error

+ FSIsolation func() cstructs.FSIsolation

type ExecContext

+ TaskDir *allocdir.TaskDir

type ExecDriver

+ func (d *ExecDriver) Cleanup(*ExecContext, *CreatedResources) error

+ func (d *ExecDriver) FSIsolation() cstructs.FSIsolation

type JavaDriver

+ func (d *JavaDriver) Cleanup(*ExecContext, *CreatedResources) error

+ func (d *JavaDriver) FSIsolation() cstructs.FSIsolation

type JavaDriverConfig

+ Class string

+ ClassPath string

+ func NewJavaDriverConfig(task *structs.Task, env *env.TaskEnvironment) (*JavaDriverConfig, error)

type QemuDriver

+ func (d *QemuDriver) Cleanup(*ExecContext, *CreatedResources) error

+ func (d *QemuDriver) FSIsolation() cstructs.FSIsolation

type RawExecDriver

+ func (d *RawExecDriver) Cleanup(*ExecContext, *CreatedResources) error

+ func (d *RawExecDriver) FSIsolation() cstructs.FSIsolation

type RktDriver

+ func (d *RktDriver) Cleanup(*ExecContext, *CreatedResources) error

+ func (d *RktDriver) FSIsolation() cstructs.FSIsolation

Dec 21, 2016

Changes in this version

type DockerDriver

+ func (d *DockerDriver) Prestart(ctx *ExecContext, task *structs.Task) error

type DockerDriverConfig

+ NetworkAliases []string

type Driver

+ Prestart func(*ExecContext, *structs.Task) error

type ExecDriver

+ func (d *ExecDriver) Prestart(execctx *ExecContext, task *structs.Task) error

type JavaDriver

+ func (d *JavaDriver) Prestart(ctx *ExecContext, task *structs.Task) error

+ type LogEventFn func(message string, args ...interface{})

type QemuDriver

+ func (d *QemuDriver) Prestart(ctx *ExecContext, task *structs.Task) error

type RawExecDriver

+ func (d *RawExecDriver) Prestart(ctx *ExecContext, task *structs.Task) error

type RktDriver

+ func (d *RktDriver) Prestart(ctx *ExecContext, task *structs.Task) error

Nov 16, 2016

Changes in this version

type DockerDriver

+ func (d *DockerDriver) Abilities() DriverAbilities

type DockerDriverConfig

+ UsernsMode string

type DockerHandle

+ func (h *DockerHandle) Signal(s os.Signal) error

type Driver

+ Abilities func() DriverAbilities

+ type DriverAbilities struct

+ SendSignals bool

type DriverHandle

+ Signal func(s os.Signal) error

type ExecDriver

+ func (d *ExecDriver) Abilities() DriverAbilities

type ExecutorRPC

+ func (e *ExecutorRPC) SetContext(ctx *executor.ExecutorContext) error

+ func (e *ExecutorRPC) Signal(s os.Signal) error

type ExecutorRPCServer

+ func (e *ExecutorRPCServer) SetContext(args *executor.ExecutorContext, resp *interface{}) error

+ func (e *ExecutorRPCServer) Signal(args os.Signal, resp *interface{}) error

type JavaDriver

+ func (d *JavaDriver) Abilities() DriverAbilities

type QemuDriver

+ func (d *QemuDriver) Abilities() DriverAbilities

type RawExecDriver

+ func (d *RawExecDriver) Abilities() DriverAbilities

type RktDriver

+ func (d *RktDriver) Abilities() DriverAbilities

+ func (d *RktDriver) Periodic() (bool, time.Duration)

type RktDriverConfig

+ Net []string

+ PortMap map[string]string

+ PortMapRaw []map[string]string

+ Volumes []string

Sep 21, 2016

Changes in this version

type DockerDriverConfig

+ Logging []DockerLoggingOpts

+ Volumes []string

+ VolumesFrom []string

+ type DockerLoggingOpts struct

+ Config map[string]string

+ ConfigRaw []map[string]string

+ Type string

Aug 17, 2016

Changes in this version

type DockerDriverConfig

+ WorkDir string

type QemuDriverConfig

+ Args []string

type RktDriverConfig

+ Command string

+ Debug bool

+ TrustPrefix string

Jun 28, 2016

Changes in this version

+ var DockerMeasuredCpuStats = []string

+ var DockerMeasuredMemStats = []string

type DockerDriverConfig

+ ShmSize int64

+ func NewDockerDriverConfig(task *structs.Task) (*DockerDriverConfig, error)

type DockerHandle

+ func (h *DockerHandle) Stats() (*cstructs.TaskResourceUsage, error)

type DriverHandle

+ Stats func() (*cstructs.TaskResourceUsage, error)

type ExecutorRPC

+ func (e *ExecutorRPC) Stats() (*cstructs.TaskResourceUsage, error)

type ExecutorRPCServer

+ func (e *ExecutorRPCServer) Stats(args interface{}, resourceUsage *cstructs.TaskResourceUsage) error

Apr 22, 2016

Changes in this version

type DockerDriver

+ func (d *DockerDriver) Validate(config map[string]interface{}) error

type DockerDriverConfig

+ Interactive bool

+ LoadImages []string

+ TTY bool

type Driver

+ Validate func(map[string]interface{}) error

type DriverContext

+ func NewEmptyDriverContext() *DriverContext

type ExecDriver

+ func (d *ExecDriver) Validate(config map[string]interface{}) error

type ExecutorRPC

+ func (e *ExecutorRPC) DeregisterServices() error

+ func (e *ExecutorRPC) LaunchSyslogServer(ctx *executor.ExecutorContext) (*executor.SyslogServerState, error)

+ func (e *ExecutorRPC) SyncServices(ctx *executor.ConsulContext) error

+ func (e *ExecutorRPC) UpdateTask(task *structs.Task) error

+ func (e *ExecutorRPC) Version() (*executor.ExecutorVersion, error)

type ExecutorRPCServer

+ func (e *ExecutorRPCServer) DeregisterServices(args interface{}, resp *interface{}) error

+ func (e *ExecutorRPCServer) LaunchSyslogServer(args LaunchSyslogServerArgs, ss *executor.SyslogServerState) error

+ func (e *ExecutorRPCServer) SyncServices(args SyncServicesArgs, resp *interface{}) error

+ func (e *ExecutorRPCServer) UpdateTask(args *structs.Task, resp *interface{}) error

+ func (e *ExecutorRPCServer) Version(args interface{}, version *executor.ExecutorVersion) error

type JavaDriver

+ func (d *JavaDriver) Validate(config map[string]interface{}) error

+ type LaunchSyslogServerArgs struct

+ Ctx *executor.ExecutorContext

type QemuDriver

+ func (d *QemuDriver) Validate(config map[string]interface{}) error

type RawExecDriver

+ func (d *RawExecDriver) Validate(config map[string]interface{}) error

type RktDriver

+ func (d *RktDriver) Validate(config map[string]interface{}) error

+ type SyncServicesArgs struct

+ Ctx *executor.ConsulContext

Mar 16, 2016

Changes in this version

+ const NoSuchContainerError

+ func GetAbsolutePath(bin string) (string, error)

+ func GetKillTimeout(desired, max time.Duration) time.Duration

type DockerDriver

+ func (d *DockerDriver) Periodic() (bool, time.Duration)

type DockerDriverConfig

+ SSL bool

+ func (c *DockerDriverConfig) Init() error

type JavaDriverConfig

+ JarPath string

type QemuDriverConfig

+ ImagePath string

type RktDriverConfig

+ DNSSearchDomains []string

+ DNSServers []string

Feb 25, 2016

Changes in this version

+ var HandshakeConfig = plugin.HandshakeConfig

+ func GetPluginMap(w io.Writer) map[string]plugin.Plugin

+ func GetTaskEnv(alloc *allocdir.AllocDir, node *structs.Node, task *structs.Task) (*env.TaskEnvironment, error)

type DockerDriverConfig

+ IpcMode string

+ PidMode string

+ UTSMode string

type DriverContext

+ func (d *DriverContext) KillTimeout(task *structs.Task) time.Duration

type ExecDriver

+ func (d *ExecDriver) Periodic() (bool, time.Duration)

+ type ExecutorPlugin struct

+ Impl *ExecutorRPCServer

+ func (p *ExecutorPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (p *ExecutorPlugin) Server(*plugin.MuxBroker) (interface{}, error)

+ type ExecutorRPC struct

+ func (e *ExecutorRPC) Exit() error

+ func (e *ExecutorRPC) LaunchCmd(cmd *executor.ExecCommand, ctx *executor.ExecutorContext) (*executor.ProcessState, error)

+ func (e *ExecutorRPC) ShutDown() error

+ func (e *ExecutorRPC) UpdateLogConfig(logConfig *structs.LogConfig) error

+ func (e *ExecutorRPC) Wait() (*executor.ProcessState, error)

+ type ExecutorRPCServer struct

+ Impl executor.Executor

+ func (e *ExecutorRPCServer) Exit(args interface{}, resp *interface{}) error

+ func (e *ExecutorRPCServer) LaunchCmd(args LaunchCmdArgs, ps *executor.ProcessState) error

+ func (e *ExecutorRPCServer) ShutDown(args interface{}, resp *interface{}) error

+ func (e *ExecutorRPCServer) UpdateLogConfig(args *structs.LogConfig, resp *interface{}) error

+ func (e *ExecutorRPCServer) Wait(args interface{}, ps *executor.ProcessState) error

+ type LaunchCmdArgs struct

+ Cmd *executor.ExecCommand

+ Ctx *executor.ExecutorContext

+ type LaunchCollectorArgs struct

+ Ctx *logging.LogCollectorContext

+ type PluginReattachConfig struct

+ AddrName string

+ AddrNet string

+ Pid int

+ func NewPluginReattachConfig(c *plugin.ReattachConfig) *PluginReattachConfig

+ func (c *PluginReattachConfig) PluginConfig() *plugin.ReattachConfig

+ type SyslogCollectorPlugin struct

+ Impl *SyslogCollectorRPCServer

+ func (p *SyslogCollectorPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (p *SyslogCollectorPlugin) Server(*plugin.MuxBroker) (interface{}, error)

+ type SyslogCollectorRPC struct

+ func (e *SyslogCollectorRPC) Exit() error

+ func (e *SyslogCollectorRPC) LaunchCollector(ctx *logging.LogCollectorContext) (*logging.SyslogCollectorState, error)

+ func (e *SyslogCollectorRPC) UpdateLogConfig(logConfig *structs.LogConfig) error

+ type SyslogCollectorRPCServer struct

+ Impl logging.LogCollector

+ func (s *SyslogCollectorRPCServer) Exit(args interface{}, resp *interface{}) error

+ func (s *SyslogCollectorRPCServer) LaunchCollector(args LaunchCollectorArgs, resp *logging.SyslogCollectorState) error

+ func (s *SyslogCollectorRPCServer) UpdateLogConfig(logConfig *structs.LogConfig, resp *interface{}) error

Nov 28, 2015

Changes in this version

type DockerDriverConfig

+ LabelsRaw []map[string]string

+ PortMapRaw []map[string]int

+ type DockerHandle struct

+ func (h *DockerHandle) ContainerID() string

+ func (h *DockerHandle) ID() string

+ func (h *DockerHandle) Kill() error

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

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

Nov 19, 2015

Changes in this version

+ type DockerDriverAuth struct

+ Email string

+ Password string

+ ServerAddress string

+ Username string

+ type DockerDriverConfig struct

+ Args []string

+ Auth []DockerDriverAuth

+ Command string

+ DNSSearchDomains []string

+ DNSServers []string

+ Hostname string

+ ImageName string

+ Labels []map[string]string

+ NetworkMode string

+ PortMap []map[string]int

+ Privileged bool

+ func (c *DockerDriverConfig) Validate() error

type Driver

+ func NewRawExecDriver(ctx *DriverContext) Driver

+ func NewRktDriver(ctx *DriverContext) Driver

type ExecContext

+ AllocID string

+ type ExecDriverConfig struct

+ Args []string

+ ArtifactSource string

+ Checksum string

+ Command string

+ type JavaDriverConfig struct

+ Args []string

+ ArtifactSource string

+ Checksum string

+ JvmOpts []string

+ type QemuDriverConfig struct

+ Accelerator string

+ ArtifactSource string

+ Checksum string

+ PortMap []map[string]int

+ type RawExecDriver struct

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

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

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

+ type RktDriver struct

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

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

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

+ type RktDriverConfig struct

+ Args []string

+ ImageName string

Sep 28, 2015

Changes in this version

+ var BuiltinDrivers = map[string]Factory

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

+ type DockerDriver struct

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

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

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

+ type Driver interface

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

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

+ func NewDockerDriver(ctx *DriverContext) Driver

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

+ func NewExecDriver(ctx *DriverContext) Driver

+ func NewJavaDriver(ctx *DriverContext) Driver

+ func NewQemuDriver(ctx *DriverContext) Driver

+ type DriverContext struct

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

+ type DriverHandle interface

+ ID func() string

+ Kill func() error

+ Update func(task *structs.Task) error

+ WaitCh func() chan error

+ type ExecContext struct

+ AllocDir *allocdir.AllocDir

+ func NewExecContext(alloc *allocdir.AllocDir) *ExecContext

+ type ExecDriver struct

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

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

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

+ type Factory func(*DriverContext) Driver

+ type JavaDriver struct

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

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

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

+ type QemuDriver struct

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

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

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