marathon

package module

Go to main page

Versions in this module

v1

v1.4.8

Mar 7, 2021

v1.4.7

Feb 24, 2021

Changes in this version

+ const APIConfigByVersion

+ const APIVersions

v1.4.6

Jan 12, 2021

Changes in this version

+ const APIApps

+ const APIBase

+ const APIDeployments

+ const APIGroups

+ const APIInfo

+ const APIPing

+ const DeploymentTimeout

type Client

+ func (mc *Client) Framework() string

+ func (mc *Client) Leader() string

+ func (mc *Client) Version() string

+ func (mc *Client) Zookeeper() string

v1.4.5

Jan 11, 2021

Changes in this version

type Client

+ func (mc *Client) AppParams(id string) (map[string]string, error)

v1.4.4

Nov 12, 2020

Changes in this version

type Application

+ func (ma *Application) AsRaw() AppDefinition

v1.4.3

Nov 12, 2020

Changes in this version

type AppDefinition

+ Constraints []TaskConstraints

+ type TaskConstraints []string

v1.4.2

Jul 19, 2020

Changes in this version

type FilteredApps

+ func (fa *FilteredApps) DumpSingly(baseName string) (err error)

v1.4.1

Jul 18, 2020

Changes in this version

type Application

+ func (ma *Application) Apply(force bool) error

v1.4.0

Jul 18, 2020

Changes in this version

+ var Logger *logger.StandardLogger = logger.NewLogger(true)

type Application

+ func (ma *Application) Dump(fileName string) (err error)

+ func (ma *Application) Load(fileName string) *Application

+ func (ma *Application) Set(app AppDefinition) *Application

+ type CallBackFuncsWithAppDef func(app AppDefinition) error

+ type CallBackFuncsWithAppID func(appID string) error

type FailureMessage

+ Details interface{}

+ type FilterFunction func(app AppDefinition) bool

+ type FilteredApps struct

+ func NewFilteredApps(marathon *Client) *FilteredApps

+ func (fa *FilteredApps) AsMap() map[string]AppSummary

+ func (fa *FilteredApps) AsRaw() []AppDefinition

+ func (fa *FilteredApps) Dump(fileName string) (err error)

+ func (fa *FilteredApps) FilterBy(filterFunc FilterFunction) *FilteredApps

+ func (fa *FilteredApps) Get(filter string) *FilteredApps

+ func (fa *FilteredApps) Load(fileName, filter string) *FilteredApps

+ func (fa *FilteredApps) Restart(force bool) error

+ func (fa *FilteredApps) Scale(instances int, force bool) error

+ func (fa *FilteredApps) Start(instances int, force bool) error

+ func (fa *FilteredApps) Stop(force bool) error

+ func (fa *FilteredApps) Suspend(force bool) error

type Groups

+ func (mg *Groups) Apply(force bool) error

+ func (mg *Groups) Dump(fileName string) (err error)

+ func (mg *Groups) Load(fileName string) *Groups

+ type TaskMarathon struct

+ AppID string

+ HealthCheckResults []HealthcheckResult

+ Host string

+ ID string

+ IPAddresses []IPAddress

+ LocalVolumes []interface{}

+ Ports []int

+ Role string

+ ServicePorts []interface{}

+ SlaveID string

+ StagedAt time.Time

+ StartedAt time.Time

+ State string

+ Version time.Time

v1.3.4

Jun 18, 2020

Changes in this version

type Applications

+ func (ma *Applications) Apply() error

+ func (ma *Applications) AsRaw() []AppDefinition

v1.3.3

Jun 18, 2020

v1.3.2

Jun 18, 2020

Changes in this version

+ type AppSummary struct

+ Cpus float64

+ Env map[string]string

+ ID string

+ Image string

+ Labels map[string]string

+ Mem float64

type Applications

+ func NewApplications(marathon *Client) *Applications

+ func (ma *Applications) DumpToFile(fileName, fileType string) error

+ func (ma *Applications) Get(id string) (*Applications, error)

+ func (ma *Applications) LoadFromFile(fileName, fileType string) error

+ func (ma *Applications) Restart(force bool) error

+ func (ma *Applications) Scale(instances int, force bool) error

+ func (ma *Applications) Start(instances int, force bool) error

+ func (ma *Applications) Stop(force bool) error

+ func (ma *Applications) Suspend(force bool) error

v1.3.1

Jun 2, 2020

Changes in this version

type Application

+ func (ma *Application) Instances() int

v1.3.0

Jun 1, 2020

Changes in this version

type Application

+ func (ma *Application) Parameters() (map[string]string, error)

v1.2.3

May 26, 2020

v1.2.2

May 30, 2020

Changes in this version

type Application

+ func NewApplication(marathon *Client) *Application

type Client

+ Session *requist.Requist

+ func NewFromURL(base *url.URL) *Client

type Deployments

+ func NewDeployments(marathon *Client) *Deployments

type Groups

+ func NewGroups(marathon *Client) *Groups

v1.2.1

May 24, 2020

Changes in this version

type Client

+ func (mc *Client) SetTimeout(timeout time.Duration)

type Deployments

+ func (md *Deployments) Rollback(id string) error

v1.2.1-1

Jun 1, 2020

v1.2.0

May 23, 2020

Changes in this version

type Client

+ func (mc *Client) MarathonFramework() string

+ func (mc *Client) MarathonLeader() string

+ func (mc *Client) MarathonVersion() string

+ func (mc *Client) MarathonZookeeper() string

+ type Config struct

+ AccessControlAllowOrigin []string

+ Checkpoint bool

+ DeclineOfferDuration int

+ DefaultNetworkName string

+ EnvVarsPrefix string

+ Executor string

+ FailoverTimeout int

+ Features []interface{}

+ FrameworkName string

+ Ha bool

+ Hostname string

+ LaunchToken int

+ LaunchTokenRefreshInterval int

+ LeaderProxyConnectionTimeoutMs int

+ LeaderProxyReadTimeoutMs int

+ LocalPortMax int

+ LocalPortMin int

+ Master string

+ MaxInstancesPerOffer int

+ MesosBridgeName string

+ MesosHeartbeatFailureThreshold int

+ MesosHeartbeatInterval int

+ MesosLeaderUIURL string

+ MesosRole string

+ MesosUser string

+ MinReviveOffersInterval int

+ OfferMatchingTimeout int

+ OnElectedPrepareTimeout int

+ ReconciliationInitialDelay int

+ ReconciliationInterval int

+ ReviveOffersForNewApps bool

+ ReviveOffersRepetitions int

+ ScaleAppsInitialDelay int

+ ScaleAppsInterval int

+ StoreCache bool

+ TaskLaunchConfirmTimeout int

+ TaskLaunchTimeout int

+ TaskLostExpungeInitialDelay int

+ TaskLostExpungeInterval int

+ TaskReservationTimeout int

+ WebuiURL string

type Deployments

+ func (md *Deployments) Await(id string, timeout time.Duration) error

+ func (md *Deployments) Destroy(id string) error

+ func (md *Deployments) Get() (*Deployments, error)

+ func (md *Deployments) SetClient(client *requist.Requist)

+ type HTTPConfig struct

+ Port int

+ SecurePort int

type Info

+ Buildref string

+ Elected bool

+ FrameworkID string

+ HTTPConf HTTPConfig

+ Leader string

+ MarathonConfig Config

+ Name string

+ ZookeeperConfig ZkConfig

+ type PluginInfo struct

+ Array []int

+ Test bool

+ Version string

+ type ZkConfig struct

+ Zk string

+ ZkCompression bool

+ ZkCompressionThreshold int

+ ZkConnectionTimeout int

+ ZkMaxNodeSize int

+ ZkMaxVersions int

+ ZkSessionTimeout int

+ ZkTimeout int

v1.1.3

May 20, 2020

Changes in this version

type Application

+ func (ma *Application) GetTag() (string, error)

+ func (ma *Application) SetTag(tag string) error

type Client

+ func (mc *Client) AppGetTag(id string) (string, error)

+ func (mc *Client) AppSetTag(id string, tag string) error

v1.1.2

May 19, 2020

v1.1.1

May 19, 2020

Changes in this version

+ type HealthcheckResult struct

+ Alive bool

+ ConsecutiveFailures int

+ FirstSuccess time.Time

+ InstanceID string

+ LastSuccess time.Time

v1.1.0

May 19, 2020

Changes in this version

+ type DockerParameters struct

+ Key string

+ Value string

v1.0.6

May 19, 2020

v1.0.5

May 19, 2020

v1.0.4

May 19, 2020

Changes in this version

type Client

+ func New(base string) *Client

+ func (mc *Client) New(base *url.URL) *Client

v1.0.3

May 19, 2020

v1.0.2

May 19, 2020

Changes in this version

type Client

+ func (mc *Client) AppDumpToFile(id, fileName string) error

+ func (mc *Client) AppLoadFromFile(fileName string) error

v1.0.1

May 18, 2020

v1.0.0

May 18, 2020

Changes in this version

+ const DockerImageRegEx

+ type Action struct

+ Action string

+ App string

+ type App struct

+ App AppDefinition

+ type AppDefinition struct

+ AcceptedResourceRoles []string

+ BackoffFactor float64

+ BackoffSeconds int

+ Container Container

+ Cpus float64

+ Disk float64

+ Env interface{}

+ Executor string

+ Fetch []Fetch

+ Gpus int

+ HealthChecks []Healthcheck

+ ID string

+ Instances int

+ KillSelection string

+ Labels interface{}

+ MaxLaunchDelaySeconds int

+ Mem float64

+ Networks []Network

+ RequirePorts bool

+ Role string

+ UnreachableStrategy UnreachableStrategy

+ UpgradeStrategy UpgradeStrategy

+ type AppQueue struct

+ BackoffFactor float64

+ BackoffSeconds int

+ Constraints [][]string

+ Container Queue

+ Cpus int

+ Disk int

+ ID string

+ Instances int

+ MaxLaunchDelaySeconds int

+ Mem int

+ Ports []int

+ RequirePorts bool

+ UpgradeStrategy UpgradeStrategy

+ Version time.Time

+ VersionInfo VersionInfo

+ type AppVersions struct

+ Versions []time.Time

+ type Application struct

+ func NewMarathonApplication() *Application

+ func (ma *Application) AddParameter(param interface{}) error

+ func (ma *Application) Container() *Container

+ func (ma *Application) Cpus() float64

+ func (ma *Application) Create(app AppDefinition) (*Application, error)

+ func (ma *Application) DelEnv(name string) error

+ func (ma *Application) DelParameter(param interface{}) error

+ func (ma *Application) Destroy() error

+ func (ma *Application) DumpToFile(id, fileName string) error

+ func (ma *Application) Env() map[string]string

+ func (ma *Application) Get(id string) (*Application, error)

+ func (ma *Application) LoadFromFile(fileName string) error

+ func (ma *Application) Memory() float64

+ func (ma *Application) Restart(force bool) error

+ func (ma *Application) Retag(tag string) error

+ func (ma *Application) Role() string

+ func (ma *Application) Scale(instances int, force bool) error

+ func (ma *Application) SetClient(client *requist.Requist)

+ func (ma *Application) SetContainer(to *Container) error

+ func (ma *Application) SetCpus(to float64) error

+ func (ma *Application) SetEnv(name, value string) error

+ func (ma *Application) SetMemory(to float64) error

+ func (ma *Application) SetRole(to string) error

+ func (ma *Application) Start(instances int, force bool) error

+ func (ma *Application) Stop(force bool) error

+ func (ma *Application) Suspend(force bool) error

+ func (ma *Application) Update(app *AppDefinition) error

+ type Applications struct

+ func NewMarathonApplications() *Applications

+ func (ma *Applications) AsMap() map[string]AppDefinition

+ func (ma *Applications) DestroyAll(force bool) error

+ func (ma *Applications) RestartAll(force bool) error

+ func (ma *Applications) ScaleAll(instances int) error

+ func (ma *Applications) StartAll() error

+ func (ma *Applications) StopAll(force bool) error

+ func (ma *Applications) SuspendAll(force bool) error

+ type Apps struct

+ Apps []AppDefinition

+ type Attribute struct

+ Name string

+ Ranges []Range

+ Scalar int

+ Set []string

+ type Client struct

+ func NewClient(base string) *Client

+ func NewClientFromURL(base *url.URL) *Client

+ func (mc *Client) AppAddParameter(id string, param interface{}) error

+ func (mc *Client) AppContainer(id string) *Container

+ func (mc *Client) AppCpus(id string) float64

+ func (mc *Client) AppCreate(app AppDefinition) error

+ func (mc *Client) AppDelEnv(id, name string) error

+ func (mc *Client) AppDelParameter(id string, param interface{}) error

+ func (mc *Client) AppDestroy(id string) error

+ func (mc *Client) AppEnv(id string) map[string]string

+ func (mc *Client) AppMemory(id string) float64

+ func (mc *Client) AppRestart(id string, force bool) error

+ func (mc *Client) AppRetag(id string, tag string) error

+ func (mc *Client) AppRole(id string) string

+ func (mc *Client) AppScale(id string, instances int, force bool) error

+ func (mc *Client) AppSetContainer(id string, to *Container) error

+ func (mc *Client) AppSetCpus(id string, to float64) error

+ func (mc *Client) AppSetEnv(id, name, value string) error

+ func (mc *Client) AppSetMemory(id string, to float64) error

+ func (mc *Client) AppSetRole(id, to string) error

+ func (mc *Client) AppStart(id string, instances int, force bool) error

+ func (mc *Client) AppStop(id string, force bool) error

+ func (mc *Client) AppSuspend(id string, force bool) error

+ func (mc *Client) AppUpdate(app AppDefinition) error

+ func (mc *Client) CheckConnection() error

+ func (mc *Client) Connect(baseUrl string)

+ func (mc *Client) NewFromURL(base *url.URL) *Client

+ func (mc *Client) SetBasicAuth(username, password string)

+ func (mc *Client) StatusCode() int

+ type Container struct

+ Docker Docker

+ PortMappings []PortMapping

+ Type string

+ Volumes []Volume

+ type CurrentAction struct

+ Action string

+ App string

+ ReadinessCheckResults []ReadinessCheckResult

+ type Delay struct

+ Overdue bool

+ TimeLeftSeconds int

+ type Deployment struct

+ AffectedApps []string

+ AffectedPods []string

+ CurrentActions []CurrentAction

+ CurrentStep int

+ ID string

+ Steps []Step

+ TotalSteps int

+ Version time.Time

+ type Deployments []Deployment

+ type Docker struct

+ ForcePullImage bool

+ Image string

+ Network string

+ Parameters []interface{}

+ Privileged bool

+ type FailureMessage struct

+ Message string

+ type Fetch struct

+ Cache bool

+ Executable bool

+ Extract bool

+ URI string

+ type Group struct

+ Apps []App

+ Dependencies []string

+ EnforceRole bool

+ Executor string

+ Groups []Group

+ ID string

+ Pods []interface{}

+ Version time.Time

+ VersionInfo VersionInfo

+ type Groups struct

+ func NewMarathonGroups() *Groups

+ func (mg *Groups) Create(group *Group) error

+ func (mg *Groups) Destroy() error

+ func (mg *Groups) Get(id string) (*Groups, error)

+ func (mg *Groups) Restart(force bool) error

+ func (mg *Groups) Scale(instances int) error

+ func (mg *Groups) SetClient(client *requist.Requist)

+ func (mg *Groups) Start() error

+ func (mg *Groups) Stop(force bool) error

+ func (mg *Groups) Suspend(force bool) error

+ func (mg *Groups) Update(group *Group) error

+ type Healthcheck struct

+ DelaySeconds int

+ GracePeriodSeconds int

+ IPProtocol string

+ IntervalSeconds int

+ MaxConsecutiveFailures int

+ Path string

+ PortIndex int

+ Protocol string

+ TimeoutSeconds int

+ type IPAddress struct

+ IPAddress string

+ Protocol string

+ type Info struct

+ Array []int

+ Test bool

+ Version string

+ type LastResponse struct

+ Body string

+ ContentType string

+ Status int

+ type LastUnusedOffer struct

+ Offer Offer

+ Reason []string

+ Timestamp interface{}

+ type Leader struct

+ Leader string

+ type Metrics struct

+ Counters struct{ ... }

+ Gauges struct{ ... }

+ Histograms struct{}

+ Meters struct{ ... }

+ Timers struct{ ... }

+ Version string

+ type Network struct

+ Mode string

+ type Offer struct

+ AgentID string

+ Attributes []Attribute

+ Hostname string

+ ID string

+ Resources []Resource

+ type Plugin struct

+ ID string

+ Implementation string

+ Info Info

+ Plugin string

+ Tags []string

+ type Plugins struct

+ Plugins []Plugin

+ type PortMapping struct

+ ContainerPort int

+ HostPort int

+ Labels []interface{}

+ Protocol string

+ ServicePort int

+ type ProcessedOffersSummary struct

+ ProcessedOffersCount int

+ UnusedOffersCount int

+ type Queue struct

+ Docker Docker

+ Type string

+ type QueueType struct

+ App AppDefinition

+ Count int

+ Delay Delay

+ LastUnusedOffers []LastUnusedOffer

+ ProcessedOffersSummary ProcessedOffersSummary

+ Since interface{}

+ type Queues struct

+ Queue []QueueType

+ type Range struct

+ Begin int

+ End int

+ type ReadinessCheckResult struct

+ LastResponse LastResponse

+ Name string

+ Ready bool

+ TaskID string

+ type Resource struct

+ Name string

+ Ranges []Range

+ Role string

+ Scalar int

+ Set []string

+ type Response struct

+ ID string

+ Version time.Time

+ type Result struct

+ Alive bool

+ ConsecutiveFailures int

+ FirstSuccess time.Time

+ InstanceID string

+ LastSuccess time.Time

+ type Step struct

+ Actions []Action

+ type Task struct

+ Task Tsk

+ type Tasks struct

+ Tasks []Tsk

+ type Tsk struct

+ AppID string

+ HealthCheckResults []Result

+ Host string

+ ID string

+ IPAddresses []IPAddress

+ LocalVolumes []interface{}

+ Ports []int

+ Role string

+ ServicePorts []interface{}

+ SlaveID string

+ StagedAt time.Time

+ StartedAt time.Time

+ State string

+ Version time.Time

+ type UnreachableStrategy struct

+ ExpungeAfterSeconds int

+ InactiveAfterSeconds int

+ type UpgradeStrategy struct

+ MaximumOverCapacity float64

+ MinimumHealthCapacity float64

+ type VersionInfo struct

+ LastConfigChangeAt time.Time

+ LastScalingAt time.Time

+ type Volume struct

+ ContainerPath string

+ HostPath string

+ Mode string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL