taskworkpool

package

v1.26.0 Latest Latest Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 14 Imported by: 28

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudfoundry/bbs

Links

Open Source Insights

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, taskHub events.Hub, task *models.Task)

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)

Source Files ¶

View all Source files

Directories ¶

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

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