Synnefo » snf-ganeti » ganeti-local

    ("maintain_node_health", None, ht.TMaybeBool),

    ("prealloc_wipe_disks", None, ht.TMaybeBool),

    ("nicparams", None, ht.TOr(ht.TDict, ht.TNone)),

    ("drbd_helper", None, ht.TOr(ht.TString, ht.TNone)),

    ("default_iallocator", None, ht.TOr(ht.TString, ht.TNone)),

    ("reserved_lvs", None, ht.TOr(ht.TListOf(ht.TNonEmptyString), ht.TNone)),

      utils.ForceDictType(self.op.beparams, constants.BES_PARAMETER_TYPES)

      self.new_beparams = cluster.SimpleFillBE(self.op.beparams)

    if self.op.nicparams:

      utils.ForceDictType(self.op.nicparams, constants.NICS_PARAMETER_TYPES)

      self.new_nicparams = cluster.SimpleFillNIC(self.op.nicparams)

      self.cluster.nicparams[constants.PP_DEFAULT] = self.new_nicparams

    if self.op.osparams:

      self.cluster.osparams = self.new_osp

    if self.op.candidate_pool_size is not None:

      self.cluster.candidate_pool_size = self.op.candidate_pool_size

    ("group", None, ht.TMaybeString),

    ("master_capable", None, ht.TMaybeBool),

    ("vm_capable", None, ht.TMaybeBool),

    ]

  _NFLAGS = ["master_capable", "vm_capable"]

                                   offline=False, drained=False,

                                   group=node_group)

  def Exec(self, feedback_fn):

    """Adds the new node to the cluster.

    if new_node.master_candidate:

      self.LogInfo("Node will be a master candidate")

    # check connectivity

    result = self.rpc.call_version([node])[node]

    result.Raise("Can't get version information from node %s" % node)

    ("master_capable", None, ht.TMaybeBool),

    ("vm_capable", None, ht.TMaybeBool),

    ("secondary_ip", None, ht.TMaybeString),

    _PForce,

    ]

  REQ_BGL = False

                                       " based ping to node daemon port",

                                       errors.ECODE_ENVIRON)

  def Exec(self, feedback_fn):

    """Modifies a node.

    result = []

    for attr in ["master_capable", "vm_capable"]:

      val = getattr(self.op, attr)

      if val is not None:

    "beparams",

    "osparams",

    "nicparams",

    "candidate_pool_size",

    "maintain_node_health",

    "uid_pool",

  OP_ID = "OP_NODE_ADD"

  OP_DSC_FIELD = "node_name"

  __slots__ = ["node_name", "primary_ip", "secondary_ip", "readd", "group",

class OpQueryNodes(OpCode):

    "master_capable",

    "vm_capable",

    "secondary_ip",

    ]