dtma.DTMAObjectsFiller.DTMAObjectsFiller Class Reference

DTMCObjectsFiller Class contents serialize/deserialize methods for incoming "DTMA" commands. More...

Inheritance diagram for dtma.DTMAObjectsFiller.DTMAObjectsFiller:

Collaboration diagram for dtma.DTMAObjectsFiller.DTMAObjectsFiller:

Public Member Functions
def	__init__ (self)
def	generateStatObjects (self, fields, classes)
def	generateSetObjects (self, fields, classes)
def	generateGetObjects (self, fields, classes)
def	generateStopObjects (self, classes)
def	generateSuspendObject (self, fields)
def	generateSystemObject (self, fields)
def	generateSQLCustomObject (self, fields)
def	generateObjectsList (self, cmd, fields, classes)
	generateObjectsList method represents main income point of user call. More...

Detailed Description

DTMCObjectsFiller Class contents serialize/deserialize methods for incoming "DTMA" commands.

Definition at line 24 of file DTMAObjectsFiller.py.

Constructor & Destructor Documentation

__init__()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.__init__

(

self

)

Definition at line 27 of file DTMAObjectsFiller.py.

  def __init__(self):
    pass

Member Function Documentation

generateGetObjects()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateGetObjects	(		self,
			fields,
			classes
	)

Definition at line 80 of file DTMAObjectsFiller.py.

  def generateGetObjects(self, fields, classes):
    ret = []
    classesList = []
    filedsList = []
    fieldsDict = {}
    if len(fields) > 0:
      filedsList = fields.split(CONSTANTS.FIELDS_SEPARATOR)
      for field in filedsList:
        if field != None and field != "":
          fieldsDict[field] = ""
      if len(classes) > 0:
        classesList = classes.split(CONSTANTS.FIELDS_SEPARATOR)
        for name in classesList:
          ret.append(dtm.EventObjects.AdminConfigVars(name, fieldsDict))
      else:
        raise DTMAExceptions.DTMAEmptyClasses("DTMAEmptyClasses [SET]")
    else:
      raise DTMAExceptions.DTMAEmptyFields("DTMAEmptyFields [SET]")
    return ret

Here is the caller graph for this function:

generateObjectsList()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateObjectsList	(		self,
			cmd,
			fields,
			classes
	)

generateObjectsList method represents main income point of user call.

Definition at line 145 of file DTMAObjectsFiller.py.

  def generateObjectsList(self, cmd, fields, classes):
    objectList = []
    if cmd == CONSTANTS.TASKS[0]:
      objectList = self.generateStatObjects(fields, classes)
    elif cmd == CONSTANTS.TASKS[1]:
      objectList = self.generateSetObjects(fields, classes)
    elif cmd == CONSTANTS.TASKS[2]:
      objectList = self.generateGetObjects(fields, classes)
    elif cmd == CONSTANTS.TASKS[3]:
      objectList = self.generateStopObjects(classes)
    elif cmd == CONSTANTS.TASKS[4]:
      objectList = self.generateSuspendObject(fields)
    elif cmd == CONSTANTS.TASKS[5]:
      objectList = self.generateSystemObject(fields)
    elif cmd == CONSTANTS.TASKS[6]:
      objectList = self.generateSQLCustomObject(fields)
    return objectList

generateSetObjects()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateSetObjects	(		self,
			fields,
			classes
	)

Definition at line 52 of file DTMAObjectsFiller.py.

  def generateSetObjects(self, fields, classes):
    ret = []
    classesList = []
    filedsList = []
    fieldsDict = {}
    if len(fields) > 0:
      filedsList = fields.split(CONSTANTS.FIELDS_SEPARATOR)
      for field in filedsList:
        fieldPair = field.split(CONSTANTS.NAME_VALUE_SEPARATOR)
        if len(fieldPair) < 2:
          raise DTMAExceptions.DTMANameValueException("wrong name-value format in --field arg [SET]")
        else:
          try:
            fieldsDict[fieldPair[0]] = eval(fieldPair[1])  # pylint: disable=eval-used
          except Exception:
            raise DTMAExceptions.DTMANameValueException("Wrong value type, for string use str('abcd') as value!")
      if len(classes) > 0:
        classesList = classes.split(CONSTANTS.FIELDS_SEPARATOR)
        for name in classesList:
          ret.append(dtm.EventObjects.AdminConfigVars(name, fieldsDict))
      else:
        raise DTMAExceptions.DTMAEmptyClasses("DTMAEmptyClasses [SET]")
    else:
      raise DTMAExceptions.DTMAEmptyFields("DTMAEmptyFields [SET]")

    return ret

Here is the caller graph for this function:

generateSQLCustomObject()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateSQLCustomObject	(		self,
			fields
	)

Definition at line 133 of file DTMAObjectsFiller.py.

  def generateSQLCustomObject(self, fields):
    ret = []
    try:
      dataJson = json.loads(fields)
      ret.append(dtm.EventObjects.CustomRequest(dataJson["id"], dataJson["sql"], None))
    except Exception:
      raise DTMAExceptions.DTMAEmptyFields("DTMAEmptyFields [SQL_CUSTOM]")
    return ret

Here is the caller graph for this function:

generateStatObjects()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateStatObjects	(		self,
			fields,
			classes
	)

Definition at line 31 of file DTMAObjectsFiller.py.

  def generateStatObjects(self, fields, classes):
    ret = []
    names = []
    filedsList = []
    fieldsDict = {}
    if fields != None and len(fields) > 0:
      filedsList = fields.split(CONSTANTS.FIELDS_SEPARATOR)
      for field in filedsList:
        if len(field) > 0:
          fieldPair = field.split(CONSTANTS.NAME_VALUE_SEPARATOR)
          if len(fieldPair) >= 1:
            fieldsDict[fieldPair[0]] = None
    if len(classes) > 0:
      names = classes.split(CONSTANTS.FIELDS_SEPARATOR)
      for name in names:
        ret.append(dtm.EventObjects.AdminStatData(name, fieldsDict))
    else:
      raise DTMAExceptions.DTMAEmptyClasses("DTMAEmptyClasses [STAT]")
    return ret

Here is the caller graph for this function:

generateStopObjects()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateStopObjects	(		self,
			classes
	)

Definition at line 101 of file DTMAObjectsFiller.py.

  def generateStopObjects(self, classes):
    ret = []
    names = []
    if len(classes) > 0:
      names = classes.split(CONSTANTS.FIELDS_SEPARATOR)
      for name in names:
        ret.append(dtm.EventObjects.AdminState(name, dtm.EventObjects.AdminState.STATE_SHUTDOWN))
    else:
      raise DTMAExceptions.DTMAEmptyClasses("DTMAEmptyFields [Stop]")
    return ret

Here is the caller graph for this function:

generateSuspendObject()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateSuspendObject	(		self,
			fields
	)

Definition at line 113 of file DTMAObjectsFiller.py.

  def generateSuspendObject(self, fields):
    ret = []
    if fields is not None:
      if fields == "1":
        ret.append(dtm.EventObjects.AdminSuspend(dtm.EventObjects.AdminSuspend.SUSPEND))
      else:
        ret.append(dtm.EventObjects.AdminSuspend(dtm.EventObjects.AdminSuspend.RUN))
    return ret

Here is the caller graph for this function:

generateSystemObject()

def dtma.DTMAObjectsFiller.DTMAObjectsFiller.generateSystemObject	(		self,
			fields
	)

Definition at line 123 of file DTMAObjectsFiller.py.

  def generateSystemObject(self, fields):
    ret = []
    try:
      dataJson = json.loads(fields)
      ret.append(dtm.EventObjects.System(dataJson["type"], dataJson["data"]))
    except Exception:
      raise DTMAExceptions.DTMAEmptyFields("DTMAEmptyFields [SYSTEM]")
    return ret

Here is the caller graph for this function:

---

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

• sources/hce/dtma/DTMAObjectsFiller.py