Versions in this module Expand all Collapse all v0 v0.1442.0 Feb 27, 2024 v0.1441.2 Jan 12, 2016 Changes in this version + const MAX_RESULT_SIZE + const TaskCompletionReasonFailedToFetchResult + const TaskCompletionReasonFailedToRunContainer + const TaskCompletionReasonInvalidTransition + const TaskCompletionReasonMissingContainer + var ErrResultFileTooLarge = errors.New(fmt.Sprintf("result file is too large (over %d bytes)", MAX_RESULT_SIZE)) + type ContainerDelegate interface + DeleteContainer func(logger lager.Logger, guid string) bool + FetchContainerResultFile func(logger lager.Logger, guid string, filename string) (string, error) + GetContainer func(logger lager.Logger, guid string) (executor.Container, bool) + RunContainer func(logger lager.Logger, req *executor.RunRequest) bool + StopContainer func(logger lager.Logger, guid string) bool + func NewContainerDelegate(client executor.Client) ContainerDelegate + type LRPProcessor interface + Process func(lager.Logger, executor.Container) + func NewLRPProcessor(bbsClient bbs.Client, containerDelegate ContainerDelegate, cellID string, ...) LRPProcessor + type TaskProcessor interface + Process func(lager.Logger, executor.Container) + func NewTaskProcessor(bbs bbs.Client, containerDelegate ContainerDelegate, cellID string) TaskProcessor