README
¶
Documentation
¶
Index ¶
- Constants
- Variables
- func LockSchemaPath() string
- type Client
- type LRPStartRequest
- func NewLRPStartRequest(processGuid, domain string, indices []int, res rep.Resource, tags []string) LRPStartRequest
- func NewLRPStartRequestFromModel(d *models.DesiredLRP, indices ...int) LRPStartRequest
- func NewLRPStartRequestFromSchedulingInfo(s *models.DesiredLRPSchedulingInfo, indices ...int) LRPStartRequest
- type Presence
- type ServiceClient
- type TaskStartRequest
Constants ¶
View Source
const ( LRPAuctionsStarted = metric.Counter("AuctioneerLRPAuctionsStarted") LRPAuctionsFailed = metric.Counter("AuctioneerLRPAuctionsFailed") TaskAuctionsStarted = metric.Counter("AuctioneerTaskAuctionsStarted") TaskAuctionsFailed = metric.Counter("AuctioneerTaskAuctionsFailed") FetchStatesDuration = metric.Duration("AuctioneerFetchStatesDuration") )
View Source
const ( CreateTaskAuctionsRoute = "CreateTaskAuctions" CreateLRPAuctionsRoute = "CreateLRPAuctions" )
View Source
const LockSchemaKey = "auctioneer_lock"
Variables ¶
View Source
var Routes = rata.Routes{ {Path: "/v1/tasks", Method: "POST", Name: CreateTaskAuctionsRoute}, {Path: "/v1/lrps", Method: "POST", Name: CreateLRPAuctionsRoute}, }
Functions ¶
func LockSchemaPath ¶
func LockSchemaPath() string
Types ¶
type Client ¶
type Client interface {
RequestLRPAuctions(lrpStart []*LRPStartRequest) error
RequestTaskAuctions(tasks []*TaskStartRequest) error
}
type LRPStartRequest ¶
type LRPStartRequest struct {
ProcessGuid string `json:"process_guid"`
Domain string `json:"domain"`
Indices []int `json:"indices"`
Tags []string `json:"environment_variables"`
rep.Resource
}
func NewLRPStartRequest ¶
func NewLRPStartRequestFromModel ¶
func NewLRPStartRequestFromModel(d *models.DesiredLRP, indices ...int) LRPStartRequest
func NewLRPStartRequestFromSchedulingInfo ¶
func NewLRPStartRequestFromSchedulingInfo(s *models.DesiredLRPSchedulingInfo, indices ...int) LRPStartRequest
func (*LRPStartRequest) Validate ¶
func (lrpstart *LRPStartRequest) Validate() error
type Presence ¶
type Presence struct {
AuctioneerID string `json:"auctioneer_id"`
AuctioneerAddress string `json:"auctioneer_address"`
}
func NewPresence ¶
type ServiceClient ¶
type ServiceClient interface {
NewAuctioneerLockRunner(lager.Logger, Presence, time.Duration) (ifrit.Runner, error)
CurrentAuctioneer() (Presence, error)
CurrentAuctioneerAddress() (string, error)
}
func NewServiceClient ¶
func NewServiceClient(session *consuladapter.Session, clock clock.Clock) ServiceClient
type TaskStartRequest ¶
func NewTaskStartRequest ¶
func NewTaskStartRequest(task rep.Task) TaskStartRequest
func NewTaskStartRequestFromModel ¶
func NewTaskStartRequestFromModel(t *models.Task) TaskStartRequest
func (*TaskStartRequest) Validate ¶
func (t *TaskStartRequest) Validate() error
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
|
cmd
|
|
Click to show internal directories.
Click to hide internal directories.