mesos

func HandleOffers ¶

func HandleOffers(offers *mesosproto.Event_Offers) error

HandleOffers will handle the offers event of mesos

func HandleUpdate ¶

func HandleUpdate(event *mesosproto.Event) error

HandleUpdate will handle the offers event of mesos

func Heartbeat ¶

func Heartbeat()

func PrepareTaskInfoExecuteContainer ¶

func PrepareTaskInfoExecuteContainer(agent mesosproto.AgentID, cmd mesosutil.Command) ([]mesosproto.TaskInfo, error)

func Reconcile ¶ added in v0.2.0

func Reconcile()

Reconcile will reconcile the task states after the framework was restarted

func SetConfig ¶

func SetConfig(cfg *cfg.Config, frm *mesosutil.FrameworkConfig)

SetConfig set the global config

func Subscribe ¶

func Subscribe() error

Subscribe to the mesos backend