handlers

Documentation

Index

• Constants
• func HangUpTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)
• func OrdinaryTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)
• func RetryTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)
• type HangUpTaskHandler
  • func (s *HangUpTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) NotifyTransitionFinish(signalChan chan struct{})
  • func (s *HangUpTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) Start() (bool, error)
  • func (s *HangUpTaskHandler) StartMigratedTask(chan struct{}) (bool, error)
  • func (s *HangUpTaskHandler) Stop() error
  • func (s *HangUpTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)
• type OrdinaryTaskHandler
  • func (s *OrdinaryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) Start() (bool, error)
  • func (s *OrdinaryTaskHandler) StartMigratedTask(chan struct{}) (bool, error)
  • func (s *OrdinaryTaskHandler) Stop() error
  • func (s *OrdinaryTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)
• type RetryTaskHandler
  • func (s *RetryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *RetryTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *RetryTaskHandler) NotifyTransitionFinish(signalChan chan struct{})
  • func (s *RetryTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *RetryTaskHandler) Start() (bool, error)
  • func (s *RetryTaskHandler) StartMigratedTask(chan struct{}) (bool, error)
  • func (s *RetryTaskHandler) Stop() error
  • func (s *RetryTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)

Constants

const HangUpDuration = 60

const (
	NumOfRetries = 2
)

const OrdinaryTaskDuration = 120

Functions

func HangUpTaskHandlerFactory

func HangUpTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)

func OrdinaryTaskHandlerFactory

func OrdinaryTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)

func RetryTaskHandlerFactory

func RetryTaskHandlerFactory(ctx *types.TaskContext, info *types.WorkerInfo) (types.TaskHandler, error)

Types

type HangUpTaskHandler

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

func (*HangUpTaskHandler) HeartBeat

func (s *HangUpTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)

func (*HangUpTaskHandler) MigrateError

func (s *HangUpTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)

func (*HangUpTaskHandler) NotifyTransitionFinish

func (s *HangUpTaskHandler) NotifyTransitionFinish(signalChan chan struct{})

func (*HangUpTaskHandler) PrepareMigration

func (s *HangUpTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)

func (*HangUpTaskHandler) Start

func (s *HangUpTaskHandler) Start() (bool, error)

func (*HangUpTaskHandler) StartMigratedTask

func (s *HangUpTaskHandler) StartMigratedTask(chan struct{}) (bool, error)

func (*HangUpTaskHandler) Stop

func (s *HangUpTaskHandler) Stop() error

func (*HangUpTaskHandler) TransitionFinish

func (s *HangUpTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)

type OrdinaryTaskHandler

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

func (*OrdinaryTaskHandler) HeartBeat

func (s *OrdinaryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)

func (*OrdinaryTaskHandler) MigrateError

func (s *OrdinaryTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)

func (*OrdinaryTaskHandler) PrepareMigration

func (s *OrdinaryTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)

func (*OrdinaryTaskHandler) Start

func (s *OrdinaryTaskHandler) Start() (bool, error)

func (*OrdinaryTaskHandler) StartMigratedTask

func (s *OrdinaryTaskHandler) StartMigratedTask(chan struct{}) (bool, error)

func (*OrdinaryTaskHandler) Stop

func (s *OrdinaryTaskHandler) Stop() error

func (*OrdinaryTaskHandler) TransitionFinish

func (s *OrdinaryTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)

type RetryTaskHandler

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

func (*RetryTaskHandler) HeartBeat

func (s *RetryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)

func (*RetryTaskHandler) MigrateError

func (s *RetryTaskHandler) MigrateError() (*types.TaskContext, *types.TaskStatus, error)

func (*RetryTaskHandler) NotifyTransitionFinish

func (s *RetryTaskHandler) NotifyTransitionFinish(signalChan chan struct{})

func (*RetryTaskHandler) PrepareMigration

func (s *RetryTaskHandler) PrepareMigration() (*types.TaskContext, *types.TaskStatus, error)

func (*RetryTaskHandler) Start

func (s *RetryTaskHandler) Start() (bool, error)

func (*RetryTaskHandler) StartMigratedTask

func (s *RetryTaskHandler) StartMigratedTask(chan struct{}) (bool, error)

func (*RetryTaskHandler) Stop

func (s *RetryTaskHandler) Stop() error

func (*RetryTaskHandler) TransitionFinish

func (s *RetryTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)