apps

Documentation

Index

• Constants
• type App
  • func ParseApp(jsonBlob []byte) (*App, error)
  • func ParseApps(jsonBlob []byte) ([]*App, error)
  • func (app *App) IsConsulApp() bool
  • func (app *App) RegistrationIntents(task *Task, nameSeparator string) []*RegistrationIntent
  • func (app *App) RegistrationIntentsNumber() int
• type AppID
  • func (id AppID) String() string
• type Apps
• type HealthCheck
• type HealthCheckResult
• type PortDefinition
• type RegistrationIntent
• type Task
  • func ParseTask(event []byte) (*Task, error)
  • func ParseTasks(jsonBlob []byte) ([]*Task, error)
  • func (t *Task) IsHealthy() bool
• type TaskID
  • func (id TaskID) AppID() AppID
  • func (id TaskID) String() string
• type TasksResponse

Constants

const MarathonConsulLabel = "consul"

Only Marathon apps with this label will be registered in Consul

Types

type App

type App struct {
	Labels          map[string]string `json:"labels"`
	HealthChecks    []HealthCheck     `json:"healthChecks"`
	ID              AppID             `json:"id"`
	Tasks           []Task            `json:"tasks"`
	PortDefinitions []PortDefinition  `json:"portDefinitions"`
}

func ParseApp

func ParseApp(jsonBlob []byte) (*App, error)

func ParseApps

func ParseApps(jsonBlob []byte) ([]*App, error)

func (*App) IsConsulApp

func (app *App) IsConsulApp() bool

func (*App) RegistrationIntents

func (app *App) RegistrationIntents(task *Task, nameSeparator string) []*RegistrationIntent

func (*App) RegistrationIntentsNumber

func (app *App) RegistrationIntentsNumber() int

type AppID

type AppID string

Marathon Application Id (aka PathId) Usually in the form of /rootGroup/subGroup/subSubGroup/name allowed characters: lowercase letters, digits, hyphens, slash

func (AppID) String

func (id AppID) String() string

type Apps

type Apps struct {
	Apps []*App `json:"apps"`
}

type HealthCheck

type HealthCheck struct {
	Path                   string `json:"path"`
	PortIndex              int    `json:"portIndex"`
	Port                   int    `json:"port"`
	Protocol               string `json:"protocol"`
	GracePeriodSeconds     int    `json:"gracePeriodSeconds"`
	IntervalSeconds        int    `json:"intervalSeconds"`
	TimeoutSeconds         int    `json:"timeoutSeconds"`
	MaxConsecutiveFailures int    `json:"maxConsecutiveFailures"`
	Command                struct {
		Value string `json:"value"`
	}
}

type HealthCheckResult

type HealthCheckResult struct {
	Alive bool `json:"alive"`
}

type PortDefinition

type PortDefinition struct {
	Labels map[string]string `json:"labels"`
}

type RegistrationIntent

type RegistrationIntent struct {
	Name string
	Port int
	Tags []string
}

type Task

type Task struct {
	ID                 TaskID              `json:"id"`
	TaskStatus         string              `json:"taskStatus"`
	AppID              AppID               `json:"appId"`
	Host               string              `json:"host"`
	Ports              []int               `json:"ports"`
	HealthCheckResults []HealthCheckResult `json:"healthCheckResults"`
}

func ParseTask

func ParseTask(event []byte) (*Task, error)

func ParseTasks

func ParseTasks(jsonBlob []byte) ([]*Task, error)

func (*Task) IsHealthy

func (t *Task) IsHealthy() bool

type TaskID

type TaskID string

Marathon Task ID Usually in the form of AppId.uuid with '/' replaced with '_'

func (TaskID) AppID

func (id TaskID) AppID() AppID

func (TaskID) String

func (id TaskID) String() string

type TasksResponse

type TasksResponse struct {
	Tasks []*Task `json:"tasks"`
}