Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
SUSE:SLE-12-SP5:GA
fence-agents.10129
0001-fence_gce-new-agent.patch
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File 0001-fence_gce-new-agent.patch of Package fence-agents.10129
From cab1e1b5fcf119b34f96829f5c618191b02cbc3e Mon Sep 17 00:00:00 2001 From: Helen Koike <helen.koike@collabora.com> Date: Sat, 18 Nov 2017 17:10:24 -0200 Subject: [PATCH] fence_gce: new agent First implementation of GCE agent --- .travis.yml | 1 + configure.ac | 3 ++ fence/agents/gce/fence_gce.py | 110 ++++++++++++++++++++++++++++++++++++++ tests/data/metadata/fence_gce.xml | 110 ++++++++++++++++++++++++++++++++++++++ 4 files changed, 224 insertions(+) create mode 100644 fence/agents/gce/fence_gce.py create mode 100644 tests/data/metadata/fence_gce.xml Index: fence-agents-4.0.17/configure.ac =================================================================== --- fence-agents-4.0.17.orig/configure.ac +++ fence-agents-4.0.17/configure.ac @@ -158,6 +158,10 @@ AC_PYTHON_MODULE(pexpect, 1) AC_PYTHON_MODULE(pycurl, 1) AC_PYTHON_MODULE(requests, 1) +if echo "$AGENTS_LIST" | grep -q gce; then + AC_PYTHON_MODULE(googleapiclient, 1) +fi + ## path to 3rd-party binaries AC_PATH_PROG([IPMITOOL_PATH], [ipmitool], [/usr/bin/ipmitool]) AC_PATH_PROG([AMTTOOL_PATH], [amttool], [/usr/bin/amttool]) Index: fence-agents-4.0.17/fence/agents/gce/fence_gce.py =================================================================== --- /dev/null +++ fence-agents-4.0.17/fence/agents/gce/fence_gce.py @@ -0,0 +1,110 @@ +#!@PYTHON@ -tt + +import atexit +import sys +sys.path.append("@FENCEAGENTSLIBDIR@") +from googleapiclient import discovery +from oauth2client.client import GoogleCredentials + +from fencing import * +from fencing import fail, fail_usage, EC_TIMED_OUT, run_delay + + +def get_nodes_list(conn, options): + result = {} + try: + instanceList = conn.instances().list(project=options["--project"], zone=options["--zone"]).execute() + for instance in instanceList["items"]: + status = "unknown" + if instance["status"] == "RUNNING": + status = "on" + elif instance["status"] == "TERMINATED": + status = "off" + result[instance["id"]] = (instance["name"], status) + # TODO: check which Exceptions it can throw + except: + fail_usage("Failed: Unable to connect to GCE. Check your configuration.") + + return result + +def get_power_status(conn, options): + try: + instance = conn.instances().get(project=options["--project"], zone=options["--zone"], + instance=options["--plug"]).execute() + if instance["status"] == "RUNNING": + return "on" + elif instance["status"] == "TERMINATED": + return "off" + else: + return "unknown" + # TODO: check which Exceptions it can throw + except: + fail_usage("Failed: Unable to connect to GCE. Check your configuration.") + +def set_power_status(conn, options): + try: + if (options["--action"]=="off"): + conn.instances().stop(project=options["--project"], zone=options["--zone"], + instance=options["--plug"]).execute() + elif (options["--action"]=="on"): + conn.instances().start(project=options["--project"], zone=options["--zone"], + instance=options["--plug"]).execute() + # TODO: check which Exceptions it can throw + except : + fail_usage("Failed: Unable to connect to GCE. Check your configuration.") + +def define_new_opts(): + all_opt["zone"] = { + "getopt" : ":", + "longopt" : "zone", + "help" : "--zone=[name] Zone, e.g. us-central1-b", + "shortdesc" : "Zone.", + "required" : "0", + "order" : 2 + } + all_opt["project"] = { + "getopt" : ":", + "longopt" : "project", + "help" : "--project=[name] Project", + "shortdesc" : "Project.", + "required" : "0", + "order" : 3 + } + +def main(): + conn = None + + device_opt = ["port", "no_password", "zone", "project"] + + atexit.register(atexit_handler) + + define_new_opts() + + all_opt["power_timeout"]["default"] = "60" + + options = check_input(device_opt, process_input(device_opt)) + + docs = {} + docs["shortdesc"] = "Fence agent for GCE (Google Cloud Engine)" + docs["longdesc"] = "fence_gce is an I/O Fencing agent for GCE (Google Cloud " \ + "Engine). It uses the googleapiclient library to connect to GCE.\n" \ + "googleapiclient can be configured with Google SDK CLI or by " \ + "executing 'gcloud auth application-default login'.\n" \ + "For instructions see: https://cloud.google.com/compute/docs/tutorials/python-guide" + docs["vendorurl"] = "http://cloud.google.com" + show_docs(options, docs) + + run_delay(options) + + try: + credentials = GoogleCredentials.get_application_default() + conn = discovery.build('compute', 'v1', credentials=credentials) + except: + fail_usage("Failed: Unable to connect to GCE. Check your configuration.") + + # Operate the fencing device + result = fence_action(conn, options, set_power_status, get_power_status, get_nodes_list) + sys.exit(result) + +if __name__ == "__main__": + main() Index: fence-agents-4.0.17/tests/data/metadata/fence_gce.xml =================================================================== --- /dev/null +++ fence-agents-4.0.17/tests/data/metadata/fence_gce.xml @@ -0,0 +1,110 @@ +<?xml version="1.0" ?> +<resource-agent name="fence_gce" shortdesc="Fence agent for GCE (Google Cloud Engine)" > +<longdesc>fence_gce is an I/O Fencing agent for GCE (Google Cloud Engine). It uses the googleapiclient library to connect to GCE. +googleapiclient can be configured with Google SDK CLI or by executing 'gcloud auth application-default login'. +For instructions see: https://cloud.google.com/compute/docs/tutorials/python-guide</longdesc> +<vendor-url>http://cloud.google.com</vendor-url> +<parameters> + <parameter name="action" unique="0" required="1"> + <getopt mixed="-o, --action=[action]" /> + <content type="string" default="reboot" /> + <shortdesc lang="en">Fencing action</shortdesc> + </parameter> + <parameter name="plug" unique="0" required="1" obsoletes="port"> + <getopt mixed="-n, --plug=[id]" /> + <content type="string" /> + <shortdesc lang="en">Physical plug number on device, UUID or identification of machine</shortdesc> + </parameter> + <parameter name="port" unique="0" required="1" deprecated="1"> + <getopt mixed="-n, --plug=[id]" /> + <content type="string" /> + <shortdesc lang="en">Physical plug number on device, UUID or identification of machine</shortdesc> + </parameter> + <parameter name="zone" unique="0" required="0"> + <getopt mixed="--zone=[name]" /> + <content type="string" /> + <shortdesc lang="en">Zone.</shortdesc> + </parameter> + <parameter name="project" unique="0" required="0"> + <getopt mixed="--project=[name]" /> + <content type="string" /> + <shortdesc lang="en">Project.</shortdesc> + </parameter> + <parameter name="quiet" unique="0" required="0"> + <getopt mixed="-q, --quiet" /> + <content type="boolean" /> + <shortdesc lang="en">Disable logging to stderr. Does not affect --verbose or --debug-file or logging to syslog.</shortdesc> + </parameter> + <parameter name="verbose" unique="0" required="0"> + <getopt mixed="-v, --verbose" /> + <content type="boolean" /> + <shortdesc lang="en">Verbose mode</shortdesc> + </parameter> + <parameter name="debug" unique="0" required="0" deprecated="1"> + <getopt mixed="-D, --debug-file=[debugfile]" /> + <content type="string" /> + <shortdesc lang="en">Write debug information to given file</shortdesc> + </parameter> + <parameter name="debug_file" unique="0" required="0" obsoletes="debug"> + <getopt mixed="-D, --debug-file=[debugfile]" /> + <content type="string" /> + <shortdesc lang="en">Write debug information to given file</shortdesc> + </parameter> + <parameter name="version" unique="0" required="0"> + <getopt mixed="-V, --version" /> + <content type="boolean" /> + <shortdesc lang="en">Display version information and exit</shortdesc> + </parameter> + <parameter name="help" unique="0" required="0"> + <getopt mixed="-h, --help" /> + <content type="boolean" /> + <shortdesc lang="en">Display help and exit</shortdesc> + </parameter> + <parameter name="separator" unique="0" required="0"> + <getopt mixed="-C, --separator=[char]" /> + <content type="string" default="," /> + <shortdesc lang="en">Separator for CSV created by 'list' operation</shortdesc> + </parameter> + <parameter name="delay" unique="0" required="0"> + <getopt mixed="--delay=[seconds]" /> + <content type="second" default="0" /> + <shortdesc lang="en">Wait X seconds before fencing is started</shortdesc> + </parameter> + <parameter name="login_timeout" unique="0" required="0"> + <getopt mixed="--login-timeout=[seconds]" /> + <content type="second" default="5" /> + <shortdesc lang="en">Wait X seconds for cmd prompt after login</shortdesc> + </parameter> + <parameter name="power_timeout" unique="0" required="0"> + <getopt mixed="--power-timeout=[seconds]" /> + <content type="second" default="60" /> + <shortdesc lang="en">Test X seconds for status change after ON/OFF</shortdesc> + </parameter> + <parameter name="power_wait" unique="0" required="0"> + <getopt mixed="--power-wait=[seconds]" /> + <content type="second" default="0" /> + <shortdesc lang="en">Wait X seconds after issuing ON/OFF</shortdesc> + </parameter> + <parameter name="shell_timeout" unique="0" required="0"> + <getopt mixed="--shell-timeout=[seconds]" /> + <content type="second" default="3" /> + <shortdesc lang="en">Wait X seconds for cmd prompt after issuing command</shortdesc> + </parameter> + <parameter name="retry_on" unique="0" required="0"> + <getopt mixed="--retry-on=[attempts]" /> + <content type="integer" default="1" /> + <shortdesc lang="en">Count of attempts to retry power on</shortdesc> + </parameter> +</parameters> +<actions> + <action name="on" automatic="0"/> + <action name="off" /> + <action name="reboot" /> + <action name="status" /> + <action name="list" /> + <action name="list-status" /> + <action name="monitor" /> + <action name="metadata" /> + <action name="validate-all" /> +</actions> +</resource-agent>
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor
