Documentation
¶
Index ¶
Constants ¶
View Source
const MAX_RESULT_SIZE = 1024 * 10
View Source
const TaskCompletionReasonFailedToFetchResult = "failed to fetch result"
View Source
const TaskCompletionReasonFailedToRunContainer = "failed to run container"
View Source
const TaskCompletionReasonInvalidTransition = "invalid state transition"
View Source
const TaskCompletionReasonMissingContainer = "task container does not exist"
Variables ¶
View Source
var ErrResultFileTooLarge = errors.New( fmt.Sprintf("result file is too large (over %d bytes)", MAX_RESULT_SIZE), )
Functions ¶
This section is empty.
Types ¶
type ContainerDelegate ¶
type ContainerDelegate interface {
GetContainer(logger lager.Logger, guid string) (executor.Container, bool)
RunContainer(logger lager.Logger, req *executor.RunRequest) bool
StopContainer(logger lager.Logger, guid string) bool
DeleteContainer(logger lager.Logger, guid string) bool
FetchContainerResultFile(logger lager.Logger, guid string, filename string) (string, error)
}
func NewContainerDelegate ¶
func NewContainerDelegate(client executor.Client) ContainerDelegate
type LRPProcessor ¶
func NewLRPProcessor ¶
func NewLRPProcessor( bbsClient bbs.Client, containerDelegate ContainerDelegate, cellID string, evacuationReporter evacuation_context.EvacuationReporter, evacuationTTLInSeconds uint64, ) LRPProcessor
type TaskProcessor ¶
func NewTaskProcessor ¶
func NewTaskProcessor(bbs bbs.Client, containerDelegate ContainerDelegate, cellID string) TaskProcessor
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.