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
• type Privilege
  • func NewPrivilege(w []string, b []string) *Privilege
  • func (p *Privilege) Allowed(name string) bool
• type RegexList
  • func NewRegexList(l []string) *RegexList
  • func (rl *RegexList) Compile(l []string)
  • func (rl *RegexList) MatchString(s string, def bool) bool

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

	// Whitelist/Blacklist privileges
	TaskPrivilege *Privilege
	FwPrivilege   *Privilege

	Separator string

	ServiceName     string
	ServiceTags     []string
	ServiceIdPrefix 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 service-id-prefix flag, followed by a colon.

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

type Privilege

type Privilege struct {
	WhiteList *RegexList
	BlackList *RegexList
}

func NewPrivilege

func NewPrivilege(w []string, b []string) *Privilege

func (*Privilege) Allowed

func (p *Privilege) Allowed(name string) bool

type RegexList

type RegexList struct {
	List  []string
	Regex *regexp.Regexp
}

func NewRegexList

func NewRegexList(l []string) *RegexList

func (*RegexList) Compile

func (rl *RegexList) Compile(l []string)

func (*RegexList) MatchString

func (rl *RegexList) MatchString(s string, def bool) bool