executor

Documentation

Index

• type DefaultExecutor
  • func (e *DefaultExecutor) Message(data []byte) error
  • func (e *DefaultExecutor) Subscribe(eventChan chan *exec.Event) error
  • func (e *DefaultExecutor) Update(taskStatus *mesos_v1.TaskStatus) error
• type Executor
  • func NewDefaultExecutor(f *mesos_v1.FrameworkID, e *mesos_v1.ExecutorID, c client.Client, ...) Executor

Types

type DefaultExecutor

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

func (*DefaultExecutor) Message

func (e *DefaultExecutor) Message(data []byte) error

func (*DefaultExecutor) Subscribe

func (e *DefaultExecutor) Subscribe(eventChan chan *exec.Event) error

func (*DefaultExecutor) Update

func (e *DefaultExecutor) Update(taskStatus *mesos_v1.TaskStatus) error

type Executor

type Executor interface {
	Subscribe(chan *exec.Event) error
	Update(*mesos_v1.TaskStatus) error
	Message([]byte) error
}

func NewDefaultExecutor

func NewDefaultExecutor(
	f *mesos_v1.FrameworkID,
	e *mesos_v1.ExecutorID,
	c client.Client,
	lgr logging.Logger) Executor

Creates a new default executor