dfb0e3e3c1
* use six.iteritems() * replace basestring with six.string_types * convert print statements to functions (they're all debugging and should be removed eventually anyway) * clean up OpenStack copyright: LLC -> Foundation Change-Id: Icb14212bcb408e63816bfec3922a697bc1a6c946
165 lines
4.8 KiB
Python
165 lines
4.8 KiB
Python
# Copyright 2013 OpenStack Foundation
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
#
|
|
|
|
"""Agent action implementations"""
|
|
|
|
import logging
|
|
import six
|
|
|
|
from cliff import command
|
|
from cliff import lister
|
|
from cliff import show
|
|
|
|
from openstackclient.common import utils
|
|
|
|
|
|
class CreateAgent(show.ShowOne):
|
|
"""Create agent command"""
|
|
|
|
log = logging.getLogger(__name__ + ".CreateAgent")
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super(CreateAgent, self).get_parser(prog_name)
|
|
parser.add_argument(
|
|
"os",
|
|
metavar="<os>",
|
|
help="Type of OS")
|
|
parser.add_argument(
|
|
"architecture",
|
|
metavar="<architecture>",
|
|
help="Type of architecture")
|
|
parser.add_argument(
|
|
"version",
|
|
metavar="<version>",
|
|
help="Version")
|
|
parser.add_argument(
|
|
"url",
|
|
metavar="<url>",
|
|
help="URL")
|
|
parser.add_argument(
|
|
"md5hash",
|
|
metavar="<md5hash>",
|
|
help="MD5 hash")
|
|
parser.add_argument(
|
|
"hypervisor",
|
|
metavar="<hypervisor>",
|
|
help="Type of hypervisor",
|
|
default="xen")
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
self.log.debug("take_action(%s)" % parsed_args)
|
|
compute_client = self.app.client_manager.compute
|
|
args = (
|
|
parsed_args.os,
|
|
parsed_args.architecture,
|
|
parsed_args.version,
|
|
parsed_args.url,
|
|
parsed_args.md5hash,
|
|
parsed_args.hypervisor
|
|
)
|
|
agent = compute_client.agents.create(*args)._info.copy()
|
|
return zip(*sorted(six.iteritems(agent)))
|
|
|
|
|
|
class DeleteAgent(command.Command):
|
|
"""Delete agent command"""
|
|
|
|
log = logging.getLogger(__name__ + ".DeleteAgent")
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super(DeleteAgent, self).get_parser(prog_name)
|
|
parser.add_argument(
|
|
"id",
|
|
metavar="<id>",
|
|
help="ID of agent to delete")
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
self.log.debug("take_action(%s)" % parsed_args)
|
|
compute_client = self.app.client_manager.compute
|
|
compute_client.agents.delete(parsed_args.id)
|
|
return
|
|
|
|
|
|
class ListAgent(lister.Lister):
|
|
"""List agent command"""
|
|
|
|
log = logging.getLogger(__name__ + ".ListAgent")
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super(ListAgent, self).get_parser(prog_name)
|
|
parser.add_argument(
|
|
"--hypervisor",
|
|
metavar="<hypervisor>",
|
|
help="Type of hypervisor")
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
self.log.debug("take_action(%s)" % parsed_args)
|
|
compute_client = self.app.client_manager.compute
|
|
columns = (
|
|
"Agent ID",
|
|
"Hypervisor",
|
|
"OS",
|
|
"Architecture",
|
|
"Version",
|
|
"Md5Hash",
|
|
"URL"
|
|
)
|
|
data = compute_client.agents.list(parsed_args.hypervisor)
|
|
return (columns,
|
|
(utils.get_item_properties(
|
|
s, columns,
|
|
) for s in data))
|
|
|
|
|
|
class SetAgent(show.ShowOne):
|
|
"""Set agent command"""
|
|
|
|
log = logging.getLogger(__name__ + ".SetAgent")
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super(SetAgent, self).get_parser(prog_name)
|
|
parser.add_argument(
|
|
"id",
|
|
metavar="<id>",
|
|
help="ID of the agent build")
|
|
parser.add_argument(
|
|
"version",
|
|
metavar="<version>",
|
|
help="Version of the agent")
|
|
parser.add_argument(
|
|
"url",
|
|
metavar="<url>",
|
|
help="URL")
|
|
parser.add_argument(
|
|
"md5hash",
|
|
metavar="<md5hash>",
|
|
help="MD5 hash")
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
self.log.debug("take_action(%s)" % parsed_args)
|
|
compute_client = self.app.client_manager.compute
|
|
args = (
|
|
parsed_args.id,
|
|
parsed_args.version,
|
|
parsed_args.url,
|
|
parsed_args.md5hash
|
|
)
|
|
agent = compute_client.agents.update(*args)._info.copy()
|
|
return zip(*sorted(six.iteritems(agent)))
|