operator

package
v1.19.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2022 License: MIT Imports: 12 Imported by: 0

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

View Source
const AGENT_SYNC_INTERVAL = 240

interval for synchronize agents from mesos master, seconds

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL