auctiontypes

package
v0.0.0-...-a0b5f6c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2023 License: Apache-2.0 Imports: 7 Imported by: 14

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

func NewPlacementTagMismatchError

func NewPlacementTagMismatchError(tags []string) error

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 AuctionRunnerDelegate interface {
	FetchCellReps(lager.Logger, string) (map[string]rep.Client, error)
	AuctionCompleted(lager.Logger, string, AuctionResults)
}

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

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

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL