mesos

Documentation

Index

• type Followers
• type Frameworks
• type Mesos
  • func New(c *config.Config, consul *consul.Consul) *Mesos
  • func (m *Mesos) Refresh() error
  • func (m *Mesos) RegisterHosts(sj StateJSON)
• type MesosHost
• type Resources
• type StateJSON
• type Tasks

Types

type Followers

type Followers []follower

type Frameworks

type Frameworks []struct {
	Tasks `json:"tasks"`
	Name  string `json:"name"`
}

type Mesos

type Mesos struct {
	Consul  *consul.Consul
	Masters *[]MesosHost
	Lock    sync.Mutex
}

func New

func New(c *config.Config, consul *consul.Consul) *Mesos

func (*Mesos) Refresh

func (m *Mesos) Refresh() error

func (*Mesos) RegisterHosts

func (m *Mesos) RegisterHosts(sj StateJSON)

type MesosHost

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

type Resources

type Resources struct {
	Ports string `json:"ports"`
}

type StateJSON

type StateJSON struct {
	Frameworks `json:"frameworks"`
	Followers  `json:"slaves"`
	Leader     string `json:"leader"`
}

type Tasks

type Tasks []struct {
	FrameworkId string `json:"framework_id"`
	Id          string `json:"id"`
	Name        string `json:"name"`
	FollowerId  string `json:"slave_id"`
	State       string `json:"state"`
	Resources   `json:"resources"`
}