Documentation ¶
Index ¶
- Constants
- Variables
- func LockSchemaPath() string
- type Client
- type LRPStartRequest
- func NewLRPStartRequest(processGuid, domain string, indices []int, res rep.Resource, ...) 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 ( 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(logger lager.Logger, lrpStart []*LRPStartRequest) error RequestTaskAuctions(logger lager.Logger, tasks []*TaskStartRequest) error }
type LRPStartRequest ¶
type LRPStartRequest struct { ProcessGuid string `json:"process_guid"` Domain string `json:"domain"` Indices []int `json:"indices"` rep.PlacementConstraint rep.Resource }
func NewLRPStartRequest ¶
func NewLRPStartRequest(processGuid, domain string, indices []int, res rep.Resource, pl rep.PlacementConstraint) LRPStartRequest
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(logger lager.Logger, presence Presence, retryInterval, lockTTL time.Duration, metronClient loggingclient.IngressClient) (ifrit.Runner, error) CurrentAuctioneer() (Presence, error) CurrentAuctioneerAddress() (string, error) }
func NewServiceClient ¶
func NewServiceClient(consulClient consuladapter.Client, clock clock.Clock) ServiceClient
type TaskStartRequest ¶
func NewTaskStartRequest ¶
func NewTaskStartRequest(task rep.Task) TaskStartRequest
func NewTaskStartRequestFromModel ¶
func NewTaskStartRequestFromModel(taskGuid, domain string, taskDef *models.TaskDefinition) TaskStartRequest
func (*TaskStartRequest) Validate ¶
func (t *TaskStartRequest) Validate() error
Click to show internal directories.
Click to hide internal directories.