queue

Documentation

Index

• type AppQueue
• type Attribute
• type Delay
• type LastUnusedOffer
• type Offer
• type ProcessedOffersSummary
• type Queues
• type Range
• type Resource
• type Type

Types

type AppQueue

type AppQueue struct {
	ID                    string                      `json:"id"`
	Instances             int                         `json:"instances"`
	Cpus                  int                         `json:"cpus"`
	Mem                   int                         `json:"mem"`
	Disk                  int                         `json:"disk"`
	Constraints           [][]string                  `json:"constraints"`
	Ports                 []int                       `json:"ports"`
	RequirePorts          bool                        `json:"requirePorts"`
	BackoffSeconds        int                         `json:"backoffSeconds"`
	BackoffFactor         float64                     `json:"backoffFactor"`
	MaxLaunchDelaySeconds int                         `json:"maxLaunchDelaySeconds"`
	Container             marathon.Queue              `json:"container"`
	UpgradeStrategy       application.UpgradeStrategy `json:"upgradeStrategy"`
	Version               time.Time                   `json:"version"`
	VersionInfo           application.VersionInfo     `json:"versionInfo"`
}

AppQueue holds definitions of Apps in Queue

type Attribute

type Attribute struct {
	Name   string   `json:"name"`
	Scalar int      `json:"scalar"`
	Ranges []Range  `json:"ranges"`
	Set    []string `json:"set"`
}

Attribute of an Offer from Mesos

type Delay

type Delay struct {
	TimeLeftSeconds int  `json:"timeLeftSeconds"`
	Overdue         bool `json:"overdue"`
}

Delay Queue representation

type LastUnusedOffer

type LastUnusedOffer struct {
	Offer     Offer       `json:"offer"`
	Timestamp interface{} `json:"timestamp"`
	Reason    []string    `json:"reason"`
}

LastUnusedOffer Offers not used info

type Offer

type Offer struct {
	ID         string      `json:"id"`
	AgentID    string      `json:"agentId"`
	Hostname   string      `json:"hostname"`
	Resources  []Resource  `json:"resources"`
	Attributes []Attribute `json:"attributes"`
}

Offer holds info of Mesos Offered resources

type ProcessedOffersSummary

type ProcessedOffersSummary struct {
	ProcessedOffersCount int `json:"processedOffersCount"`
	UnusedOffersCount    int `json:"unusedOffersCount"`
}

ProcessedOffersSummary is Processed Offers Summary info

type Queues

type Queues struct {
	Queue []Type `json:"queue"`
}

Queues Array of

type Range

type Range struct {
	Begin int `json:"begin"`
	End   int `json:"end"`
}

Range scalar of an Offer from Mesos

type Resource

type Resource struct {
	Name   string   `json:"name"`
	Scalar int      `json:"scalar"`
	Ranges []Range  `json:"ranges"`
	Set    []string `json:"set"`
	Role   string   `json:"role"`
}

Resource is Offer resource representation

type Type

type Type struct {
	App                    application.AppDefinition `json:"app"`
	Count                  int                       `json:"count"`
	Delay                  Delay                     `json:"delay"`
	Since                  interface{}               `json:"since"`
	ProcessedOffersSummary ProcessedOffersSummary    `json:"processedOffersSummary"`
	LastUnusedOffers       []LastUnusedOffer         `json:"lastUnusedOffers,omitempty"`
}

Type holds definitions of Tasks queued up or waiting to be scheduled