taskworkpool

package
v0.0.0-...-2942e7d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const MAX_CB_RETRIES = 3

Variables

This section is empty.

Functions

func HandleCompletedTask

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

Types

type CompletedTaskHandler

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

type TaskCompletionClient

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

type TaskCompletionWorkPool

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

func New

func New(logger lager.Logger, maxWorkers int, cbHandler CompletedTaskHandler, tlsConfig *tls.Config, requestTimeout time.Duration) *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, taskHub events.Hub, task *models.Task)

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL