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
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.