Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorCellCommunication = errors.New("unable to communicate to compatible cells")
View Source
var ErrorCellMismatch = errors.New("found no compatible cell for required rootfs")
View Source
var ErrorExceededInflightCreation = errors.New("waiting to start instance: reached in-flight start limit")
View Source
var ErrorNothingToStop = errors.New("nothing to stop")
View Source
var ErrorVolumeDriverMismatch = errors.New("found no compatible cell with required volume drivers")
Functions ¶
Types ¶
type AuctionRecord ¶
type AuctionRecord struct {
Winner string
Attempts int
QueueTime time.Time
WaitDuration time.Duration
PlacementError string
}
func NewAuctionRecord ¶
func NewAuctionRecord(now time.Time) AuctionRecord
type AuctionRequest ¶
type AuctionRequest struct {
LRPs []LRPAuction
Tasks []TaskAuction
}
type AuctionResults ¶
type AuctionResults struct {
SuccessfulLRPs []LRPAuction
SuccessfulTasks []TaskAuction
FailedLRPs []LRPAuction
FailedTasks []TaskAuction
}
type AuctionRunner ¶
type AuctionRunner interface {
ifrit.Runner
ScheduleLRPsForAuctions([]auctioneer.LRPStartRequest, string)
ScheduleTasksForAuctions([]auctioneer.TaskStartRequest, string)
}
type AuctionRunnerDelegate ¶
type LRPAuction ¶
type LRPAuction struct {
rep.LRP
AuctionRecord
}
func NewLRPAuction ¶
func NewLRPAuction(lrp rep.LRP, now time.Time) LRPAuction
func (*LRPAuction) Copy ¶
func (a *LRPAuction) Copy() LRPAuction
type PlacementTagMismatchError ¶
type PlacementTagMismatchError struct {
// contains filtered or unexported fields
}
func (PlacementTagMismatchError) Error ¶
func (e PlacementTagMismatchError) Error() string
type TaskAuction ¶
type TaskAuction struct {
rep.Task
AuctionRecord
}
func NewTaskAuction ¶
func NewTaskAuction(task rep.Task, now time.Time) TaskAuction
func (*TaskAuction) Copy ¶
func (a *TaskAuction) Copy() TaskAuction
Click to show internal directories.
Click to hide internal directories.