marathon

Documentation

Index

• type AppResponse
• type InfoResponse
• type Marathon
  • func NewMarathon(location, protocol string, auth *url.Userinfo) (Marathon, error)
  • func (m Marathon) Apps() ([]*apps.App, error)
  • func (m Marathon) ParseApps(jsonBlob []byte) ([]*apps.App, error)
  • func (m Marathon) ParseTasks(jsonBlob []byte) ([]*tasks.Task, error)
  • func (m Marathon) ParseVersion(resp []byte) (string, error)
  • func (m Marathon) Tasks(app string) ([]*tasks.Task, error)
  • func (m Marathon) Url(path string) string
  • func (m Marathon) Version() (*version.Version, error)
• type MarathonSync
  • func NewMarathonSync(marathon Marathoner, consul consul.Consul) *MarathonSync
  • func (m *MarathonSync) Sync() error
• type Marathoner
• type TasksResponse

Types

type AppResponse

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

type InfoResponse

type InfoResponse struct {
	Version string `json:"version"`
}

type Marathon

type Marathon struct {
	Location    string
	Protocol    string
	Auth        *url.Userinfo
	NoVerifySsl bool
}

func NewMarathon

func NewMarathon(location, protocol string, auth *url.Userinfo) (Marathon, error)

func (Marathon) Apps

func (m Marathon) Apps() ([]*apps.App, error)

func (Marathon) ParseApps

func (m Marathon) ParseApps(jsonBlob []byte) ([]*apps.App, error)

func (Marathon) ParseTasks

func (m Marathon) ParseTasks(jsonBlob []byte) ([]*tasks.Task, error)

func (Marathon) ParseVersion

func (m Marathon) ParseVersion(resp []byte) (string, error)

func (Marathon) Tasks

func (m Marathon) Tasks(app string) ([]*tasks.Task, error)

func (Marathon) Url

func (m Marathon) Url(path string) string

func (Marathon) Version

func (m Marathon) Version() (*version.Version, error)

type MarathonSync

type MarathonSync struct {
	// contains filtered or unexported fields
}

func NewMarathonSync

func NewMarathonSync(marathon Marathoner, consul consul.Consul) *MarathonSync

func (*MarathonSync) Sync

func (m *MarathonSync) Sync() error

type Marathoner

type Marathoner interface {
	Apps() ([]*apps.App, error)
	Tasks(string) ([]*tasks.Task, error)
}

type TasksResponse

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