driver

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)