mesos

Documentation

Index

• func GetCheck(t *state.Task, cv *CheckVar) *registry.Check
• type CacheEntry
• type CheckVar
• type Mesos
  • func New(c *config.Config) *Mesos
  • func (m *Mesos) LoadCache() error
  • func (m *Mesos) OnMasterChanged(leader *proto.MasterInfo)
  • func (m *Mesos) Refresh() error
  • func (m *Mesos) RegisterHosts(s state.State)
  • func (m *Mesos) UpdatedMasters(masters []*proto.MasterInfo)
• type MesosHost
  • func MasterInfoToMesosHost(mi *proto.MasterInfo) *MesosHost
  • func ProtoBufToMesosHost(mi *proto.MasterInfo) *MesosHost

Functions

func GetCheck

func GetCheck(t *state.Task, cv *CheckVar) *registry.Check

GetCheck()

Build a Check structure from the Task labels

Types

type CacheEntry

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

type CheckVar

type CheckVar struct {
	Host string
	Port string
}

type Mesos

type Mesos struct {
	Registry registry.Registry
	Agents   map[string]string
	Lock     sync.Mutex

	Leader  *proto.MasterInfo
	Masters []*proto.MasterInfo

	IpOrder []string
	// contains filtered or unexported fields
}

func New

func New(c *config.Config) *Mesos

func (*Mesos) LoadCache

func (m *Mesos) LoadCache() error

Query the consul agent on the Mesos Master to initialize the cache.

All services created by mesos-consul are prefixed with `mesos-consul:`

func (*Mesos) OnMasterChanged

func (m *Mesos) OnMasterChanged(leader *proto.MasterInfo)

func (*Mesos) Refresh

func (m *Mesos) Refresh() error

func (*Mesos) RegisterHosts

func (m *Mesos) RegisterHosts(s state.State)

func (*Mesos) UpdatedMasters

func (m *Mesos) UpdatedMasters(masters []*proto.MasterInfo)

type MesosHost

type MesosHost struct {
	Ip           string
	Host         string
	Port         int
	PortString   string
	IsLeader     bool
	IsRegistered bool
}

func MasterInfoToMesosHost

func MasterInfoToMesosHost(mi *proto.MasterInfo) *MesosHost

func ProtoBufToMesosHost

func ProtoBufToMesosHost(mi *proto.MasterInfo) *MesosHost