auctioncellrep

Documentation

Index

• Variables
• func GenerateGuid() (string, error)
• type AuctionCellClient
• type AuctionCellRep
  • func New(cellID string, cellIndex int, repURL string, ...) *AuctionCellRep
  • func (a *AuctionCellRep) Metrics(logger lager.Logger) (*rep.ContainerMetricsCollection, error)
  • func (a *AuctionCellRep) Perform(logger lager.Logger, traceID string, work rep.Work) (rep.Work, error)
  • func (a *AuctionCellRep) Reset() error
  • func (a *AuctionCellRep) State(logger lager.Logger) (rep.CellState, bool, error)
• type BatchContainerAllocator
  • func NewContainerAllocator(instanceGuidGenerator func() (string, error), stackPathMap rep.StackPathMap, ...) BatchContainerAllocator

Variables

var ErrCellIdMismatch = errors.New("workload cell ID does not match this cell")

var ErrCellUnhealthy = errors.New("internal cell healthcheck failed")

var ErrNotEnoughMemory = errors.New("not enough memory for container and additional memory allocation")

Functions

func GenerateGuid

func GenerateGuid() (string, error)

Types

type AuctionCellClient

type AuctionCellClient interface {
	State(logger lager.Logger) (rep.CellState, bool, error)
	Perform(logger lager.Logger, traceID string, work rep.Work) (rep.Work, error)
	Reset() error
}

type AuctionCellRep

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

func New

func New(
	cellID string,
	cellIndex int,
	repURL string,
	preloadedStackPathMap rep.StackPathMap,
	containerMetricsProvider rep.ContainerMetricsProvider,
	arbitraryRootFSes []string,
	zone string,
	client executor.Client,
	evacuationReporter evacuation_context.EvacuationReporter,
	placementTags []string,
	optionalPlacementTags []string,
	proxyMemoryAllocation int,
	enableContainerProxy bool,
	allocator BatchContainerAllocator,
) *AuctionCellRep

func (*AuctionCellRep) Metrics

func (a *AuctionCellRep) Metrics(logger lager.Logger) (*rep.ContainerMetricsCollection, error)

func (*AuctionCellRep) Perform

func (a *AuctionCellRep) Perform(logger lager.Logger, traceID string, work rep.Work) (rep.Work, error)

func (*AuctionCellRep) Reset

func (a *AuctionCellRep) Reset() error

func (*AuctionCellRep) State

func (a *AuctionCellRep) State(logger lager.Logger) (rep.CellState, bool, error)

type BatchContainerAllocator

type BatchContainerAllocator interface {
	BatchLRPAllocationRequest(lager.Logger, string, bool, int, []rep.LRP) []rep.LRP
	BatchTaskAllocationRequest(lager.Logger, string, []rep.Task) []rep.Task
}

func NewContainerAllocator

func NewContainerAllocator(instanceGuidGenerator func() (string, error), stackPathMap rep.StackPathMap, executorClient executor.Client) BatchContainerAllocator