Versions in this module Expand all Collapse all v0 v0.0.2 Sep 30, 2015 v0.0.1 Sep 15, 2015 Changes in this version + type DriverConfig struct + BindingAddress net.IP + BindingPort uint16 + Executor Executor + HostnameOverride string + NewMessenger func() (messenger.Messenger, error) + PublishedAddress net.IP + type Executor interface + Disconnected func(ExecutorDriver) + Error func(ExecutorDriver, string) + FrameworkMessage func(ExecutorDriver, string) + KillTask func(ExecutorDriver, *mesosproto.TaskID) + LaunchTask func(ExecutorDriver, *mesosproto.TaskInfo) + Registered func(ExecutorDriver, *mesosproto.ExecutorInfo, *mesosproto.FrameworkInfo, ...) + Reregistered func(ExecutorDriver, *mesosproto.SlaveInfo) + Shutdown func(ExecutorDriver) + type ExecutorDriver interface + Abort func() (mesosproto.Status, error) + Join func() (mesosproto.Status, error) + Run func() (mesosproto.Status, error) + SendFrameworkMessage func(string) (mesosproto.Status, error) + SendStatusUpdate func(*mesosproto.TaskStatus) (mesosproto.Status, error) + Start func() (mesosproto.Status, error) + Stop func() (mesosproto.Status, error) + type MesosExecutorDriver struct + func NewMesosExecutorDriver(config DriverConfig) (*MesosExecutorDriver, error) + func (driver *MesosExecutorDriver) Abort() (mesosproto.Status, error) + func (driver *MesosExecutorDriver) Connected() bool + func (driver *MesosExecutorDriver) Join() (mesosproto.Status, error) + func (driver *MesosExecutorDriver) Run() (mesosproto.Status, error) + func (driver *MesosExecutorDriver) Running() bool + func (driver *MesosExecutorDriver) SendFrameworkMessage(data string) (mesosproto.Status, error) + func (driver *MesosExecutorDriver) SendStatusUpdate(taskStatus *mesosproto.TaskStatus) (mesosproto.Status, error) + func (driver *MesosExecutorDriver) Start() (mesosproto.Status, error) + func (driver *MesosExecutorDriver) Status() mesosproto.Status + func (driver *MesosExecutorDriver) Stop() (mesosproto.Status, error) + type MockedExecutor struct + func NewMockedExecutor() *MockedExecutor + func (e *MockedExecutor) Disconnected(ExecutorDriver) + func (e *MockedExecutor) Error(ExecutorDriver, string) + func (e *MockedExecutor) FrameworkMessage(ExecutorDriver, string) + func (e *MockedExecutor) KillTask(ExecutorDriver, *mesosproto.TaskID) + func (e *MockedExecutor) LaunchTask(ExecutorDriver, *mesosproto.TaskInfo) + func (e *MockedExecutor) Registered(ExecutorDriver, *mesosproto.ExecutorInfo, *mesosproto.FrameworkInfo, ...) + func (e *MockedExecutor) Reregistered(ExecutorDriver, *mesosproto.SlaveInfo) + func (e *MockedExecutor) Shutdown(ExecutorDriver)
Go to main page