runner

Documentation

Index

• func LogCall(c *scheduler.Call, log *zap.Logger)
• func LogEvent(e *scheduler.Event, log *zap.Logger)
• func Mux(db *state.State, c *Context) events.Handler
• func Run(profile *config.Profile, tasks []*mesos.TaskInfo) (err error)
• type Context
  • func (c Context) Done() bool
  • func (c *Context) Error(err error)
  • func (c Context) FrameworkID() string
• type ErrRunnerFailed
  • func (e ErrRunnerFailed) Error() string

Functions

func LogCall

func LogCall(c *scheduler.Call, log *zap.Logger)

func LogEvent

func LogEvent(e *scheduler.Event, log *zap.Logger)

func Mux

func Mux(db *state.State, c *Context) events.Handler

func Run

func Run(profile *config.Profile, tasks []*mesos.TaskInfo) (err error)

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

func (Context) Done

func (c Context) Done() bool

func (*Context) Error

func (c *Context) Error(err error)

func (Context) FrameworkID

func (c Context) FrameworkID() string

type ErrRunnerFailed

type ErrRunnerFailed struct{ *scheduler.Event }

func (ErrRunnerFailed) Error

func (e ErrRunnerFailed) Error() string