summaryrefslogtreecommitdiffstats
path: root/deploy/adapters/ansible/roles/ceph-config/templates/dump_var.j2
blob: a4a9b1552c0c5104bc2a1087205b7e269ccb9825 (plain) 
1
2
3
4
5
6
7
8

HOSTVARS (ANSIBLE GATHERED, group_vars, host_vars) :

{{ hostvars[inventory_hostname] | to_yaml }}

PLAYBOOK VARS:

{{ vars | to_yaml }}
008800; font-weight: bold } /* Keyword.Namespace */ .highlight .kp { color: #008800 } /* Keyword.Pseudo */ .highlight .kr { color: #008800; font-weight: bold } /* Keyword.Reserved */ .highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */ .highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */ .highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */ .highlight .na { color: #336699 } /* Name.Attribute */ .highlight .nb { color: #003388 } /* Name.Builtin */ .highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */ .highlight .no { color: #003366; font-weight: bold } /* Name.Constant */ .highlight .nd { color: #555555 } /* Name.Decorator */ .highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */ .highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */ .highlight .nl { color: #336699; font-style: italic } /* Name.Label */ .highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */ .highlight .py { color: #336699; font-weight: bold } /* Name.Property */ .highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */ .highlight .nv { color: #336699 } /* Name.Variable */ .highlight .ow { color: #008800 } /* Operator.Word */ .highlight .w { color: #bbbbbb } /* Text.Whitespace */ .highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */ .highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */ .highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */ .highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */ .highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */ .highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */ .highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */ .highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */ .highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */ .highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */ } 
#!/usr/bin/env python
##############################################################################
# Copyright (c) 2017 Huawei Technologies Co.,Ltd and others.
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
'''This file contain all functions about storperf API.
At present, This file contain the following function:
1. Ask storperf to configure the environment.
2. Ask Storperf to run testcase and get the job id.
3. Use Job id to ask storperf for status, metrics and metadata.
4. Query information about current jobs, environment and view logs.'''

import time
import requests
import json
import os
import utils.logger as logger

headers = {
    "Content-Type": "application/json",
    "Accept": "application/json"
    }
LOG = logger.Logger(__name__).getLogger()


def storperf_env_prepare(con_dic, storperf_count, storperf_image,
                         storperf_flavor, volume_size):
    base_url = ("http://%s/api/v1.0/configurations"
                % (con_dic['storperf_test_ip']))
    test_dict = {
        "agent_count": storperf_count,
        "agent_image": storperf_image,
        "agent_flavor": storperf_flavor,
        "public_network": os.environ.get("EXTERNAL_NETWORK"),
        "volume_size": volume_size
    }
    LOG.info("waiting for storperf environment to prepare")
    reponse = requests.post(
        base_url, data=json.dumps(test_dict), headers=headers)
    ask_data = json.loads(reponse.text)
    stack_id = ask_data["stack_id"]
    LOG.info("Done, storperf environment prepare complete!")
    time.sleep(30)
    return stack_id


def warmup(con_dic):
    base_url = ("http://%s/api/v1.0/jobs"
                % (con_dic['storperf_test_ip']))
    test_dict = {
        "workload": "_warm_up"
    }
    LOG.info("filling the cinder volume with random data")
    reponse = requests.post(
        base_url, data=json.dumps(test_dict), headers=headers)
    ask_data = json.loads(reponse.text)
    job_id = ask_data["job_id"]
    LOG.info("Done, filled the cinder volume with random data!")
    time.sleep(600)
    return job_id


def job(con_dic):
    base_url = ("http://%s/api/v1.0/jobs"
                % (con_dic['storperf_test_ip']))
    test_dict = {
        "block_sizes": con_dic['block_sizes'],
        "deadline": con_dic['deadline'],
        "steady_state_samples": con_dic['steady_state_samples'],
        "queue_depths": con_dic['queue_depths'],
        "workload": con_dic['workload']
    }
    deadline = con_dic['deadline']
    LOG.info("running the storage performance testcase")
    reponse = requests.post(
        base_url, data=json.dumps(test_dict), headers=headers)
    ask_data = json.loads(reponse.text)
    job_id = ask_data["job_id"]
    LOG.info("Done, testcase still executing for specified deadline")
    time.sleep(deadline)
    return job_id


def current_jobs(con_dic):
    base_url = ("http://%s/api/v1.0/jobs"
                % (con_dic['storperf_test_ip']))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("current storperf jobs are %s" % (reply_data))
    return reply_data


def job_status(con_dic, job_id):
    base_url = ("http://%s/api/v1.0/jobs?id=%s&type=status"
                % (con_dic['storperf_test_ip'], job_id))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("job status is %s" % (reply_data))
    return reply_data


def job_metrics(con_dic, job_id):
    base_url = ("http://%s/api/v1.0/jobs?id=%s&type=metrics"
                % (con_dic['storperf_test_ip'], job_id))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("job metrics is %s" % (reply_data))
    return reply_data


def job_metadata(con_dic, job_id):
    base_url = ("http://%s/api/v1.0/jobs?id=%s&type=metadata"
                % (con_dic['storperf_test_ip'], job_id))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("job metadata is %s" % (reply_data))
    return reply_data


def get_logs(con_dic):
    base_url = ("http://%s/api/v1.0/logs?lines=all"
                % (con_dic['storperf_test_ip']))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("All storperf logs: %s" % (reply_data))
    return reply_data


def get_quotas(con_dic):
    base_url = ("http://%s/api/v1.0/quotas"
                % (con_dic['storperf_test_ip']))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("current quotas is %s" % (reply_data))
    return reply_data


def get_configurations(con_dic):
    base_url = ("http://%s/api/v1.0/configurations"
                % (con_dic['storperf_test_ip']))
    reply_response = requests.get(
        base_url, headers=headers)
    reply_data = json.loads(reply_response.text)
    LOG.info("current configurations is %s" % (reply_data))
    return reply_data


def delete_configurations(con_dic):
    base_url = ("http://%s/api/v1.0/configurations"
                % (con_dic['storperf_test_ip']))
    requests.delete(
        base_url, headers=headers)
    LOG.info("delete the storperf environment")


def delete_jobs(con_dic):
    base_url = ("http://%s/api/v1.0/jobs"
                % (con_dic['storperf_test_ip']))
    requests.delete(
        base_url, headers=headers)
    LOG.info("delete current storperf jobs")