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) BeforeTransitionStart() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) NotifyTransitionFinish(signalChan chan struct{})
  • func (s *HangUpTaskHandler) Start() (bool, error)
  • func (s *HangUpTaskHandler) StartTransitionTask(chan struct{}) (bool, error)
  • func (s *HangUpTaskHandler) Stop() error
  • func (s *HangUpTaskHandler) TransitionError() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *HangUpTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)
• type OrdinaryTaskHandler
  • func (s *OrdinaryTaskHandler) BeforeTransitionStart() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) Start() (bool, error)
  • func (s *OrdinaryTaskHandler) StartTransitionTask(chan struct{}) (bool, error)
  • func (s *OrdinaryTaskHandler) Stop() error
  • func (s *OrdinaryTaskHandler) TransitionError() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *OrdinaryTaskHandler) TransitionFinish() (*types.TaskContext, *types.TaskStatus, error)
• type RetryTaskHandler
  • func (s *RetryTaskHandler) BeforeTransitionStart() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *RetryTaskHandler) HeartBeat() (*types.TaskContext, *types.TaskStatus, error)
  • func (s *RetryTaskHandler) NotifyTransitionFinish(signalChan chan struct{})
  • func (s *RetryTaskHandler) Start() (bool, error)
  • func (s *RetryTaskHandler) StartTransitionTask(chan struct{}) (bool, error)
  • func (s *RetryTaskHandler) Stop() error
  • func (s *RetryTaskHandler) TransitionError() (*types.TaskContext, *types.TaskStatus, 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) BeforeTransitionStart

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

func (*HangUpTaskHandler) HeartBeat

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

func (*HangUpTaskHandler) NotifyTransitionFinish

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

func (*HangUpTaskHandler) Start

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

func (*HangUpTaskHandler) StartTransitionTask

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

func (*HangUpTaskHandler) Stop

func (s *HangUpTaskHandler) Stop() error

func (*HangUpTaskHandler) TransitionError

func (s *HangUpTaskHandler) TransitionError() (*types.TaskContext, *types.TaskStatus, 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) BeforeTransitionStart

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

func (*OrdinaryTaskHandler) HeartBeat

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

func (*OrdinaryTaskHandler) Start

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

func (*OrdinaryTaskHandler) StartTransitionTask

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

func (*OrdinaryTaskHandler) Stop

func (s *OrdinaryTaskHandler) Stop() error

func (*OrdinaryTaskHandler) TransitionError

func (s *OrdinaryTaskHandler) TransitionError() (*types.TaskContext, *types.TaskStatus, 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) BeforeTransitionStart

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

func (*RetryTaskHandler) HeartBeat

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

func (*RetryTaskHandler) NotifyTransitionFinish

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

func (*RetryTaskHandler) Start

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

func (*RetryTaskHandler) StartTransitionTask

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

func (*RetryTaskHandler) Stop

func (s *RetryTaskHandler) Stop() error

func (*RetryTaskHandler) TransitionError

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

func (*RetryTaskHandler) TransitionFinish

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