mesos

Documentation

Index

• type Mesos
  • func New(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Mesos
  • func (e *Mesos) Call(message *mesosproto.Call) error
  • func (e *Mesos) DeclineOffer(offerIds []mesosproto.OfferID) *mesosproto.Call
  • func (e *Mesos) DecodeTask(key string) cfg.Command
  • func (e *Mesos) GetAgentInfo(agentID string) cfg.MesosSlaves
  • func (e *Mesos) GetNetworkInfo(taskID string) []mesosproto.NetworkInfo
  • func (e *Mesos) GetOffer(offers *mesosproto.Event_Offers, cmd cfg.Command) (mesosproto.Offer, []mesosproto.OfferID)
  • func (e *Mesos) GetTaskInfo(taskID string) cfg.MesosTasks
  • func (e *Mesos) IsRessourceMatched(ressource []mesosproto.Resource, cmd cfg.Command) bool
  • func (e *Mesos) Kill(taskID string, agentID string) error
  • func (e *Mesos) Revive()
  • func (e *Mesos) SuppressFramework()

Types

type Mesos

type Mesos struct {
	Config    *cfg.Config
	Framework *cfg.FrameworkConfig
}

Mesos include all the current vars and global config

func New

func New(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Mesos

New will create a new API object

func (*Mesos) Call

func (e *Mesos) Call(message *mesosproto.Call) error

Call will send messages to mesos

func (*Mesos) DeclineOffer

func (e *Mesos) DeclineOffer(offerIds []mesosproto.OfferID) *mesosproto.Call

DeclineOffer will decline the given offers

func (*Mesos) DecodeTask

func (e *Mesos) DecodeTask(key string) cfg.Command

DecodeTask will decode the key into an mesos command struct

func (*Mesos) GetAgentInfo

func (e *Mesos) GetAgentInfo(agentID string) cfg.MesosSlaves

GetAgentInfo get information about the agent

func (*Mesos) GetNetworkInfo

func (e *Mesos) GetNetworkInfo(taskID string) []mesosproto.NetworkInfo

GetNetworkInfo get network info of task

func (*Mesos) GetOffer

func (e *Mesos) GetOffer(offers *mesosproto.Event_Offers, cmd cfg.Command) (mesosproto.Offer, []mesosproto.OfferID)

GetOffer get out the offer for the mesos task

func (*Mesos) GetTaskInfo

func (e *Mesos) GetTaskInfo(taskID string) cfg.MesosTasks

GetTaskInfo get the task object to the given ID

func (*Mesos) IsRessourceMatched

func (e *Mesos) IsRessourceMatched(ressource []mesosproto.Resource, cmd cfg.Command) bool

IsRessourceMatched - check if the ressources of the offer are matching the needs of the cmd nolint:gocyclo

func (*Mesos) Kill

func (e *Mesos) Kill(taskID string, agentID string) error

Kill a Task with the given taskID

func (*Mesos) Revive

func (e *Mesos) Revive()

Revive will revive the mesos tasks to clean up

func (*Mesos) SuppressFramework

func (e *Mesos) SuppressFramework()

SuppressFramework if all Tasks are running, suppress framework offers