marathon

package module

Go to main page

Versions in this module

v0

v0.7.1

Feb 20, 2017

v0.7.0

Feb 17, 2017

Changes in this version

type Application

+ func (r *Application) EmptyUpgradeStrategy() *Application

+ func (r *Application) SetUpgradeStrategy(us UpgradeStrategy) *Application

type Task

+ State string

type UpgradeStrategy

+ func (us UpgradeStrategy) SetMaximumOverCapacity(cap float64) UpgradeStrategy

+ func (us UpgradeStrategy) SetMinimumHealthCapacity(cap float64) UpgradeStrategy

v0.6.0

Dec 14, 2016

Changes in this version

type Application

+ TaskKillGracePeriodSeconds *float64

+ TaskStats map[string]TaskStats

+ func (r *Application) SetTaskKillGracePeriod(seconds float64) *Application

+ type Stats struct

+ Counts map[string]int

+ LifeTime map[string]float64

+ type TaskStats struct

+ Stats Stats

v0.5.1

Nov 9, 2016

v0.5.0

Nov 7, 2016

Changes in this version

type HealthCheckResult

+ LastFailureCause string

+ type InvalidEndpointError struct

+ func (e *InvalidEndpointError) Error() string

v0.4.0

Oct 28, 2016

Changes in this version

type Application

+ IPAddressPerTask *IPAddressPerTask

+ func (r *Application) SetIPAddressPerTask(ipAddressPerTask IPAddressPerTask) *Application

+ type Discovery struct

+ Ports *[]Port

+ func (d *Discovery) AddPort(port Port) *Discovery

+ func (d *Discovery) EmptyPorts() *Discovery

+ type ExternalVolume struct

+ Name string

+ Options *map[string]string

+ Provider string

+ func (ev *ExternalVolume) AddOption(name, value string) *ExternalVolume

+ func (ev *ExternalVolume) EmptyOptions() *ExternalVolume

+ type IPAddressPerTask struct

+ Discovery Discovery

+ Groups *[]string

+ Labels *map[string]string

+ NetworkName string

+ func (i *IPAddressPerTask) AddGroup(group string) *IPAddressPerTask

+ func (i *IPAddressPerTask) AddLabel(name, value string) *IPAddressPerTask

+ func (i *IPAddressPerTask) EmptyGroups() *IPAddressPerTask

+ func (i *IPAddressPerTask) EmptyLabels() *IPAddressPerTask

+ func (i *IPAddressPerTask) SetDiscovery(discovery Discovery) *IPAddressPerTask

+ type Port struct

+ Name string

+ Number int

+ Protocol string

type Volume

+ External *ExternalVolume

+ func (v *Volume) EmptyExternalVolume() *Volume

+ func (v *Volume) SetExternalVolume(name, provider string) *ExternalVolume

v0.3.0

Sep 27, 2016

Changes in this version

+ type EventsChannelContext struct

type Marathon

+ Subscribe func(string) error

v0.2.0

Sep 23, 2016

Changes in this version

type Application

+ PortDefinitions *[]PortDefinition

+ func (r *Application) AddPortDefinition(portDefinition PortDefinition) *Application

+ func (r *Application) EmptyPortDefinitions() *Application

type Config

+ PollingWaitTime time.Duration

+ type PortDefinition struct

+ Labels *map[string]string

+ Name string

+ Port *int

+ Protocol string

+ func (p *PortDefinition) EmptyLabels() *PortDefinition

+ func (p PortDefinition) AddLabel(name, value string) PortDefinition

+ func (p PortDefinition) SetPort(port int) PortDefinition

type PortMapping

+ Labels *map[string]string

+ Name string

+ func (p *PortMapping) AddLabel(name, value string) *PortMapping

+ func (p *PortMapping) EmptyLabels() *PortMapping

v0.1.1

Sep 7, 2016

v0.1.0

Aug 23, 2016

Changes in this version

+ const EventIDAPIRequest

+ const EventIDAddHealthCheck

+ const EventIDAppTerminated

+ const EventIDApplications

+ const EventIDChangedHealthCheck

+ const EventIDDeploymentFailed

+ const EventIDDeploymentInfo

+ const EventIDDeploymentStepFailed

+ const EventIDDeploymentStepSuccess

+ const EventIDDeploymentSuccess

+ const EventIDFailedHealthCheck

+ const EventIDFrameworkMessage

+ const EventIDGroupChangeFailed

+ const EventIDGroupChangeSuccess

+ const EventIDRemoveHealthCheck

+ const EventIDStatusUpdate

+ const EventIDStreamAttached

+ const EventIDStreamDetached

+ const EventIDSubscription

+ const EventIDSubscriptions

+ const EventIDUnsubscribed

type Application

+ Fetch *[]Fetch

+ func (r *Application) AddArgs(arguments ...string) *Application

+ func (r *Application) AddConstraint(constraints ...string) *Application

+ func (r *Application) AddFetchURIs(fetchURIs ...Fetch) *Application

+ func (r *Application) AddHealthCheck(healthCheck HealthCheck) *Application

+ func (r *Application) AddUris(newUris ...string) *Application

+ func (r *Application) Command(cmd string) *Application

+ func (r *Application) EmptyArgs() *Application

+ func (r *Application) EmptyConstraints() *Application

+ func (r *Application) EmptyEnvs() *Application

+ func (r *Application) EmptyFetchURIs() *Application

+ func (r *Application) EmptyHealthChecks() *Application

+ func (r *Application) EmptyLabels() *Application

+ func (r *Application) EmptyUris() *Application

+ func (r *Application) SetExecutor(executor string) *Application

+ func (r *Application) String() string

type Config

+ DCOSToken string

+ HTTPClient *http.Client

type Container

+ func (container *Container) EmptyVolumes() *Container

+ type Delay struct

+ Overdue bool

+ TimeLeftSeconds int

+ type DeleteAppOpts struct

+ Force bool

+ type DeleteGroupOpts struct

+ Force bool

type Deployment

+ XXStepsRaw json.RawMessage

type Docker

+ func (docker *Docker) AddParameter(key string, value string) *Docker

+ func (docker *Docker) EmptyParameters() *Docker

+ func (docker *Docker) EmptyPortMappings() *Docker

+ func (docker *Docker) Host() *Docker

+ func (docker *Docker) SetForcePullImage(forcePull bool) *Docker

+ func (docker *Docker) SetPrivileged(priv bool) *Docker

type EventAPIRequest

+ ClientIP string

+ URI string

type EventAddHealthCheck

+ AppID string

type EventFailedHealthCheck

+ AppID string

type EventFrameworkMessage

+ ExecutorID string

+ SlaveID string

type EventGroupChangeFailed

+ GroupID string

type EventGroupChangeSuccess

+ GroupID string

type EventRemoveHealthCheck

+ AppID string

type EventStatusUpdate

+ IPAddresses []*IPAddress

+ Message string

type EventSubscription

+ CallbackURL string

+ ClientIP string

type EventUnsubscription

+ CallbackURL string

+ ClientIP string

+ type Fetch struct

+ Cache bool

+ Executable bool

+ Extract bool

+ URI string

+ type GetAppOpts struct

+ Embed []string

+ type GetGroupOpts struct

+ Embed []string

type HealthCheck

+ Port *int

+ func (h HealthCheck) SetCommand(c Command) HealthCheck

+ func (h HealthCheck) SetMaxConsecutiveFailures(i int) HealthCheck

+ func (h HealthCheck) SetPath(p string) HealthCheck

+ func (h HealthCheck) SetPort(i int) HealthCheck

+ func (h HealthCheck) SetPortIndex(i int) HealthCheck

+ type IPAddress struct

+ IPAddress string

+ Protocol string

+ type Item struct

+ Application Application

+ Count int

+ Delay Delay

type KillApplicationTasksOpts

+ Force bool

type KillTaskOpts

+ Force bool

type Marathon

+ ApplicationBy func(name string, opts *GetAppOpts) (*Application, error)

+ ApplicationByVersion func(name, version string) (*Application, error)

+ DeleteQueueDelay func(appID string) error

+ GroupBy func(name string, opts *GetGroupOpts) (*Group, error)

+ GroupsBy func(opts *GetGroupOpts) (*Groups, error)

+ Queue func() (*Queue, error)

+ type Queue struct

+ Items []Item

+ type StepActions struct

+ Actions []struct{ ... }

type Task

+ IPAddresses []*IPAddress

+ SlaveID string

+ type UpdateGroupOpts struct

+ Force bool

v0.0.1

Jan 26, 2016

Changes in this version

+ const EVENTS_APPLICATIONS

+ const EVENTS_SUBSCRIPTIONS

+ const EVENT_ADD_HEALTH_CHECK

+ const EVENT_API_REQUEST

+ const EVENT_APP_TERMINATED

+ const EVENT_CHANGED_HEALTH_CHECK

+ const EVENT_DEPLOYMENT_FAILED

+ const EVENT_DEPLOYMENT_INFO

+ const EVENT_DEPLOYMENT_STEP_FAILED

+ const EVENT_DEPLOYMENT_STEP_SUCCESS

+ const EVENT_DEPLOYMENT_SUCCESS

+ const EVENT_FAILED_HEALTH_CHECK

+ const EVENT_FRAMEWORK_MESSAGE

+ const EVENT_GROUP_CHANGE_FAILED

+ const EVENT_GROUP_CHANGE_SUCCESS

+ const EVENT_REMOVE_HEALTH_CHECK

+ const EVENT_STATUS_UPDATE

+ const EVENT_STREAM_ATTACHED

+ const EVENT_STREAM_DETACHED

+ const EVENT_SUBSCRIPTION

+ const EVENT_UNSUBSCRIBED

+ const ErrCodeAppLocked

+ const ErrCodeBadRequest

+ const ErrCodeDuplicateID

+ const ErrCodeForbidden

+ const ErrCodeInvalidBean

+ const ErrCodeNotFound

+ const ErrCodeServer

+ const ErrCodeUnauthorized

+ const ErrCodeUnknown

+ var ErrInvalidEndpoint = errors.New("invalid Marathon endpoint specified")

+ var ErrInvalidResponse = errors.New("invalid response from Marathon")

+ var ErrMarathonDown = errors.New("all the Marathon hosts are presently down")

+ var ErrNoApplicationContainer = errors.New("you have not specified a docker container yet")

+ var ErrTimeoutError = errors.New("the operation has timed out")

+ var Events map[string]int

+ type APIError struct

+ ErrCode int

+ func NewAPIError(code int, content []byte) (*APIError, error)

+ func (e *APIError) Error() string

+ type AllTasksOpts struct

+ Status string

+ type Application struct

+ AcceptedResourceRoles []string

+ Args []string

+ BackoffFactor float64

+ BackoffSeconds float64

+ CPUs float64

+ Cmd string

+ Constraints [][]string

+ Container *Container

+ Dependencies []string

+ Deployments []map[string]string

+ Disk float64

+ Env map[string]string

+ Executor string

+ HealthChecks []*HealthCheck

+ ID string

+ Instances int

+ Labels map[string]string

+ LastTaskFailure *LastTaskFailure

+ MaxLaunchDelaySeconds float64

+ Mem float64

+ Ports []int

+ RequirePorts bool

+ Tasks []*Task

+ TasksHealthy int

+ TasksRunning int

+ TasksStaged int

+ TasksUnhealthy int

+ UpgradeStrategy *UpgradeStrategy

+ Uris []string

+ User string

+ Version string

+ VersionInfo *VersionInfo

+ func NewDockerApplication() *Application

+ func (r *Application) AddEnv(name, value string) *Application

+ func (r *Application) AddLabel(name, value string) *Application

+ func (r *Application) AllTaskRunning() bool

+ func (r *Application) Arg(arguments ...string) *Application

+ func (r *Application) CPU(cpu float64) *Application

+ func (r *Application) CheckHTTP(uri string, port, interval int) (*Application, error)

+ func (r *Application) CheckTCP(port, interval int) (*Application, error)

+ func (r *Application) Count(count int) *Application

+ func (r *Application) DependsOn(names ...string) *Application

+ func (r *Application) DeploymentIDs() []*DeploymentID

+ func (r *Application) HasHealthChecks() bool

+ func (r *Application) Memory(memory float64) *Application

+ func (r *Application) Name(id string) *Application

+ func (r *Application) Storage(disk float64) *Application

+ type ApplicationVersion struct

+ Version string

+ type ApplicationVersions struct

+ Versions []string

+ type Applications struct

+ Apps []Application

+ type Cluster interface

+ Active func() []string

+ GetMember func() (string, error)

+ MarkDown func()

+ NonActive func() []string

+ Size func() int

+ URL func() string

+ type Command struct

+ Value string

+ type Config struct

+ CallbackURL string

+ EventsInterface string

+ EventsPort int

+ EventsTransport EventsTransport

+ HTTPBasicAuthUser string

+ HTTPBasicPassword string

+ LogOutput io.Writer

+ RequestTimeout int

+ URL string

+ func NewDefaultConfig() Config

+ type Container struct

+ Docker *Docker

+ Type string

+ Volumes []*Volume

+ func NewDockerContainer() *Container

+ func (container *Container) Volume(hostPath, containerPath, mode string) *Container

+ type Deployment struct

+ AffectedApps []string

+ CurrentActions []*DeploymentStep

+ CurrentStep int

+ ID string

+ Steps [][]*DeploymentStep

+ TotalSteps int

+ Version string

+ type DeploymentID struct

+ DeploymentID string

+ Version string

+ type DeploymentPlan struct

+ ID string

+ Original struct{ ... }

+ Steps []*DeploymentStep

+ Target struct{ ... }

+ Version string

+ type DeploymentStep struct

+ Action string

+ App string

+ type Docker struct

+ ForcePullImage bool

+ Image string

+ Network string

+ Parameters []*Parameters

+ PortMappings []*PortMapping

+ Privileged bool

+ func (docker *Docker) Bridged() *Docker

+ func (docker *Docker) Container(image string) *Docker

+ func (docker *Docker) Expose(ports ...int) *Docker

+ func (docker *Docker) ExposePort(containerPort, hostPort, servicePort int, protocol string) *Docker

+ func (docker *Docker) ExposeUDP(ports ...int) *Docker

+ func (docker *Docker) Parameter(key string, value string) *Docker

+ func (docker *Docker) ServicePortIndex(port int) (int, error)

+ type Event struct

+ Event interface{}

+ ID int

+ Name string

+ func GetEvent(eventType string) (*Event, error)

+ func (event *Event) String() string

+ type EventAPIRequest struct

+ AppDefinition *Application

+ ClientIp string

+ EventType string

+ Timestamp string

+ Uri string

+ type EventAddHealthCheck struct

+ AppId string

+ EventType string

+ HealthCheck struct{ ... }

+ Timestamp string

+ type EventAppTerminated struct

+ AppID string

+ EventType string

+ Timestamp string

+ type EventDeploymentFailed struct

+ EventType string

+ ID string

+ Timestamp string

+ type EventDeploymentInfo struct

+ CurrentStep *DeploymentStep

+ EventType string

+ Plan *DeploymentPlan

+ Timestamp string

+ type EventDeploymentStepFailure struct

+ CurrentStep *DeploymentStep

+ EventType string

+ Plan *DeploymentPlan

+ Timestamp string

+ type EventDeploymentStepSuccess struct

+ CurrentStep *DeploymentStep

+ EventType string

+ Plan *DeploymentPlan

+ Timestamp string

+ type EventDeploymentSuccess struct

+ EventType string

+ ID string

+ Timestamp string

+ type EventFailedHealthCheck struct

+ AppId string

+ EventType string

+ HealthCheck struct{ ... }

+ Timestamp string

+ type EventFrameworkMessage struct

+ EventType string

+ ExecutorId string

+ Message string

+ SlaveId string

+ Timestamp string

+ type EventGroupChangeFailed struct

+ EventType string

+ GroupId string

+ Reason string

+ Timestamp string

+ Version string

+ type EventGroupChangeSuccess struct

+ EventType string

+ GroupId string

+ Timestamp string

+ Version string

+ type EventHealthCheckChanged struct

+ Alive bool

+ AppID string

+ EventType string

+ TaskID string

+ Timestamp string

+ Version string

+ type EventRemoveHealthCheck struct

+ AppId string

+ EventType string

+ HealthCheck struct{ ... }

+ Timestamp string

+ type EventStatusUpdate struct

+ AppID string

+ EventType string

+ Host string

+ Ports []int

+ SlaveID string

+ TaskID string

+ TaskStatus string

+ Timestamp string

+ Version string

+ type EventStreamAttached struct

+ EventType string

+ RemoteAddress string

+ Timestamp string

+ type EventStreamDetached struct

+ EventType string

+ RemoteAddress string

+ Timestamp string

+ type EventSubscription struct

+ CallbackUrl string

+ ClientIp string

+ EventType string

+ Timestamp string

+ type EventType struct

+ EventType string

+ type EventUnsubscription struct

+ CallbackUrl string

+ ClientIp string

+ EventType string

+ Timestamp string

+ type EventsChannel chan *Event

+ type EventsTransport int

+ const EventsTransportCallback

+ const EventsTransportSSE

+ type Group struct

+ Apps []*Application

+ Dependencies []string

+ Groups []*Group

+ ID string

+ func NewApplicationGroup(name string) *Group

+ func (r *Group) App(application *Application) *Group

+ func (r *Group) Name(name string) *Group

+ type Groups struct

+ Apps []*Application

+ Dependencies []string

+ Groups []*Group

+ ID string

+ type HealthCheck struct

+ Command *Command

+ GracePeriodSeconds int

+ IntervalSeconds int

+ MaxConsecutiveFailures int

+ Path string

+ PortIndex int

+ Protocol string

+ TimeoutSeconds int

+ func NewDefaultHealthCheck() *HealthCheck

+ type HealthCheckResult struct

+ Alive bool

+ ConsecutiveFailures int

+ FirstSuccess string

+ LastFailure string

+ LastSuccess string

+ TaskID string

+ type Info struct

+ EventSubscriber struct{ ... }

+ FrameworkID string

+ HTTPConfig struct{ ... }

+ Leader string

+ MarathonConfig struct{ ... }

+ Name string

+ Version string

+ ZookeeperConfig struct{ ... }

+ type KillApplicationTasksOpts struct

+ Host string

+ Scale bool

+ type KillTaskOpts struct

+ Scale bool

+ type LastTaskFailure struct

+ AppID string

+ Host string

+ Message string

+ State string

+ TaskID string

+ Timestamp string

+ Version string

+ type Marathon interface

+ AbdicateLeader func() (string, error)

+ AddEventsListener func(channel EventsChannel, filter int) error

+ AllTasks func(opts *AllTasksOpts) (*Tasks, error)

+ Application func(name string) (*Application, error)

+ ApplicationDeployments func(name string) ([]*DeploymentID, error)

+ ApplicationOK func(name string) (bool, error)

+ ApplicationVersions func(name string) (*ApplicationVersions, error)

+ Applications func(url.Values) (*Applications, error)

+ CreateApplication func(application *Application) (*Application, error)

+ CreateGroup func(group *Group) error

+ DeleteApplication func(name string) (*DeploymentID, error)

+ DeleteDeployment func(id string, force bool) (*DeploymentID, error)

+ DeleteGroup func(name string) (*DeploymentID, error)

+ Deployments func() ([]*Deployment, error)

+ GetMarathonURL func() string

+ Group func(name string) (*Group, error)

+ Groups func() (*Groups, error)

+ HasApplicationVersion func(name, version string) (bool, error)

+ HasDeployment func(id string) (bool, error)

+ HasGroup func(name string) (bool, error)

+ Info func() (*Info, error)

+ KillApplicationTasks func(applicationID string, opts *KillApplicationTasksOpts) (*Tasks, error)

+ KillTask func(taskID string, opts *KillTaskOpts) (*Task, error)

+ KillTasks func(taskIDs []string, opts *KillTaskOpts) error

+ Leader func() (string, error)

+ ListApplications func(url.Values) ([]string, error)

+ Ping func() (bool, error)

+ RemoveEventsListener func(channel EventsChannel)

+ RestartApplication func(name string, force bool) (*DeploymentID, error)

+ ScaleApplicationInstances func(name string, instances int, force bool) (*DeploymentID, error)

+ SetApplicationVersion func(name string, version *ApplicationVersion) (*DeploymentID, error)

+ Subscriptions func() (*Subscriptions, error)

+ TaskEndpoints func(name string, port int, healthCheck bool) ([]string, error)

+ Tasks func(application string) (*Tasks, error)

+ Unsubscribe func(string) error

+ UpdateApplication func(application *Application) (*DeploymentID, error)

+ UpdateGroup func(id string, group *Group) (*DeploymentID, error)

+ WaitOnApplication func(name string, timeout time.Duration) error

+ WaitOnDeployment func(id string, timeout time.Duration) error

+ WaitOnGroup func(name string, timeout time.Duration) error

+ func NewClient(config Config) (Marathon, error)

+ type Parameters struct

+ Key string

+ Value string

+ type PortMapping struct

+ ContainerPort int

+ HostPort int

+ Protocol string

+ ServicePort int

+ type Subscriptions struct

+ CallbackURLs []string

+ type Task struct

+ AppID string

+ HealthCheckResults []*HealthCheckResult

+ Host string

+ ID string

+ Ports []int

+ ServicePorts []int

+ StagedAt string

+ StartedAt string

+ Version string

+ func (r *Task) HasHealthCheckResults() bool

+ type Tasks struct

+ Tasks []Task

+ type UpgradeStrategy struct

+ MaximumOverCapacity float64

+ MinimumHealthCapacity float64

+ type VersionInfo struct

+ LastConfigChangeAt string

+ LastScalingAt string

+ type Volume struct

+ ContainerPath string

+ HostPath string

+ Mode string

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