cloudmesh_client.comet package

Submodules

cloudmesh_client.comet.authenticate module

exception cloudmesh_client.comet.authenticate.AuthenticationException

Bases: exceptions.Exception

class cloudmesh_client.comet.authenticate.Authenticator(uri=None)

Bases: object

HEADER = {'content-type': 'application/json'}

base_uri = None

classmethod logoff()

classmethod logon(username, password)

classmethod set_auth_base_uri(uri)

classmethod status()

token = None

verify = False

cloudmesh_client.comet.authenticate.hop_get(url, headers=None)

cloudmesh_client.comet.authenticate.main()

cloudmesh_client.comet.authenticate.test_get_cluster_list()

cloudmesh_client.comet.cluster module

class cloudmesh_client.comet.cluster.Cluster

Bases: object

ACTIVE_COMPUTESETS = ['running', 'submitted', 'created']

CLUSTER_HEADER = ['name', 'state', 'kind', 'type', 'mac', 'ip', 'cpus', 'cluster', 'RAM(M)', 'disk(G)', 'computeset', 'allocation', 'admin_state']

CLUSTER_HEADER_TABLE = ['name', 'state', 'computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster', 'kind', 'type', 'cpus', 'RAM(M)', 'disk(G)']

CLUSTER_HEADER_TABLE_CONCISE = ['name', 'state', 'computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster']

CLUSTER_HEADER_TABLE_STATE = ['name', 'state', 'computeset', 'allocation', 'admin_state']

CLUSTER_ORDER = ['name', 'state', 'kind', 'type', 'mac', 'ip', 'cpus', 'cluster', 'memory', 'disksize', 'active_computeset', 'allocation', 'admin_state']

CLUSTER_ORDER_TABLE = ['name', 'state', 'active_computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster', 'kind', 'type', 'cpus', 'memory', 'disksize']

CLUSTER_ORDER_TABLE_CONCISE = ['name', 'state', 'active_computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster']

CLUSTER_ORDER_TABLE_STATE = ['name', 'state', 'active_computeset', 'allocation', 'admin_state']

CLUSTER_SORT_KEY = ['name', 'state', 'kind', 'type', 'mac', 'ip', 'cpus', 'cluster', 'ram', 'disk', 'computeset', 'allocation', 'admin_state']

CLUSTER_TABLE_VIEW = {'STATE': {'header': ['name', 'state', 'computeset', 'allocation', 'admin_state'], 'order': ['name', 'state', 'active_computeset', 'allocation', 'admin_state']}, 'FULL': {'header': ['name', 'state', 'computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster', 'kind', 'type', 'cpus', 'RAM(M)', 'disk(G)'], 'order': ['name', 'state', 'active_computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster', 'kind', 'type', 'cpus', 'memory', 'disksize']}, 'CONCISE': {'header': ['name', 'state', 'computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster'], 'order': ['name', 'state', 'active_computeset', 'allocation', 'admin_state', 'mac', 'ip', 'cluster']}}

FINISHED_COMPUTESETS = ['completed', 'failed']

MINS_PER_UNIT = {'h': 60, 'm': 1, 'd': 1440, 'w': 10080}

N_ALLOCATIONS_PER_LINE = 5

PENDING_COMPUTESETS = ['queued', 'submitted', 'created']

SECS_PER_DAY = 86400

STUCK_COMPUTESETS = ['submitted', 'ending']

WALLTIME_MINS = 2880

static add()

static attach_iso(iso_id_name, clusterid, nodeids=None, action='Attaching')

static check_nodes_computesets(clusterid, computenodeids)

static computeset(id=None, cluster=None, state=None, allocation=None)

static computeset_start(clusterid, computenodeids=None, numnodes=None, allocation=None, reservation=None, walltime=None)

static computeset_terminate(computesetid)

static convert_to_mins(s)

static delete()

static detach_iso(clusterid, nodeids=None, action='Detaching')

static display_get_allocation(allocations)

static format_ddd_hh_mm(time_duration_secs)

static info()

static list(id=None, format='table', sort=None, view='FULL')

static node_info(clusterid, nodeid=None, format='table')

static output_computeset(computesetdict, cluster=None, allocation=None)

static power(clusterid, subject, param=None, action=None)

static rename_node(clusterid, old_compute_name, new_compute_name)

static simple_list(id=None, format='table')

static start(id)

static stop(id)

cloudmesh_client.comet.comet module

class cloudmesh_client.comet.comet.Comet

Bases: object

AUTH_HEADER = {'content-type': 'application/json'}

HEADER = {'content-type': 'application/json'}

api_auth = None

api_key = None

api_secret = None

api_version = ''

auth_provider = None

auth_uri = '/rest-auth'

base_uri = ''

static console(clusterid, nodeid=None, linkonly=False)

static console_url(clusterid, nodeid=None)

static docs()

endpoint = ''

static find_tunnel()

static get(url, headers=None, allow_redirects=True, data=None, authuser=None, authpass=None)

static get_apikey(endpoint)

static get_computeset(id=None, state=None)

static get_nonce()

static http(url, action='get', headers=None, data=None, authuser=None, authpass=None, files=None, md5=None, cacert=True, allow_redirects=True)

static is_tunnel()

static kill_tunnel()

static list_iso()

local_auth_uri = 'https://localhost:8443/nucleus/rest-auth'

local_base_uri = 'https://localhost:8443/nucleus'

classmethod logoff()

classmethod logon(endpoint=None, username=None, password=None)

static md5(fname)

static post(url, headers=None, data=None, md5=None, files=None, cacert=True, allow_redirects=True)

static put(url, headers=None, data=None, allow_redirects=True)

static set_api_version(api_version)

classmethod set_auth_provider(auth_provider=None)

static set_base_uri(uri)

static set_endpoint(endpoint)

static state()

classmethod status()

token = None

static tunnel(start)

tunnelled = False

static upload_iso(filename, filepath)

static url(path)

verify = False

cloudmesh_client.comet.comet.main()

cloudmesh_client.comet.comet.test_get_cluster_list()

cloudmesh_client.comet.comet.test_power_nodes(action='on')

Module contents