Documentation ¶
Index ¶
- type StartStoper
- type SyslogExecutor
- func (se *SyslogExecutor) Disconnected(executor.ExecutorDriver)
- func (se *SyslogExecutor) Error(driver executor.ExecutorDriver, err string)
- func (se *SyslogExecutor) FrameworkMessage(driver executor.ExecutorDriver, msg string)
- func (se *SyslogExecutor) KillTask(_ executor.ExecutorDriver, taskId *mesos.TaskID)
- func (se *SyslogExecutor) LaunchTask(driver executor.ExecutorDriver, taskInfo *mesos.TaskInfo)
- func (se *SyslogExecutor) Registered(driver executor.ExecutorDriver, execInfo *mesos.ExecutorInfo, ...)
- func (se *SyslogExecutor) Reregistered(driver executor.ExecutorDriver, slaveInfo *mesos.SlaveInfo)
- func (se *SyslogExecutor) Shutdown(executor.ExecutorDriver)
- type SyslogScheduler
- func (ss *SyslogScheduler) Disconnected(scheduler.SchedulerDriver)
- func (ss *SyslogScheduler) Error(driver scheduler.SchedulerDriver, err string)
- func (ss *SyslogScheduler) ExecutorLost(scheduler.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)
- func (ss *SyslogScheduler) FrameworkMessage(scheduler.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)
- func (ss *SyslogScheduler) OfferRescinded(scheduler.SchedulerDriver, *mesos.OfferID)
- func (ss *SyslogScheduler) Registered(driver scheduler.SchedulerDriver, frameworkId *mesos.FrameworkID, ...)
- func (ss *SyslogScheduler) Reregistered(driver scheduler.SchedulerDriver, masterInfo *mesos.MasterInfo)
- func (ss *SyslogScheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesos.Offer)
- func (ss *SyslogScheduler) Shutdown(driver scheduler.SchedulerDriver)
- func (ss *SyslogScheduler) SlaveLost(scheduler.SchedulerDriver, *mesos.SlaveID)
- func (ss *SyslogScheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus)
- type SyslogSchedulerConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StartStoper ¶
type StartStoper interface { Start() Stop() }
type SyslogExecutor ¶
type SyslogExecutor struct {
// contains filtered or unexported fields
}
func NewSyslogExecutor ¶
func NewSyslogExecutor(producer StartStoper) *SyslogExecutor
Creates a new SyslogExecutor with a given config.
func (*SyslogExecutor) Disconnected ¶
func (se *SyslogExecutor) Disconnected(executor.ExecutorDriver)
mesos.Executor interface method. Invoked when the executor becomes "disconnected" from the slave.
func (*SyslogExecutor) Error ¶
func (se *SyslogExecutor) Error(driver executor.ExecutorDriver, err string)
mesos.Executor interface method. Invoked when a fatal error has occured with the executor and/or executor driver.
func (*SyslogExecutor) FrameworkMessage ¶
func (se *SyslogExecutor) FrameworkMessage(driver executor.ExecutorDriver, msg string)
mesos.Executor interface method. Invoked when a framework message has arrived for this executor.
func (*SyslogExecutor) KillTask ¶
func (se *SyslogExecutor) KillTask(_ executor.ExecutorDriver, taskId *mesos.TaskID)
mesos.Executor interface method. Invoked when a task running within this executor has been killed.
func (*SyslogExecutor) LaunchTask ¶
func (se *SyslogExecutor) LaunchTask(driver executor.ExecutorDriver, taskInfo *mesos.TaskInfo)
mesos.Executor interface method. Invoked when a task has been launched on this executor.
func (*SyslogExecutor) Registered ¶
func (se *SyslogExecutor) Registered(driver executor.ExecutorDriver, execInfo *mesos.ExecutorInfo, fwinfo *mesos.FrameworkInfo, slaveInfo *mesos.SlaveInfo)
mesos.Executor interface method. Invoked once the executor driver has been able to successfully connect with Mesos.
func (*SyslogExecutor) Reregistered ¶
func (se *SyslogExecutor) Reregistered(driver executor.ExecutorDriver, slaveInfo *mesos.SlaveInfo)
mesos.Executor interface method. Invoked when the executor re-registers with a restarted slave.
func (*SyslogExecutor) Shutdown ¶
func (se *SyslogExecutor) Shutdown(executor.ExecutorDriver)
mesos.Executor interface method. Invoked when the executor should terminate all of its currently running tasks.
type SyslogScheduler ¶
type SyslogScheduler struct {
// contains filtered or unexported fields
}
func NewSyslogScheduler ¶
func NewSyslogScheduler(config SyslogSchedulerConfig) *SyslogScheduler
func (*SyslogScheduler) Disconnected ¶
func (ss *SyslogScheduler) Disconnected(scheduler.SchedulerDriver)
mesos.Scheduler interface method. Invoked when the scheduler becomes "disconnected" from the master.
func (*SyslogScheduler) Error ¶
func (ss *SyslogScheduler) Error(driver scheduler.SchedulerDriver, err string)
mesos.Scheduler interface method. Invoked when there is an unrecoverable error in the scheduler or scheduler driver.
func (*SyslogScheduler) ExecutorLost ¶
func (ss *SyslogScheduler) ExecutorLost(scheduler.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)
mesos.Scheduler interface method. Invoked when an executor has exited/terminated.
func (*SyslogScheduler) FrameworkMessage ¶
func (ss *SyslogScheduler) FrameworkMessage(scheduler.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)
mesos.Scheduler interface method. Invoked when an executor sends a message.
func (*SyslogScheduler) OfferRescinded ¶
func (ss *SyslogScheduler) OfferRescinded(scheduler.SchedulerDriver, *mesos.OfferID)
mesos.Scheduler interface method. Invoked when an offer is no longer valid.
func (*SyslogScheduler) Registered ¶
func (ss *SyslogScheduler) Registered(driver scheduler.SchedulerDriver, frameworkId *mesos.FrameworkID, masterInfo *mesos.MasterInfo)
mesos.Scheduler interface method. Invoked when the scheduler successfully registers with a Mesos master.
func (*SyslogScheduler) Reregistered ¶
func (ss *SyslogScheduler) Reregistered(driver scheduler.SchedulerDriver, masterInfo *mesos.MasterInfo)
mesos.Scheduler interface method. Invoked when the scheduler re-registers with a newly elected Mesos master.
func (*SyslogScheduler) ResourceOffers ¶
func (ss *SyslogScheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesos.Offer)
mesos.Scheduler interface method. Invoked when resources have been offered to ss framework.
func (*SyslogScheduler) Shutdown ¶
func (ss *SyslogScheduler) Shutdown(driver scheduler.SchedulerDriver)
Gracefully shuts down all running tasks.
func (*SyslogScheduler) SlaveLost ¶
func (ss *SyslogScheduler) SlaveLost(scheduler.SchedulerDriver, *mesos.SlaveID)
mesos.Scheduler interface method. Invoked when a slave has been determined unreachable
func (*SyslogScheduler) StatusUpdate ¶
func (ss *SyslogScheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus)
mesos.Scheduler interface method. Invoked when the status of a task has changed.
type SyslogSchedulerConfig ¶
type SyslogSchedulerConfig struct { // Number of CPUs allocated for each created Mesos task. CpuPerTask float64 // Number of RAM allocated for each created Mesos task. MemPerTask float64 // Artifact server host name. Will be used to fetch the executor. ArtifactServerHost string // Artifact server port.Will be used to fetch the executor. ArtifactServerPort int // Name of the executor archive file. ExecutorArchiveName string // Name of the executor binary file contained in the executor archive. ExecutorBinaryName string // Maximum retries to kill a task. KillTaskRetries int // Number of task instances to run. Instances int // Producer config file name. ProducerConfig string // Topic to produce transformed data to. Topic string // Flag to respond only after decoding-encoding is done. Sync bool LogLevel string // Mesos master ip:port Master string // Broker list BrokerList string }