operator

Documentation

Overview

Package operator implement functions for get or synchronize informations from mesos master using mesos operate API

A oprate manager is responsible for synchronize agents from mesos master

Index

• Constants
• func GetMesosResource(mesosClient *client.Client) (*commtypes.BcsClusterResource, error)
• type OperatorMgr
  • func CreateOperatorMgr(store store.Store, client *client.Client) (*OperatorMgr, error)
  • func (mgr *OperatorMgr) UpdateMesosAgents()
• type OperatorMsg

Constants

const AGENT_SYNC_INTERVAL = 240

interval for synchronize agents from mesos master, seconds

Functions

func GetMesosResource

func GetMesosResource(mesosClient *client.Client) (*commtypes.BcsClusterResource, error)

GetMesosResource Get cluster current resource information from mesos master

Types

type OperatorMgr

type OperatorMgr struct {

	// at present, just for exit msg
	OperatorMsgQueue chan *OperatorMsg
	// contains filtered or unexported fields
}

Operate manager

func CreateOperatorMgr

func CreateOperatorMgr(store store.Store, client *client.Client) (*OperatorMgr, error)

Create operate manager

func (*OperatorMgr) UpdateMesosAgents

func (mgr *OperatorMgr) UpdateMesosAgents()

type OperatorMsg

type OperatorMsg struct {
	MsgType string
}

Operate manager control message