syslog

Documentation

Index

• type StartStoper
• type SyslogExecutor
  • func NewSyslogExecutor(producer StartStoper) *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 NewSyslogScheduler(config SyslogSchedulerConfig) *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

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
}