taskworkpool

Documentation

Index

• Constants
• func HandleCompletedTask(logger lager.Logger, httpClient *http.Client, taskDB db.TaskDB, ...)
• type CompletedTaskHandler
• type TaskCompletionClient
• type TaskCompletionWorkPool
  • func New(logger lager.Logger, maxWorkers int, cbHandler CompletedTaskHandler) *TaskCompletionWorkPool
  • func (twp *TaskCompletionWorkPool) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (twp *TaskCompletionWorkPool) Submit(taskDB db.TaskDB, task *models.Task)

Constants

const MAX_CB_RETRIES = 3

Functions

func HandleCompletedTask

func HandleCompletedTask(logger lager.Logger, httpClient *http.Client, taskDB db.TaskDB, task *models.Task)

Types

type CompletedTaskHandler

type CompletedTaskHandler func(logger lager.Logger, httpClient *http.Client, taskDB db.TaskDB, task *models.Task)

type TaskCompletionClient

type TaskCompletionClient interface {
	Submit(taskDB db.TaskDB, task *models.Task)
}

type TaskCompletionWorkPool

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

func New

func New(logger lager.Logger, maxWorkers int, cbHandler CompletedTaskHandler) *TaskCompletionWorkPool

func (*TaskCompletionWorkPool) Run

func (twp *TaskCompletionWorkPool) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*TaskCompletionWorkPool) Submit

func (twp *TaskCompletionWorkPool) Submit(taskDB db.TaskDB, task *models.Task)