golden hour

/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils

⬆️ Go Up

Upload

File/Folder	Size	Actions
__init__.py	237 B	Del OK
__pycache__	-	Del OK
aggregation.py	5.17 KB	Del OK
ansible.py	1.48 KB	Del OK
args.py	18.33 KB	Del OK
asynchronous.py	4.06 KB	Del OK
atomicfile.py	5.33 KB	Del OK
aws.py	20.37 KB	Del OK
azurearm.py	11.42 KB	Del OK
beacons.py	517 B	Del OK
boto3mod.py	8.36 KB	Del OK
boto_elb_tag.py	3.02 KB	Del OK
botomod.py	7.98 KB	Del OK
cache.py	11.49 KB	Del OK
channel.py	489 B	Del OK
cloud.py	116.3 KB	Del OK
color.py	2.72 KB	Del OK
compat.py	1.89 KB	Del OK
configcomparer.py	3.88 KB	Del OK
configparser.py	10.82 KB	Del OK
context.py	6.8 KB	Del OK
crypt.py	5 KB	Del OK
ctx.py	1.42 KB	Del OK
data.py	53.03 KB	Del OK
dateutils.py	2.3 KB	Del OK
debug.py	4.19 KB	Del OK
decorators	-	Del OK
dictdiffer.py	16.48 KB	Del OK
dicttrim.py	3.9 KB	Del OK
dictupdate.py	11.33 KB	Del OK
dns.py	35.21 KB	Del OK
doc.py	2.25 KB	Del OK
dockermod	-	Del OK
entrypoints.py	1.83 KB	Del OK
environment.py	2.2 KB	Del OK
error.py	1.18 KB	Del OK
etcd_util.py	33.25 KB	Del OK
event.py	52.45 KB	Del OK
extend.py	8.87 KB	Del OK
extmods.py	6.04 KB	Del OK
filebuffer.py	3.15 KB	Del OK
files.py	27.94 KB	Del OK
find.py	22.08 KB	Del OK
fsutils.py	3.29 KB	Del OK
functools.py	6.02 KB	Del OK
gitfs.py	130.41 KB	Del OK
github.py	1.52 KB	Del OK
gzip_util.py	2.86 KB	Del OK
hashutils.py	5.91 KB	Del OK
http.py	33.9 KB	Del OK
iam.py	1.22 KB	Del OK
icinga2.py	754 B	Del OK
idem.py	1.22 KB	Del OK
immutabletypes.py	2.46 KB	Del OK
itertools.py	2.36 KB	Del OK
jid.py	3 KB	Del OK
jinja.py	33.92 KB	Del OK
job.py	6.89 KB	Del OK
json.py	3.78 KB	Del OK
kickstart.py	41.04 KB	Del OK
kinds.py	493 B	Del OK
lazy.py	3.06 KB	Del OK
listdiffer.py	10.9 KB	Del OK
locales.py	2.06 KB	Del OK
mac_utils.py	14.01 KB	Del OK
mako.py	3.97 KB	Del OK
master.py	29.7 KB	Del OK
mattermost.py	1.77 KB	Del OK
memcached.py	3.56 KB	Del OK
migrations.py	1.46 KB	Del OK
mine.py	3.68 KB	Del OK
minion.py	4.13 KB	Del OK
minions.py	43.38 KB	Del OK
mount.py	1.15 KB	Del OK
msazure.py	5.36 KB	Del OK
msgpack.py	4.69 KB	Del OK
nacl.py	13.65 KB	Del OK
namecheap.py	4.32 KB	Del OK
napalm.py	23.22 KB	Del OK
nb_popen.py	7.24 KB	Del OK
network.py	73.86 KB	Del OK
nxos.py	12.94 KB	Del OK
nxos_api.py	4 KB	Del OK
odict.py	13.21 KB	Del OK
openstack	-	Del OK
oset.py	6.41 KB	Del OK
pagerduty.py	3.03 KB	Del OK
parsers.py	122.69 KB	Del OK
path.py	11.24 KB	Del OK
pbm.py	9.81 KB	Del OK
pkg	-	Del OK
platform.py	5.84 KB	Del OK
powershell.py	4.15 KB	Del OK
preseed.py	2.64 KB	Del OK
process.py	40.76 KB	Del OK
profile.py	3.21 KB	Del OK
proxy.py	331 B	Del OK
psutil_compat.py	3.63 KB	Del OK
pushover.py	4.51 KB	Del OK
pycrypto.py	5.41 KB	Del OK
pydsl.py	13.74 KB	Del OK
pyobjects.py	10.75 KB	Del OK
reactor.py	18.99 KB	Del OK
reclass.py	752 B	Del OK
roster_matcher.py	3.55 KB	Del OK
rsax931.py	8.42 KB	Del OK
s3.py	8.78 KB	Del OK
saltclass.py	14.27 KB	Del OK
sanitizers.py	2.51 KB	Del OK
schedule.py	71.81 KB	Del OK
schema.py	54.26 KB	Del OK
sdb.py	4.04 KB	Del OK
slack.py	3.58 KB	Del OK
smb.py	11.16 KB	Del OK
smtp.py	3.27 KB	Del OK
ssdp.py	14.75 KB	Del OK
ssh.py	769 B	Del OK
state.py	8.43 KB	Del OK
stringio.py	355 B	Del OK
stringutils.py	16.95 KB	Del OK
systemd.py	5.51 KB	Del OK
templates.py	24.03 KB	Del OK
textformat.py	5.03 KB	Del OK
thin.py	31.91 KB	Del OK
timed_subprocess.py	4.06 KB	Del OK
timeout.py	1.53 KB	Del OK
timeutil.py	2.4 KB	Del OK
url.py	5 KB	Del OK
user.py	11.86 KB	Del OK
validate	-	Del OK
value.py	247 B	Del OK
vault.py	21.74 KB	Del OK
verify.py	25.34 KB	Del OK
versions.py	17.17 KB	Del OK
virt.py	3.24 KB	Del OK
virtualbox.py	22.43 KB	Del OK
vmware.py	129.74 KB	Del OK
vsan.py	17.18 KB	Del OK
vt.py	31.47 KB	Del OK
vt_helper.py	4.4 KB	Del OK
win_chcp.py	3.7 KB	Del OK
win_dacl.py	95.49 KB	Del OK
win_dotnet.py	4.74 KB	Del OK
win_functions.py	12.69 KB	Del OK
win_lgpo_auditpol.py	8.48 KB	Del OK
win_lgpo_netsh.py	17.87 KB	Del OK
win_lgpo_reg.py	16.98 KB	Del OK
win_network.py	16.35 KB	Del OK
win_osinfo.py	2.83 KB	Del OK
win_pdh.py	13.85 KB	Del OK
win_reg.py	30.82 KB	Del OK
win_runas.py	10.53 KB	Del OK
win_service.py	5.2 KB	Del OK
win_system.py	14.47 KB	Del OK
win_update.py	40.36 KB	Del OK
winapi.py	818 B	Del OK
x509.py	73.19 KB	Del OK
xdg.py	316 B	Del OK
xmlutil.py	13.91 KB	Del OK
yaml.py	349 B	Del OK
yamldumper.py	3.37 KB	Del OK
yamlencoding.py	1.55 KB	Del OK
yamllint.py	1.61 KB	Del OK
yamlloader.py	6.04 KB	Del OK
yamlloader_old.py	8.15 KB	Del OK
yast.py	619 B	Del OK
zeromq.py	1.74 KB	Del OK
zfs.py	19.15 KB	Del OK

Edit: pbm.py

""" Library for VMware Storage Policy management (via the pbm endpoint) This library is used to manage the various policies available in VMware :codeauthor: Alexandru Bleotu <alexandru.bleotu@morganstaley.com> Dependencies ~~~~~~~~~~~~ - pyVmomi Python Module pyVmomi ------- PyVmomi can be installed via pip: .. code-block:: bash pip install pyVmomi .. note:: versions of Python. If using version 6.0 of pyVmomi, Python 2.6, Python 2.7.9, or newer must be present. This is due to an upstream dependency in pyVmomi 6.0 that is not supported in Python versions 2.7 to 2.7.8. If the version of Python is not in the supported range, you will need to install an earlier version of pyVmomi. See `Issue #29537`_ for more information. .. _Issue #29537: https://github.com/saltstack/salt/issues/29537 Based on the note above, to install an earlier version of pyVmomi than the version currently listed in PyPi, run the following: .. code-block:: bash pip install pyVmomi==5.5.0.2014.1.1 """ import logging import salt.utils.vmware from salt.exceptions import ( VMwareApiError, VMwareObjectRetrievalError, VMwareRuntimeError, ) try: from pyVmomi import pbm, vim, vmodl # pylint: disable=no-name-in-module HAS_PYVMOMI = True except ImportError: HAS_PYVMOMI = False # Get Logging Started log = logging.getLogger(__name__) def __virtual__(): """ Only load if PyVmomi is installed. """ if HAS_PYVMOMI: return True else: return ( False, "Missing dependency: The salt.utils.pbm module " "requires the pyvmomi library", ) def get_profile_manager(service_instance): """ Returns a profile manager service_instance Service instance to the host or vCenter """ stub = salt.utils.vmware.get_new_service_instance_stub( service_instance, ns="pbm/2.0", path="/pbm/sdk" ) pbm_si = pbm.ServiceInstance("ServiceInstance", stub) try: profile_manager = pbm_si.RetrieveContent().profileManager except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) return profile_manager def get_placement_solver(service_instance): """ Returns a placement solver service_instance Service instance to the host or vCenter """ stub = salt.utils.vmware.get_new_service_instance_stub( service_instance, ns="pbm/2.0", path="/pbm/sdk" ) pbm_si = pbm.ServiceInstance("ServiceInstance", stub) try: profile_manager = pbm_si.RetrieveContent().placementSolver except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) return profile_manager def get_capability_definitions(profile_manager): """ Returns a list of all capability definitions. profile_manager Reference to the profile manager. """ res_type = pbm.profile.ResourceType( resourceType=pbm.profile.ResourceTypeEnum.STORAGE ) try: cap_categories = profile_manager.FetchCapabilityMetadata(res_type) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) cap_definitions = [] for cat in cap_categories: cap_definitions.extend(cat.capabilityMetadata) return cap_definitions def get_policies_by_id(profile_manager, policy_ids): """ Returns a list of policies with the specified ids. profile_manager Reference to the profile manager. policy_ids List of policy ids to retrieve. """ try: return profile_manager.RetrieveContent(policy_ids) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) def get_storage_policies(profile_manager, policy_names=None, get_all_policies=False): """ Returns a list of the storage policies, filtered by name. profile_manager Reference to the profile manager. policy_names List of policy names to filter by. Default is None. get_all_policies Flag specifying to return all policies, regardless of the specified filter. """ res_type = pbm.profile.ResourceType( resourceType=pbm.profile.ResourceTypeEnum.STORAGE ) try: policy_ids = profile_manager.QueryProfile(res_type) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) log.trace("policy_ids = %s", policy_ids) # More policies are returned so we need to filter again policies = [ p for p in get_policies_by_id(profile_manager, policy_ids) if p.resourceType.resourceType == pbm.profile.ResourceTypeEnum.STORAGE ] if get_all_policies: return policies if not policy_names: policy_names = [] return [p for p in policies if p.name in policy_names] def create_storage_policy(profile_manager, policy_spec): """ Creates a storage policy. profile_manager Reference to the profile manager. policy_spec Policy update spec. """ try: profile_manager.Create(policy_spec) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) def update_storage_policy(profile_manager, policy, policy_spec): """ Updates a storage policy. profile_manager Reference to the profile manager. policy Reference to the policy to be updated. policy_spec Policy update spec. """ try: profile_manager.Update(policy.profileId, policy_spec) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) def get_default_storage_policy_of_datastore(profile_manager, datastore): """ Returns the default storage policy reference assigned to a datastore. profile_manager Reference to the profile manager. datastore Reference to the datastore. """ # Retrieve all datastores visible hub = pbm.placement.PlacementHub(hubId=datastore._moId, hubType="Datastore") log.trace("placement_hub = %s", hub) try: policy_id = profile_manager.QueryDefaultRequirementProfile(hub) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg) policy_refs = get_policies_by_id(profile_manager, [policy_id]) if not policy_refs: raise VMwareObjectRetrievalError( "Storage policy with id '{}' was not found".format(policy_id) ) return policy_refs[0] def assign_default_storage_policy_to_datastore(profile_manager, policy, datastore): """ Assigns a storage policy as the default policy to a datastore. profile_manager Reference to the profile manager. policy Reference to the policy to assigned. datastore Reference to the datastore. """ placement_hub = pbm.placement.PlacementHub( hubId=datastore._moId, hubType="Datastore" ) log.trace("placement_hub = %s", placement_hub) try: profile_manager.AssignDefaultRequirementProfile( policy.profileId, [placement_hub] ) except vim.fault.NoPermission as exc: log.exception(exc) raise VMwareApiError( "Not enough permissions. Required privilege: {}".format(exc.privilegeId) ) except vim.fault.VimFault as exc: log.exception(exc) raise VMwareApiError(exc.msg) except vmodl.RuntimeFault as exc: log.exception(exc) raise VMwareRuntimeError(exc.msg)
Save