auctionrunner

Documentation

Index

• type AuctionRunner
  • func New(delegate auctiontypes.AuctionRunnerDelegate, ...) *AuctionRunner
  • func (a *AuctionRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (a *AuctionRunner) ScheduleLRPsForAuctions(lrpStarts []auctioneer.LRPStartRequest)
  • func (a *AuctionRunner) ScheduleTasksForAuctions(tasks []auctioneer.TaskStartRequest)

Types

type AuctionRunner

type AuctionRunner struct {
	HasWork chan struct{}
	// contains filtered or unexported fields
}

func New

func New(
	delegate auctiontypes.AuctionRunnerDelegate,
	metricEmitter auctiontypes.AuctionMetricEmitterDelegate,
	clock clock.Clock,
	workPool *workpool.WorkPool,
	logger lager.Logger,
) *AuctionRunner

func (*AuctionRunner) Run

func (a *AuctionRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*AuctionRunner) ScheduleLRPsForAuctions

func (a *AuctionRunner) ScheduleLRPsForAuctions(lrpStarts []auctioneer.LRPStartRequest)

func (*AuctionRunner) ScheduleTasksForAuctions

func (a *AuctionRunner) ScheduleTasksForAuctions(tasks []auctioneer.TaskStartRequest)