internal

Documentation

Index

• Constants
• Variables
• type ContainerDelegate
  • func NewContainerDelegate(client executor.Client) ContainerDelegate
• type LRPProcessor
  • func NewLRPProcessor(bbsClient bbs.Client, containerDelegate ContainerDelegate, cellID string, ...) LRPProcessor
• type TaskProcessor
  • func NewTaskProcessor(bbs bbs.Client, containerDelegate ContainerDelegate, cellID string) TaskProcessor

Constants

const MAX_RESULT_SIZE = 1024 * 10

const TaskCompletionReasonFailedToFetchResult = "failed to fetch result"

const TaskCompletionReasonFailedToRunContainer = "failed to run container"

const TaskCompletionReasonInvalidTransition = "invalid state transition"

const TaskCompletionReasonMissingContainer = "task container does not exist"

Variables

var ErrResultFileTooLarge = errors.New(
	fmt.Sprintf("result file is too large (over %d bytes)", MAX_RESULT_SIZE),
)

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

type LRPProcessor interface {
	Process(lager.Logger, executor.Container)
}

func NewLRPProcessor

func NewLRPProcessor(
	bbsClient bbs.Client,
	containerDelegate ContainerDelegate,
	cellID string,
	evacuationReporter evacuation_context.EvacuationReporter,
	evacuationTTLInSeconds uint64,
) LRPProcessor

type TaskProcessor

type TaskProcessor interface {
	Process(lager.Logger, executor.Container)
}

func NewTaskProcessor

func NewTaskProcessor(bbs bbs.Client, containerDelegate ContainerDelegate, cellID string) TaskProcessor