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) ForceSuppressFramework()
  • 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
	IsSuppress bool
	IsRevive   bool
	CountAgent int
}

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) ForceSuppressFramework

func (e *Mesos) ForceSuppressFramework()

ForceSuppressFramework if all Tasks are running, suppress framework offers

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

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