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 AuctionMetricEmitterDelegate ¶
type AuctionMetricEmitterDelegate interface { FetchStatesCompleted(time.Duration) error FailedCellStateRequest() AuctionCompleted(AuctionResults) }
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.