35d67b6a4f
List of improvements:
* Fixed bug with freezer complete command. The root cause of
this problem was not implemented methods get_parser in
classes SessionStart and SessionDelete.
* Actions session-start and session-end and appropriate classes
was removed due to this actions are not called by user, it's
triggered by freezer-scheduler directly [1].
* Action session-list now prints empty table if no sessions
found.
* Import objects replaced on import modules
[1]85ab97121e/freezer/scheduler/scheduler_job.py (L432)
Change-Id: I49933fd77d858fa0e07849889678de9703a4824e
Closes-Bug: #1640761
Closes-Bug: #1641991
Signed-off-by: Ruslan Aliev <raliev@mirantis.com>
236 lines
7.9 KiB
Python
236 lines
7.9 KiB
Python
# (c) Copyright 2014-2016 Hewlett-Packard Development Company, L.P.
|
|
#
|
|
# 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.
|
|
|
|
import logging
|
|
import os
|
|
import sys
|
|
|
|
from cliff import app
|
|
from cliff import commandmanager
|
|
|
|
from freezerclient.v1 import actions
|
|
from freezerclient.v1 import backups
|
|
from freezerclient.v1 import client
|
|
from freezerclient.v1 import clients
|
|
from freezerclient.v1 import jobs
|
|
from freezerclient.v1 import sessions
|
|
|
|
|
|
log = logging.getLogger(__name__)
|
|
# Suppress output from requests
|
|
logging.getLogger('requests').setLevel(logging.WARN)
|
|
|
|
|
|
class FreezerCommandManager(commandmanager.CommandManager):
|
|
"""All commands available for the shell are registered here"""
|
|
SHELL_COMMANDS = {
|
|
'job-show': jobs.JobShow,
|
|
'job-list': jobs.JobList,
|
|
'job-create': jobs.JobCreate,
|
|
'job-get': jobs.JobGet,
|
|
'job-delete': jobs.JobDelete,
|
|
'job-start': jobs.JobStart,
|
|
'job-stop': jobs.JobStop,
|
|
'job-abort': jobs.JobAbort,
|
|
'job-update': jobs.JobUpdate,
|
|
'client-list': clients.ClientList,
|
|
'client-show': clients.ClientShow,
|
|
'client-register': clients.ClientRegister,
|
|
'client-delete': clients.ClientDelete,
|
|
'backup-list': backups.BackupList,
|
|
'backup-show': backups.BackupShow,
|
|
'session-list': sessions.SessionList,
|
|
'session-show': sessions.SessionShow,
|
|
'session-create': sessions.SessionCreate,
|
|
'session-add-job': sessions.SessionAddJob,
|
|
'session-remove-job': sessions.SessionRemoveJob,
|
|
'session-update': sessions.SessionUpdate,
|
|
'action-show': actions.ActionShow,
|
|
'action-list': actions.ActionList,
|
|
'action-delete': actions.ActionDelete,
|
|
'action-create': actions.ActionCreate,
|
|
'action-update': actions.ActionUpdate
|
|
}
|
|
|
|
def load_commands(self, namespace):
|
|
for name, command_class in self.SHELL_COMMANDS.items():
|
|
self.add_command(name, command_class)
|
|
|
|
|
|
class FreezerShell(app.App):
|
|
def __init__(self):
|
|
super(FreezerShell, self).__init__(
|
|
description='Python Freezer Client',
|
|
version='0.1',
|
|
deferred_help=True,
|
|
command_manager=FreezerCommandManager(None),
|
|
)
|
|
|
|
def build_option_parser(self, description, version):
|
|
parser = super(FreezerShell, self).build_option_parser(description,
|
|
version)
|
|
parser.add_argument(
|
|
'--os-auth-url',
|
|
dest='os_auth_url',
|
|
default=os.environ.get('OS_AUTH_URL'),
|
|
help='Specify identity endpoint',
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-backup-url',
|
|
dest='os_backup_url',
|
|
default=os.environ.get('OS_BACKUP_URL'),
|
|
help='Specify the Freezer backup service endpoint to use'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-endpoint-type',
|
|
dest='os_endpoint_type',
|
|
default=os.environ.get('OS_ENDPOINT_TYPE') or 'public',
|
|
help='''Endpoint type to select. Valid endpoint types:
|
|
"public" or "publicURL", "internal" or "internalURL",
|
|
"admin" or "adminURL"'''
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-identity-api-version',
|
|
dest='os_identity_api_version',
|
|
default=os.environ.get('OS_IDENTITY_API_VERSION'),
|
|
help='Identity API version: 2.0 or 3'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-password',
|
|
dest='os_password',
|
|
default=os.environ.get('OS_PASSWORD'),
|
|
help='''Password used for authentication with the OpenStack
|
|
Identity service'''
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-username',
|
|
dest='os_username',
|
|
default=os.environ.get('OS_USERNAME'),
|
|
help='''Name used for authentication with the OpenStack
|
|
Identity service'''
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-token',
|
|
dest='os_token',
|
|
default=os.environ.get('OS_TOKEN'),
|
|
help='''Specify an existing token to use instead of retrieving
|
|
one via authentication'''
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-project-domain-name',
|
|
dest='os_project_domain_name',
|
|
default=os.environ.get('OS_PROJECT_DOMAIN_NAME'),
|
|
help='Domain name containing project'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-project-name',
|
|
dest='os_project_name',
|
|
default=os.environ.get('OS_PROJECT_NAME'),
|
|
help='Project name to scope to'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-region-name',
|
|
dest='os_region_name',
|
|
default=os.environ.get('OS_REGION_NAME'),
|
|
help='Specify the region to use'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-tenant-id',
|
|
dest='os_tenant_id',
|
|
default=os.environ.get('OS_TENANT_ID'),
|
|
help='Tenant to request authorization on'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-tenant-name',
|
|
dest='os_tenant_name',
|
|
default=os.environ.get('OS_TENANT_NAME'),
|
|
help='Tenant to request authorization on'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-user-domain-name',
|
|
dest='os_user_domain_name',
|
|
default=os.environ.get('OS_USER_DOMAIN_NAME'),
|
|
help='User domain name'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'-k', '--insecure',
|
|
dest='insecure',
|
|
action='store_true',
|
|
default=os.environ.get('OS_INSECURE'),
|
|
help='use python-freezerclient with insecure connections'
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-cacert',
|
|
dest='os_cacert',
|
|
default=os.environ.get('OS_CACERT'),
|
|
help='''Path of CA TLS certificate(s) used to verify the
|
|
remote server's certificate. Without this option
|
|
freezer looks for the default system CA certificates.'''
|
|
)
|
|
|
|
parser.add_argument(
|
|
'--os-cert',
|
|
dest='os_cert',
|
|
default=os.environ.get('OS_CERT'),
|
|
help='''Path of CERT TLS certificate(s) used to verify the
|
|
remote server's certificate.1'''
|
|
)
|
|
|
|
return parser
|
|
|
|
@property
|
|
def client(self):
|
|
"""Build a client object to communicate with the API
|
|
:return: freezerclient object
|
|
"""
|
|
opts = {
|
|
'token': self.options.os_token,
|
|
'version': self.options.os_identity_api_version,
|
|
'username': self.options.os_username,
|
|
'password': self.options.os_password,
|
|
'tenant_name': self.options.os_tenant_name,
|
|
'auth_url': self.options.os_auth_url,
|
|
'endpoint': self.options.os_backup_url,
|
|
'endpoint_type': self.options.os_endpoint_type,
|
|
'project_name': self.options.os_project_name,
|
|
'user_domain_name': self.options.os_user_domain_name,
|
|
'project_domain_name': self.options.os_project_domain_name,
|
|
'verify': True or self.options.os_cacert,
|
|
'cert': self.options.os_cert,
|
|
'insecure': self.options.insecure
|
|
}
|
|
return client.Client(**opts)
|
|
|
|
|
|
def main(argv=sys.argv[1:]):
|
|
return FreezerShell().run(argv)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
sys.exit(main(sys.argv[1:]))
|