/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

       the master side.
       """
       def Run(self, name, idata):
       @staticmethod
       def Run(name, idata):
         """Run an iallocator script.
         @type name: str

         nl = [self.cfg.GetMasterNode()] + list(self.instance.all_nodes)
         return env, nl, nl
       def _GetUpdatedParams(self, old_params, update_dict,
       @staticmethod
       def _GetUpdatedParams(old_params, update_dict,
                             default_values, parameter_types):
         """Return the new params dict for the given params.

     class HttpJsonConverter: # pylint: disable-msg=W0232
       CONTENT_TYPE = "application/json"
       def Encode(self, data):
       @staticmethod
       def Encode(data):
         return serializer.DumpJson(data)
       def Decode(self, data):
       @staticmethod
       def Decode(data):
         return serializer.LoadJson(data)

         except KeyError:
           pass
       def _CheckRpcResult(self, result, nodes, failmsg):
       @staticmethod
       def _CheckRpcResult(result, nodes, failmsg):
         """Verifies the status of an RPC call.
         Since we aim to keep consistency should this node (the current
-...
         result = rpc.RpcRunner.call_jobqueue_rename(names, addrs, rename)
         self._CheckRpcResult(result, self._nodes, "Renaming files (%r)" % rename)
       def _FormatJobID(self, job_id):
       @staticmethod
       def _FormatJobID(job_id):
         """Convert a job ID to string format.
         Currently this just does C{str(job_id)} after performing some
-...
         return (archived_count, len(all_job_ids) - last_touched - 1)
       def _GetJobInfoUnlocked(self, job, fields):
       @staticmethod
       def _GetJobInfoUnlocked(job, fields):
         """Returns information about a job.
         @type job: L{_QueuedJob}

       """/ resource.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Show the list of mapped resources.
         @return: a dictionary with 'name' and 'uri' keys for each of them.
-...
       """ /2 resource, the root of the version 2 API.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Show the list of mapped resources.
         @return: a dictionary with 'name' and 'uri' keys for each of them.

       to adapt clients accordingly.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Returns the remote API version.
         """
-...
       """Cluster info.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Returns cluster information.
         """
-...
       """/2/os resource.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Return a list of all OSes.
         Can return error 500 in case of a problem.
-...
       """/2/redistribute-config resource.
       """
       def PUT(self):
       @staticmethod
       def PUT():
         """Redistribute configuration to all nodes.
         """
-...
       """/2/jobs resource.
       """
       def GET(self):
       @staticmethod
       def GET():
         """Returns a dictionary of jobs.
         @return: a dictionary with jobs id and uri.

           Log("remove export", indent=2)
           self.ExecOrQueue(instance, exp_op, rem_op, imp_op, erem_op)
       def StopInstanceOp(self, instance):
       @staticmethod
       def StopInstanceOp(instance):
         """Stop given instance."""
         return opcodes.OpShutdownInstance(instance_name=instance)
       def StartInstanceOp(self, instance):
       @staticmethod
       def StartInstanceOp(instance):
         """Start given instance."""
         return opcodes.OpStartupInstance(instance_name=instance, force=False)
       def RenameInstanceOp(self, instance, instance_new):
       @staticmethod
       def RenameInstanceOp(instance, instance_new):
         """Rename instance."""
         return opcodes.OpRenameInstance(instance_name=instance,
                                         new_name=instance_new)

           else:
             print "Invalid node name"
       def do_EOF(self, line):
       @staticmethod
       def do_EOF(line):
         """Exit the application.
         """
         print
         return True
       def do_quit(self, line):
       @staticmethod
       def do_quit(line):
         """Exit the application.
         """

Synnefo » snf-ganeti