Inheritance diagram for dtm.ResourcesStateMonitor.ResourcesStateMonitor:

Collaboration diagram for dtm.ResourcesStateMonitor.ResourcesStateMonitor:

Public Member Functions
def	__init__ (self, configParser, connectionBuilderLight=None)

def	onUpdateResourcesDataResponse (self, event)

def	on_poll_timeout (self)

def	getResourceFromTaskResponse (self, taskResponseObjects)

def	sendUpdateResourceDataRequest (self, resourcesList)

def	getConnectedNodesFromSchema (self, clusterSchemaObj)

def	sendToHCENodeAdmin (self, host, port, messageParameters)

def	getObjectFromJsonFile (self, filePath)

def	loadFromFile (self, filePath)

Public Member Functions inherited from app.BaseServerManager.BaseServerManager
def	__init__ (self, poller_manager=None, admin_connection=None, conectionLightBuilder=None, exceptionForward=False, dumpStatVars=True)
	constructor More...

def	addConnection (self, name, connection)

def	setEventHandler (self, eventType, handler)
	set event handler rewrite the current handler for eventType More...

def	send (self, connect_name, event)
	send event More...

def	reply (self, event, reply_event)
	wrapper for sending event in reply for event More...

def	poll (self)
	poll function polling connections receive as multipart msg, the second argument is pickled pyobj More...

def	process (self, event)
	process event call the event handler method that was set by user or on_unhandled_event method if not set More...

def	run (self)

def	is_connection_registered (self, name)
	check is a connection was registered in a instance of BaseServerManager i object More...

def	on_poll_timeout (self)
	function will call every time when ConnectionTimeout exception arrive More...

def	on_unhandled_event (self, event)
	function will call every time when arrive doesn't set handler for event type of event.evenType More...

def	build_poller_list (self)

def	clear_poller (self)

def	onAdminState (self, event)
	onAdminState event handler process admin SHUTDOWN command More...

def	onAdminFetchStatData (self, event)
	onAdminState event handler process admin command More...

def	onAdminSuspend (self, event)
	onAdminState event handler process admin command More...

def	getStatDataFields (self, fields)
	getStatDataFields returns stat data from storage More...

def	getSystemStat (self)
	getSystemStat returns stat data for system indicators: RAMV, RAMR and CPU More...

def	getConfigVarsFields (self, fields)
	getConfigVarsFields returns config vars from storage More...

def	onAdminGetConfigVars (self, event)
	onAdminGetConfigVars event handler process getConfigVars admin command, fill and return config vars array from internal storage More...

def	onAdminSetConfigVars (self, event)
	onAdminSetConfigVars event handler process setConfigVars admin command More...

def	setConfigVars (self, setConfigVars)
	processSetConfigVars sets config vars in storage More...

def	sendAdminReadyEvent (self)
	send ready event to notify adminInterfaceService More...

def	createLogMsg (self, event)
	from string message from event object More...

def	initStatFields (self, connect_name)
	add record in statFields More...

def	updateStatField (self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD)
	update values of stat field - default sum More...

def	processSpecialConfigVars (self, name, value)
	send ready event to notify adminInterfaceService More...

def	getLogLevel (self)
	Get log level from first of existing loggers. More...

def	setLogLevel (self, level)
	Set log level for all loggers. More...

def	saveStatVarsDump (self)
	Save stat vars in json file. More...

def	loadStatVarsDump (self)
	Load stat vars in json file. More...

def	getStatVarsDumpFileName (self)
	Get stat vars file name. More...

def	createDBIDict (self, configParser)

Public Attributes
	clientResourcesManagerName

	resourcesUpdateDRCERequestJsonFile

	hceClusterSchemaFile

	hceNodeAdminTimeout

	hceNodeManagerRequest

	drceIdGenerator

	drceCommandConvertor

Public Attributes inherited from app.BaseServerManager.BaseServerManager
	dumpStatVars

	poller_manager

	eventBuilder

	exit_flag

	pollTimeout

	connections

	event_handlers

	statFields
	stat fields container More...

	configVars

	exceptionForward

Static Public Attributes
string	CONFIG_RESOURCES_MANAGER_CLIENT = "clientResourcesManager"

string	CONFIG_HCE_NODE_ADMIN_TIMEOUT = "HCENodeAdminTimeout"

string	CONFIG_UPDATE_RESOURCES_DRCE_JSON = "FetchResourcesStateDRCEJsonFile"

string	CONFIG_HCE_CLUSTER_SCHEMA_FILE = "HCEClusterSchemaFile"

string	CONFIG_POLLING_TIMEOUT = "PollingTimeout"

string	ERROR_UPDATE_RESOURCES = "Not all resources updated!"

string	ERROR_JSON_DECODE = "Json decode error!"

string	ERROR_RESOURCES_LISTS_NOT_EQUAL = "Lists of sent and received messages not equal!"

string	ERROR_READ_FILE = "Error read file"

string	ERROR_READ_DRCE_JSON_FILE = "Error read DRCE update resources state request json file"

string	ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION = "HCE node Admin API response processing exception"

string	ERROR_HCE_CLUSTER_SCHEMA_STRUCTURE_WRONG = "Wrong structure of HCE cluster schema object"

string	ERROR_HCE_NODE_REQUEST_ERROR = "HCE node request error"

string	ERROR_HCE_RESPONSE_PROCESSING_FORMAT_ADMIN = "HCE node response format error, cant to split"

string	ERROR_HCE_RESPONSE_PROCESSING_NO_RESOURCE_IN_RESPONSE = "No resource data found in response or response with error"

string	ERROR_NO_ITEMS_IN_DRCE_RESPONSE = "No items in DRCE response"

string	ERROR_DRCE_RESPONSE_ERROR_CODE = "DRCE response with error"

string	ERROR_RE_PARSE_NO_MATCHES = "RE parse results from DRCE node, no matches!"

Static Public Attributes inherited from app.BaseServerManager.BaseServerManager
string	ADMIN_CONNECT_ENDPOINT = "Admin"

string	ADMIN_CONNECT_CLIENT = "Admin"

int	POLL_TIMEOUT_DEFAULT = 3000

int	STAT_FIELDS_OPERATION_ADD = 0

int	STAT_FIELDS_OPERATION_SUB = 1

int	STAT_FIELDS_OPERATION_SET = 2

int	STAT_FIELDS_OPERATION_INIT = 3

string	POLL_TIMEOUT_CONFIG_VAR_NAME = "POLL_TIMEOUT"

string	LOG_LEVEL_CONFIG_VAR_NAME = "LOG_LEVEL"

string	STAT_DUMPS_DEFAULT_DIR = "/tmp/"

string	STAT_DUMPS_DEFAULT_NAME = "%APP_NAME%_%CLASS_NAME%_stat_vars.dump"

dictionary	LOGGERS_NAMES = {APP_CONSTS.LOGGER_NAME, "dc", "dtm", "root", ""}

Detailed Description

Definition at line 54 of file ResourcesStateMonitor.py.

Constructor & Destructor Documentation

◆ init()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.__init__	(	self,
		configParser,
		connectionBuilderLight = `None`
	)

Definition at line 84 of file ResourcesStateMonitor.py.

   def __init__(self, configParser, connectionBuilderLight=None):
     super(ResourcesStateMonitor, self).__init__()
 
     # Instantiate the connection builder light if not set
     if connectionBuilderLight == None:
       connectionBuilderLight = ConnectionBuilderLight()
 
     className = self.__class__.__name__
 
     # Get configuration settings
     self.clientResourcesManagerName = configParser.get(className, self.CONFIG_RESOURCES_MANAGER_CLIENT)
     self.resourcesUpdateDRCERequestJsonFile = configParser.get(className, self.CONFIG_UPDATE_RESOURCES_DRCE_JSON)
     self.hceClusterSchemaFile = configParser.get(className, self.CONFIG_HCE_CLUSTER_SCHEMA_FILE)
 
     # Set connections poll timeout, defines period of HCE cluster monitoring cycle
     # self.pollTimeout = configParser.getint(className, self.CONFIG_POLLING_TIMEOUT)
     self.configVars[self.POLL_TIMEOUT_CONFIG_VAR_NAME] = configParser.getint(className, self.CONFIG_POLLING_TIMEOUT)
 
     # Create connections and raise bind or connect actions for correspondent connection type
     resourcesManagerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.CLIENT_CONNECT,
                                                               self.clientResourcesManagerName)
 
     # Add connections to the polling set
     self.addConnection(self.clientResourcesManagerName, resourcesManagerConnection)
 
     # Set event handler for EXECUTE_TASK event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.UPDATE_RESOURCES_DATA_RESPONSE, self.onUpdateResourcesDataResponse)
 
     # Initialize HCE node Admin API
     self.hceNodeAdminTimeout = configParser.getint(className, self.CONFIG_HCE_NODE_ADMIN_TIMEOUT)
     self.hceNodeManagerRequest = admin.NodeManagerRequest.NodeManagerRequest()
 
     # Initialize unique Id generator
     self.drceIdGenerator = UIDGenerator()
     # Initialize DRCE commands convertor
     self.drceCommandConvertor = CommandConvertor()
     logger.debug("Constructor passed")
 
 

Member Function Documentation

◆ getConnectedNodesFromSchema()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.getConnectedNodesFromSchema	(	self,
		clusterSchemaObj
	)

Definition at line 336 of file ResourcesStateMonitor.py.

   def getConnectedNodesFromSchema(self, clusterSchemaObj):
     nodes = []
     # Not sure in structure integrity
     try:
       # Seek on connected data node
       for item in clusterSchemaObj["cluster"]["nodes"]:
         if (item["role"] == "replica" or item["role"] == "shard") and ('connection' in item):
           port = item["admin"].split(":")
           if len(port) > 2:
             nodes.append(admin.Node.Node(item["host"], port[2]))
     except Exception, e:
       logger.error(self.ERROR_HCE_CLUSTER_SCHEMA_STRUCTURE_WRONG + " : " + str(e.message))
 
     return nodes
 
 
 

Here is the caller graph for this function:

◆ getObjectFromJsonFile()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.getObjectFromJsonFile	(	self,
		filePath
	)

Definition at line 391 of file ResourcesStateMonitor.py.

   def getObjectFromJsonFile(self, filePath):
     # Initialize returned dic
     schemaDic = None
 
     # Load schema from file
     schemaJsonString = self.loadFromFile(filePath)
     if schemaJsonString is not None:
       try:
         # Decode json
         # schemaDic = json.loads(schemaJsonString).decode('utf-8')
         schemaDic = json.loads(str(schemaJsonString))
       except ValueError:
         logger.error(self.ERROR_JSON_DECODE)
         logger.debug(schemaJsonString)
 
     return schemaDic
 
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getResourceFromTaskResponse()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.getResourceFromTaskResponse	(	self,
		taskResponseObjects
	)

Definition at line 199 of file ResourcesStateMonitor.py.

   def getResourceFromTaskResponse(self, taskResponseObjects):
     resource = None
 
     if len(taskResponseObjects.items) > 0:
       # logger.debug("Received taskResponseObjects.items[0]:" + str(vars(taskResponseObjects.items[0])))
 
       if taskResponseObjects.items[0].error_code == 0 or taskResponseObjects.items[0].error_code > 0:
         resource = dtm.EventObjects.Resource(taskResponseObjects.items[0].host + ":" +
                                              str(taskResponseObjects.items[0].port))
         resource.nodeName = taskResponseObjects.items[0].node
         resource.state = dtm.EventObjects.Resource.STATE_ACTIVE
         # logger.debug("Received stdout:\n" + str(taskResponseObjects.items[0].stdout))
         reTemplate1 = r"---CPU LA---(.*)"\
                        "---cpu cores---(.*)"\
                        "---vmstat---(.*)"\
                        "---processes---(.*)"\
                        "---threads max---(.*)"\
                        "---threads actual---(.*)"\
                        "---RAM---(.*)"\
                        "---Disk---(.*)"\
                        "---uptime---(.*)"\
                        "---END---(.*)"
         groupsItems = re.match (reTemplate1, taskResponseObjects.items[0].stdout, re.M | re.I | re.S)
         if groupsItems:
           # CPU LA
           # cpuLA = int(float(groupsItems.group(1).split(" ")[0].lstrip()) * 100)
           # print "cpuLA*100%=" + str(cpuLA)
 
           # CPU cores
           cpuCores = int(groupsItems.group(2))
           # print "cpuCores=" + str(cpuCores)
           resource.cpuCores = cpuCores
 
           # CPU Load
           lines = (' '.join(groupsItems.group(3).split("\n")[4].split())).split(' ')
           cpuIdle = int(lines[14])
           # logger.error("cpuIdle=" + str(cpuIdle))
           cpuLoad = 100 - cpuIdle
           if cpuLoad > 100:
             cpuLoad = 100
           else:
             if cpuLoad < 0:
               cpuLoad = 0
           # print "cpuLoad=" + str(cpuLoad)
           resource.cpu = cpuLoad
 
           # IO wait
           lines = (' '.join(groupsItems.group(3).split("\n")[4].split())).split(' ')
           cpuIO = int(lines[15])
           # logger.error("cpuIO=" + str(cpuIO))
           resource.io = cpuIO
 
           # Processes
           processes = int(groupsItems.group(4).lstrip().rstrip())
           # print "processes=" + str(processes)
           resource.processes = processes
 
           # Threads max
           # threadsMax = int(groupsItems.group(5).lstrip().rstrip())
           # print "threadsMax=" + str(threadsMax)
 
           # Threads actual
           threadsActual = int(groupsItems.group(6).lstrip().rstrip())
           # print "threadsActual=" + str(threadsActual)
           resource.threads = threadsActual
 
           # RAM
           lines = groupsItems.group(7).split("\n")
           # RAM total
           ramTotal = int(lines[2][4: 18].lstrip()) * 1000
           # print "[" + str(ramTotal) + "]"
           resource.ramR = ramTotal
           # RAM used
           ramUsed = int(lines[2][19: 29].lstrip()) * 1000
           # print "[" + str(ramUsed) + "]"
           resource.ramRU = ramUsed
           # RAM cached
           ramCached = int(lines[2][63:].lstrip()) * 1000
           # print "[" + str(ramCached) + "]"
           resource.ramRU = resource.ramRU - ramCached
 
           # Swap total
           swapTotal = int(lines[4][5: 18].lstrip()) * 1000
           # print "swapTotal=" + str(swapTotal)
           resource.swap = swapTotal
           # Swap used
           swapUsed = int(lines[4][19: 29].lstrip()) * 1000
           # print "swapUsed=" + str(swapUsed)
           resource.swapU = swapUsed
 
           # Disk
           lines = groupsItems.group(8).split("\n")
           lines = (' '.join(lines[2].split())).split(" ")
           # Disk total
           diskTotal = int(lines[1]) * 1024
           # print "diskTotal=" + str(diskTotal)
           resource.disk = diskTotal
           # Disk used
           diskUsed = int(lines[2]) * 1024
           # print "diskUsed=" + str(diskUsed)
           resource.diskU = diskUsed
 
           resource.ramV = 0
           resource.ramVU = 0
 
           # print vars(resource)
         else:
           logger.error(self.ERROR_RE_PARSE_NO_MATCHES + ", node:" + resource.nodeName + "\nstdout:\n" +
                        taskResponseObjects.items[0].stdout + "\nstderr:\n" + taskResponseObjects.items[0].stderror)
           resource = None
       else:
         logger.error(self.ERROR_DRCE_RESPONSE_ERROR_CODE + " : " + str(taskResponseObjects.items[0].error_code) + \
                      " : " + taskResponseObjects.items[0].error_message)
         resource = None
     else:
       logger.error(self.ERROR_NO_ITEMS_IN_DRCE_RESPONSE)
 
     return resource
 
 
 

Here is the caller graph for this function:

◆ loadFromFile()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.loadFromFile	(	self,
		filePath
	)

Definition at line 415 of file ResourcesStateMonitor.py.

   def loadFromFile(self, filePath):
     # Initialize file content
     fileContent = None
 
     try:
       fileContent = open(filePath, 'r').read()    except IOError:
       logger.error(self.ERROR_READ_FILE + " " + filePath)
 
     return fileContent
 
Here is the caller graph for this function:

◆ on_poll_timeout()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.on_poll_timeout ( self )

Definition at line 148 of file ResourcesStateMonitor.py.

   def on_poll_timeout(self):
     # Initialize list of resources objects to update
     resources = []
 
     # Get HCE Cluster schema
     clusterSchemaObj = self.getObjectFromJsonFile(self.hceClusterSchemaFile)
     # Get DRCE FO request to get resources state from file
     drceRequestJson = self.loadFromFile(self.resourcesUpdateDRCERequestJsonFile)
     if drceRequestJson is not None:
       # Get connected data nodes from schema
       nodes = self.getConnectedNodesFromSchema(clusterSchemaObj)
       # For each DRCE node execute HCE node admin request
       for node in nodes:
         # Send request to HCE node Admin API
         rawResponse = self.sendToHCENodeAdmin(node.host, node.port, drceRequestJson)
         if rawResponse is not None:
           try:
             # Split admin response parts
             logger.debug("Raw node response: " + str(rawResponse) + ", type = " + str(type(rawResponse)))
             parts = rawResponse.split(admin.Constants.COMMAND_DELIM)
             if len(parts) > 1:
               # Convert DRCE jason protocol response to TaskResponse object
               taskResponse = self.drceCommandConvertor.from_json(parts[1])
               logger.debug("Received taskResponse object: " + str(vars(taskResponse)))
               # Get resource info data from the TaskResponse object and create Resource object
               resource = self.getResourceFromTaskResponse(taskResponse)
               logger.debug("Received Resource object: " + str(varDump(resource)))
               # Collect resource if valid data detected
               if resource is not None:
                 resources.append(resource)
               else:
                 logger.error(self.ERROR_HCE_RESPONSE_PROCESSING_NO_RESOURCE_IN_RESPONSE)
             else:
               logger.error(self.ERROR_HCE_RESPONSE_PROCESSING_FORMAT_ADMIN)
           except Exception, e:
             logger.error(self.ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION + " : " + str(e.message) + "\n" + \
                          app.Utils.getTracebackInfo())
 
       # Send update for collected resources objects
       if len(resources) > 0:
         self.sendUpdateResourceDataRequest(resources)
     else:
       logger.error(self.ERROR_READ_DRCE_JSON_FILE + " " + self.resourcesUpdateDRCERequestJsonFile)
 
 
 

Here is the call graph for this function:

◆ onUpdateResourcesDataResponse()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.onUpdateResourcesDataResponse	(	self,
		event
	)

Definition at line 126 of file ResourcesStateMonitor.py.

   def onUpdateResourcesDataResponse(self, event):
     # Get task Id from event
     generalResponse = event.eventObj
     # Get list of sent resources to update
     resourcesToUpdate = event.cookie
     if len(resourcesToUpdate) == len(generalResponse.statuses):
       errorObjects = []
       for i in range(len(generalResponse.statuses)):
         if generalResponse.statuses[i] == False:
           errorObjects.append(resourcesToUpdate[i])
           logger.error(LogFormatterEvent(event, errorObjects, self.ERROR_UPDATE_RESOURCES))
     else:
       logger.error(LogFormatterEvent(event, [], self.ERROR_RESOURCES_LISTS_NOT_EQUAL + "\n" +
                                      "send " + str(len(resourcesToUpdate)) + " returned " +
                                      str(len(generalResponse.statuses))
                                      ))
 
 
 

◆ sendToHCENodeAdmin()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.sendToHCENodeAdmin	(	self,
		host,
		port,
		messageParameters
	)

Definition at line 359 of file ResourcesStateMonitor.py.

   def sendToHCENodeAdmin(self, host, port, messageParameters):
     response = None
 
     logger.debug("sendToHCENodeAdmin() use Host: '%s' and Port '%s'", str(host), str(port))
 
     # Execute EE node admin request
     node = admin.Node.Node(host, port)
     params = [messageParameters]
     command = admin.Command.Command(admin.Constants.COMMAND_NAMES.DRCE,
                                     params,
                                     admin.Constants.ADMIN_HANDLER_TYPES.DATA_PROCESSOR_DATA
                                     )
     requestBody = command.generateBody()
     message = {admin.Constants.STRING_MSGID_NAME : self.drceIdGenerator.get_uid(),
                admin.Constants.STRING_BODY_NAME : requestBody}
     try:
       logger.debug("!!! Before makeRequest() msg_id = %s", str(message[admin.Constants.STRING_MSGID_NAME]))
       response = self.hceNodeManagerRequest.makeRequest(node, message, self.hceNodeAdminTimeout)
     except Exception, e:
       logger.error(self.ERROR_HCE_NODE_REQUEST_ERROR + " : " + str(e.message))
 
     if response is None:
       return response
     else:
       return response.getBody()
 
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendUpdateResourceDataRequest()

def dtm.ResourcesStateMonitor.ResourcesStateMonitor.sendUpdateResourceDataRequest	(	self,
		resourcesList
	)

Definition at line 323 of file ResourcesStateMonitor.py.

   def sendUpdateResourceDataRequest(self, resourcesList):
     # Get TaskManager fields
     # Prepare synch GetTaskFields request to the TasksManager
     updateResourceDataEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.UPDATE_RESOURCES_DATA, resourcesList)
     updateResourceDataEvent.cookie = resourcesList
     self.send(self.clientResourcesManagerName, updateResourceDataEvent)
 
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ clientResourcesManagerName

dtm.ResourcesStateMonitor.ResourcesStateMonitor.clientResourcesManagerName

Definition at line 94 of file ResourcesStateMonitor.py.

◆ CONFIG_HCE_CLUSTER_SCHEMA_FILE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.CONFIG_HCE_CLUSTER_SCHEMA_FILE = "HCEClusterSchemaFile"

static

Definition at line 60 of file ResourcesStateMonitor.py.

◆ CONFIG_HCE_NODE_ADMIN_TIMEOUT

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.CONFIG_HCE_NODE_ADMIN_TIMEOUT = "HCENodeAdminTimeout"

static

Definition at line 58 of file ResourcesStateMonitor.py.

◆ CONFIG_POLLING_TIMEOUT

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.CONFIG_POLLING_TIMEOUT = "PollingTimeout"

static

Definition at line 61 of file ResourcesStateMonitor.py.

◆ CONFIG_RESOURCES_MANAGER_CLIENT

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.CONFIG_RESOURCES_MANAGER_CLIENT = "clientResourcesManager"

static

Definition at line 57 of file ResourcesStateMonitor.py.

◆ CONFIG_UPDATE_RESOURCES_DRCE_JSON

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.CONFIG_UPDATE_RESOURCES_DRCE_JSON = "FetchResourcesStateDRCEJsonFile"

static

Definition at line 59 of file ResourcesStateMonitor.py.

◆ drceCommandConvertor

dtm.ResourcesStateMonitor.ResourcesStateMonitor.drceCommandConvertor

Definition at line 119 of file ResourcesStateMonitor.py.

◆ drceIdGenerator

dtm.ResourcesStateMonitor.ResourcesStateMonitor.drceIdGenerator

Definition at line 117 of file ResourcesStateMonitor.py.

◆ ERROR_DRCE_RESPONSE_ERROR_CODE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_DRCE_RESPONSE_ERROR_CODE = "DRCE response with error"

static

Definition at line 74 of file ResourcesStateMonitor.py.

◆ ERROR_HCE_CLUSTER_SCHEMA_STRUCTURE_WRONG

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_HCE_CLUSTER_SCHEMA_STRUCTURE_WRONG = "Wrong structure of HCE cluster schema object"

static

Definition at line 69 of file ResourcesStateMonitor.py.

◆ ERROR_HCE_NODE_REQUEST_ERROR

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_HCE_NODE_REQUEST_ERROR = "HCE node request error"

static

Definition at line 70 of file ResourcesStateMonitor.py.

◆ ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION = "HCE node Admin API response processing exception"

static

Definition at line 68 of file ResourcesStateMonitor.py.

◆ ERROR_HCE_RESPONSE_PROCESSING_FORMAT_ADMIN

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_HCE_RESPONSE_PROCESSING_FORMAT_ADMIN = "HCE node response format error, cant to split"

static

Definition at line 71 of file ResourcesStateMonitor.py.

◆ ERROR_HCE_RESPONSE_PROCESSING_NO_RESOURCE_IN_RESPONSE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_HCE_RESPONSE_PROCESSING_NO_RESOURCE_IN_RESPONSE = "No resource data found in response or response with error"

static

Definition at line 72 of file ResourcesStateMonitor.py.

◆ ERROR_JSON_DECODE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_JSON_DECODE = "Json decode error!"

static

Definition at line 64 of file ResourcesStateMonitor.py.

◆ ERROR_NO_ITEMS_IN_DRCE_RESPONSE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_NO_ITEMS_IN_DRCE_RESPONSE = "No items in DRCE response"

static

Definition at line 73 of file ResourcesStateMonitor.py.

◆ ERROR_RE_PARSE_NO_MATCHES

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_RE_PARSE_NO_MATCHES = "RE parse results from DRCE node, no matches!"

static

Definition at line 75 of file ResourcesStateMonitor.py.

◆ ERROR_READ_DRCE_JSON_FILE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_READ_DRCE_JSON_FILE = "Error read DRCE update resources state request json file"

static

Definition at line 67 of file ResourcesStateMonitor.py.

◆ ERROR_READ_FILE

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_READ_FILE = "Error read file"

static

Definition at line 66 of file ResourcesStateMonitor.py.

◆ ERROR_RESOURCES_LISTS_NOT_EQUAL

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_RESOURCES_LISTS_NOT_EQUAL = "Lists of sent and received messages not equal!"

static

Definition at line 65 of file ResourcesStateMonitor.py.

◆ ERROR_UPDATE_RESOURCES

string dtm.ResourcesStateMonitor.ResourcesStateMonitor.ERROR_UPDATE_RESOURCES = "Not all resources updated!"

static

Definition at line 63 of file ResourcesStateMonitor.py.

◆ hceClusterSchemaFile

dtm.ResourcesStateMonitor.ResourcesStateMonitor.hceClusterSchemaFile

Definition at line 96 of file ResourcesStateMonitor.py.

◆ hceNodeAdminTimeout

dtm.ResourcesStateMonitor.ResourcesStateMonitor.hceNodeAdminTimeout

Definition at line 113 of file ResourcesStateMonitor.py.

◆ hceNodeManagerRequest

dtm.ResourcesStateMonitor.ResourcesStateMonitor.hceNodeManagerRequest

Definition at line 114 of file ResourcesStateMonitor.py.

◆ resourcesUpdateDRCERequestJsonFile

dtm.ResourcesStateMonitor.ResourcesStateMonitor.resourcesUpdateDRCERequestJsonFile

Definition at line 95 of file ResourcesStateMonitor.py.

The documentation for this class was generated from the following file:

sources/hce/dtm/ResourcesStateMonitor.py

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ getConnectedNodesFromSchema()

◆ getObjectFromJsonFile()

◆ getResourceFromTaskResponse()

◆ loadFromFile()

◆ on_poll_timeout()

◆ onUpdateResourcesDataResponse()

◆ sendToHCENodeAdmin()

◆ sendUpdateResourceDataRequest()

Member Data Documentation

◆ clientResourcesManagerName

◆ CONFIG_HCE_CLUSTER_SCHEMA_FILE

◆ CONFIG_HCE_NODE_ADMIN_TIMEOUT

◆ CONFIG_POLLING_TIMEOUT

◆ CONFIG_RESOURCES_MANAGER_CLIENT

◆ CONFIG_UPDATE_RESOURCES_DRCE_JSON

◆ drceCommandConvertor

◆ drceIdGenerator

◆ ERROR_DRCE_RESPONSE_ERROR_CODE

◆ ERROR_HCE_CLUSTER_SCHEMA_STRUCTURE_WRONG

◆ ERROR_HCE_NODE_REQUEST_ERROR

◆ ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION

◆ ERROR_HCE_RESPONSE_PROCESSING_FORMAT_ADMIN

◆ ERROR_HCE_RESPONSE_PROCESSING_NO_RESOURCE_IN_RESPONSE

◆ ERROR_JSON_DECODE

◆ ERROR_NO_ITEMS_IN_DRCE_RESPONSE

◆ ERROR_RE_PARSE_NO_MATCHES

◆ ERROR_READ_DRCE_JSON_FILE

◆ ERROR_READ_FILE

◆ ERROR_RESOURCES_LISTS_NOT_EQUAL

◆ ERROR_UPDATE_RESOURCES

◆ hceClusterSchemaFile

◆ hceNodeAdminTimeout

◆ hceNodeManagerRequest

◆ resourcesUpdateDRCERequestJsonFile

◆ init()