driver

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

Dec 12, 2016

Changes in this version

type DockerDriver

+ func (d *DockerDriver) Abilities() DriverAbilities

type DockerDriverConfig

+ Logging []DockerLoggingOpts

+ UsernsMode string

+ Volumes []string

type DockerHandle

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

+ type DockerLoggingOpts struct

+ Config map[string]string

+ ConfigRaw []map[string]string

+ Type string

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

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)