golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.py
35 B
Del
OK
__pycache__
-
Del
OK
acme.py
12.74 KB
Del
OK
aix_group.py
4.12 KB
Del
OK
aix_shadow.py
1.93 KB
Del
OK
aixpkg.py
24.15 KB
Del
OK
aliases.py
5.07 KB
Del
OK
alternatives.py
5.71 KB
Del
OK
ansiblegate.py
19.51 KB
Del
OK
apache.py
12.47 KB
Del
OK
apcups.py
2.15 KB
Del
OK
apf.py
3.09 KB
Del
OK
apkpkg.py
16 KB
Del
OK
aptly.py
15.28 KB
Del
OK
aptpkg.py
116.64 KB
Del
OK
archive.py
48.63 KB
Del
OK
arista_pyeapi.py
22.06 KB
Del
OK
artifactory.py
24.78 KB
Del
OK
at.py
10.72 KB
Del
OK
at_solaris.py
8.51 KB
Del
OK
augeas_cfg.py
13.93 KB
Del
OK
aws_sqs.py
6.55 KB
Del
OK
azurearm_compute.py
20.8 KB
Del
OK
azurearm_dns.py
15.8 KB
Del
OK
azurearm_network.py
82.99 KB
Del
OK
azurearm_resource.py
35.75 KB
Del
OK
bamboohr.py
7.36 KB
Del
OK
baredoc.py
11.13 KB
Del
OK
bcache.py
28.97 KB
Del
OK
beacons.py
27.82 KB
Del
OK
bigip.py
69.11 KB
Del
OK
bluez_bluetooth.py
6.76 KB
Del
OK
boto3_elasticache.py
37.34 KB
Del
OK
boto3_elasticsearch.py
53.17 KB
Del
OK
boto3_route53.py
39.82 KB
Del
OK
boto3_sns.py
12.93 KB
Del
OK
boto_apigateway.py
61.86 KB
Del
OK
boto_asg.py
35.69 KB
Del
OK
boto_cfn.py
7.95 KB
Del
OK
boto_cloudfront.py
12.75 KB
Del
OK
boto_cloudtrail.py
14.45 KB
Del
OK
boto_cloudwatch.py
10.99 KB
Del
OK
boto_cloudwatch_event.py
9.48 KB
Del
OK
boto_cognitoidentity.py
14.63 KB
Del
OK
boto_datapipeline.py
6.94 KB
Del
OK
boto_dynamodb.py
14.98 KB
Del
OK
boto_ec2.py
79.27 KB
Del
OK
boto_efs.py
14.05 KB
Del
OK
boto_elasticache.py
23.69 KB
Del
OK
boto_elasticsearch_domain.py
15.85 KB
Del
OK
boto_elb.py
35.53 KB
Del
OK
boto_elbv2.py
10.78 KB
Del
OK
boto_iam.py
75.62 KB
Del
OK
boto_iot.py
26.2 KB
Del
OK
boto_kinesis.py
19.62 KB
Del
OK
boto_kms.py
17.29 KB
Del
OK
boto_lambda.py
35.05 KB
Del
OK
boto_rds.py
34.92 KB
Del
OK
boto_route53.py
32.55 KB
Del
OK
boto_s3.py
4.24 KB
Del
OK
boto_s3_bucket.py
31.8 KB
Del
OK
boto_secgroup.py
25.22 KB
Del
OK
boto_sns.py
7.22 KB
Del
OK
boto_sqs.py
6.43 KB
Del
OK
boto_ssm.py
3.63 KB
Del
OK
boto_vpc.py
113.08 KB
Del
OK
bower.py
5.85 KB
Del
OK
bridge.py
10.81 KB
Del
OK
bsd_shadow.py
6.25 KB
Del
OK
btrfs.py
33.66 KB
Del
OK
cabal.py
3.79 KB
Del
OK
capirca_acl.py
40.04 KB
Del
OK
cassandra_cql.py
54.16 KB
Del
OK
cassandra_mod.py
4.3 KB
Del
OK
celery.py
3.33 KB
Del
OK
ceph.py
15.82 KB
Del
OK
chassis.py
1.52 KB
Del
OK
chef.py
4.66 KB
Del
OK
chocolatey.py
41.55 KB
Del
OK
chronos.py
2.89 KB
Del
OK
chroot.py
11.73 KB
Del
OK
cimc.py
23.02 KB
Del
OK
ciscoconfparse_mod.py
14.79 KB
Del
OK
cisconso.py
3.83 KB
Del
OK
cloud.py
9.39 KB
Del
OK
cmdmod.py
163.73 KB
Del
OK
composer.py
10.31 KB
Del
OK
config.py
16.98 KB
Del
OK
consul.py
69.3 KB
Del
OK
container_resource.py
12.94 KB
Del
OK
cp.py
31.98 KB
Del
OK
cpan.py
5.54 KB
Del
OK
cron.py
28.09 KB
Del
OK
cryptdev.py
10.08 KB
Del
OK
csf.py
16.04 KB
Del
OK
cyg.py
8.32 KB
Del
OK
daemontools.py
5.41 KB
Del
OK
data.py
3.85 KB
Del
OK
datadog_api.py
7.76 KB
Del
OK
ddns.py
7.12 KB
Del
OK
deb_apache.py
7.41 KB
Del
OK
deb_postgres.py
4.18 KB
Del
OK
debconfmod.py
4.06 KB
Del
OK
debian_ip.py
64.91 KB
Del
OK
debian_service.py
6.55 KB
Del
OK
debuild_pkgbuild.py
34.68 KB
Del
OK
defaults.py
6.55 KB
Del
OK
devinfo.py
9.07 KB
Del
OK
devmap.py
627 B
Del
OK
dig.py
8.75 KB
Del
OK
disk.py
30.82 KB
Del
OK
djangomod.py
7.53 KB
Del
OK
dnsmasq.py
5.71 KB
Del
OK
dnsutil.py
11.51 KB
Del
OK
dockercompose.py
32.62 KB
Del
OK
dockermod.py
224.85 KB
Del
OK
dpkg_lowpkg.py
12.94 KB
Del
OK
drac.py
10.97 KB
Del
OK
dracr.py
38.53 KB
Del
OK
drbd.py
7.19 KB
Del
OK
dummyproxy_pkg.py
2.46 KB
Del
OK
dummyproxy_service.py
2.91 KB
Del
OK
ebuildpkg.py
38.74 KB
Del
OK
eix.py
1.58 KB
Del
OK
elasticsearch.py
51.44 KB
Del
OK
environ.py
8.96 KB
Del
OK
eselect.py
4.99 KB
Del
OK
esxcluster.py
1.66 KB
Del
OK
esxdatacenter.py
1.68 KB
Del
OK
esxi.py
2.79 KB
Del
OK
esxvm.py
1.63 KB
Del
OK
etcd_mod.py
8.56 KB
Del
OK
ethtool.py
11.12 KB
Del
OK
event.py
7.67 KB
Del
OK
extfs.py
8.78 KB
Del
OK
file.py
232.18 KB
Del
OK
firewalld.py
20.51 KB
Del
OK
freebsd_sysctl.py
4.99 KB
Del
OK
freebsd_update.py
6.19 KB
Del
OK
freebsdjail.py
7.16 KB
Del
OK
freebsdkmod.py
6.17 KB
Del
OK
freebsdpkg.py
17.04 KB
Del
OK
freebsdports.py
13.13 KB
Del
OK
freebsdservice.py
12.53 KB
Del
OK
freezer.py
10.2 KB
Del
OK
gcp_addon.py
4.07 KB
Del
OK
gem.py
10.6 KB
Del
OK
genesis.py
21.75 KB
Del
OK
gentoo_service.py
9.18 KB
Del
OK
gentoolkitmod.py
8.39 KB
Del
OK
git.py
172.01 KB
Del
OK
github.py
53.19 KB
Del
OK
glanceng.py
4.69 KB
Del
OK
glassfish.py
19.49 KB
Del
OK
glusterfs.py
19.55 KB
Del
OK
gnomedesktop.py
6.85 KB
Del
OK
google_chat.py
1.52 KB
Del
OK
gpg.py
39.09 KB
Del
OK
grafana4.py
30.27 KB
Del
OK
grains.py
21.81 KB
Del
OK
groupadd.py
11.87 KB
Del
OK
grub_legacy.py
3.08 KB
Del
OK
guestfs.py
2.37 KB
Del
OK
hadoop.py
3.76 KB
Del
OK
haproxyconn.py
10.17 KB
Del
OK
hashutil.py
6.77 KB
Del
OK
heat.py
25.25 KB
Del
OK
helm.py
39.27 KB
Del
OK
hg.py
7.16 KB
Del
OK
highstate_doc.py
22.76 KB
Del
OK
hosts.py
10.47 KB
Del
OK
http.py
3.76 KB
Del
OK
icinga2.py
4.46 KB
Del
OK
idem.py
1.75 KB
Del
OK
ifttt.py
2.28 KB
Del
OK
ilo.py
15.98 KB
Del
OK
incron.py
7.68 KB
Del
OK
influxdb08mod.py
15.07 KB
Del
OK
influxdbmod.py
16.13 KB
Del
OK
infoblox.py
17.53 KB
Del
OK
ini_manage.py
14.63 KB
Del
OK
inspectlib
-
Del
OK
inspector.py
8.19 KB
Del
OK
introspect.py
4.02 KB
Del
OK
iosconfig.py
14.78 KB
Del
OK
ipmi.py
25.47 KB
Del
OK
ipset.py
17.97 KB
Del
OK
iptables.py
57.44 KB
Del
OK
iwtools.py
3.99 KB
Del
OK
jboss7.py
20.51 KB
Del
OK
jboss7_cli.py
15.23 KB
Del
OK
jenkinsmod.py
11.9 KB
Del
OK
jinja.py
2.66 KB
Del
OK
jira_mod.py
7.07 KB
Del
OK
junos.py
73.96 KB
Del
OK
k8s.py
24.87 KB
Del
OK
kapacitor.py
5.37 KB
Del
OK
kerberos.py
5.42 KB
Del
OK
kernelpkg_linux_apt.py
6.71 KB
Del
OK
kernelpkg_linux_yum.py
7.26 KB
Del
OK
key.py
1007 B
Del
OK
keyboard.py
2.64 KB
Del
OK
keystone.py
43.14 KB
Del
OK
keystoneng.py
21.82 KB
Del
OK
keystore.py
7.18 KB
Del
OK
kmod.py
7.65 KB
Del
OK
kubeadm.py
34.64 KB
Del
OK
kubernetesmod.py
46.77 KB
Del
OK
launchctl_service.py
9.69 KB
Del
OK
layman.py
4.22 KB
Del
OK
ldap3.py
18.81 KB
Del
OK
ldapmod.py
5.9 KB
Del
OK
libcloud_compute.py
23.48 KB
Del
OK
libcloud_dns.py
9.73 KB
Del
OK
libcloud_loadbalancer.py
13.14 KB
Del
OK
libcloud_storage.py
12.16 KB
Del
OK
linux_acl.py
7.7 KB
Del
OK
linux_ip.py
5.55 KB
Del
OK
linux_lvm.py
17.86 KB
Del
OK
linux_service.py
4.64 KB
Del
OK
linux_shadow.py
12.96 KB
Del
OK
linux_sysctl.py
7.5 KB
Del
OK
localemod.py
11.84 KB
Del
OK
locate.py
2.58 KB
Del
OK
logadm.py
9.44 KB
Del
OK
logmod.py
1.25 KB
Del
OK
logrotate.py
7.72 KB
Del
OK
lvs.py
11.54 KB
Del
OK
lxc.py
147.27 KB
Del
OK
lxd.py
90.07 KB
Del
OK
mac_assistive.py
11.37 KB
Del
OK
mac_brew_pkg.py
19.91 KB
Del
OK
mac_desktop.py
2.77 KB
Del
OK
mac_group.py
6.62 KB
Del
OK
mac_keychain.py
6.39 KB
Del
OK
mac_pkgutil.py
2.84 KB
Del
OK
mac_portspkg.py
11.36 KB
Del
OK
mac_power.py
13.29 KB
Del
OK
mac_service.py
19.64 KB
Del
OK
mac_shadow.py
14.23 KB
Del
OK
mac_softwareupdate.py
14.52 KB
Del
OK
mac_sysctl.py
5.13 KB
Del
OK
mac_system.py
15.07 KB
Del
OK
mac_timezone.py
8.34 KB
Del
OK
mac_user.py
16.41 KB
Del
OK
mac_xattr.py
6.27 KB
Del
OK
macdefaults.py
2.33 KB
Del
OK
macpackage.py
6.66 KB
Del
OK
makeconf.py
17.31 KB
Del
OK
mandrill.py
6.31 KB
Del
OK
marathon.py
5.36 KB
Del
OK
match.py
13 KB
Del
OK
mattermost.py
3.4 KB
Del
OK
mdadm_raid.py
9.86 KB
Del
OK
mdata.py
3.38 KB
Del
OK
memcached.py
6.13 KB
Del
OK
mine.py
18.84 KB
Del
OK
minion.py
7.68 KB
Del
OK
mod_random.py
7.18 KB
Del
OK
modjk.py
12.48 KB
Del
OK
mongodb.py
29.75 KB
Del
OK
monit.py
5.51 KB
Del
OK
moosefs.py
3.87 KB
Del
OK
mount.py
58.44 KB
Del
OK
mssql.py
14.64 KB
Del
OK
msteams.py
2.11 KB
Del
OK
munin.py
2.4 KB
Del
OK
mysql.py
90.66 KB
Del
OK
nacl.py
9.72 KB
Del
OK
nagios.py
6.53 KB
Del
OK
nagios_rpc.py
5.09 KB
Del
OK
namecheap_domains.py
12.84 KB
Del
OK
namecheap_domains_dns.py
5.93 KB
Del
OK
namecheap_domains_ns.py
4.51 KB
Del
OK
namecheap_ssl.py
25.69 KB
Del
OK
namecheap_users.py
2.4 KB
Del
OK
napalm_bgp.py
9.72 KB
Del
OK
napalm_formula.py
11.33 KB
Del
OK
napalm_mod.py
61.37 KB
Del
OK
napalm_netacl.py
28.59 KB
Del
OK
napalm_network.py
93.22 KB
Del
OK
napalm_ntp.py
10.22 KB
Del
OK
napalm_probes.py
13.25 KB
Del
OK
napalm_route.py
5.09 KB
Del
OK
napalm_snmp.py
7.05 KB
Del
OK
napalm_users.py
6.49 KB
Del
OK
napalm_yang_mod.py
20.28 KB
Del
OK
netaddress.py
1.6 KB
Del
OK
netbox.py
32.22 KB
Del
OK
netbsd_sysctl.py
3.92 KB
Del
OK
netbsdservice.py
6.43 KB
Del
OK
netmiko_mod.py
19.61 KB
Del
OK
netscaler.py
27.02 KB
Del
OK
network.py
63.42 KB
Del
OK
neutron.py
44.92 KB
Del
OK
neutronng.py
15.02 KB
Del
OK
nexus.py
22.95 KB
Del
OK
nfs3.py
3.9 KB
Del
OK
nftables.py
33.58 KB
Del
OK
nginx.py
3.83 KB
Del
OK
nilrt_ip.py
36.18 KB
Del
OK
nix.py
8.03 KB
Del
OK
nova.py
19.6 KB
Del
OK
npm.py
10.4 KB
Del
OK
nspawn.py
41.35 KB
Del
OK
nxos.py
24.65 KB
Del
OK
nxos_api.py
14.72 KB
Del
OK
nxos_upgrade.py
14.74 KB
Del
OK
omapi.py
3.6 KB
Del
OK
openbsd_sysctl.py
3.74 KB
Del
OK
openbsdpkg.py
10.97 KB
Del
OK
openbsdrcctl_service.py
6.33 KB
Del
OK
openbsdservice.py
8.31 KB
Del
OK
openscap.py
2.81 KB
Del
OK
openstack_config.py
3.21 KB
Del
OK
openstack_mng.py
2.71 KB
Del
OK
openvswitch.py
17.19 KB
Del
OK
opkg.py
49.67 KB
Del
OK
opsgenie.py
3.29 KB
Del
OK
oracle.py
5.82 KB
Del
OK
osquery.py
24.93 KB
Del
OK
out.py
2.53 KB
Del
OK
pacmanpkg.py
31.92 KB
Del
OK
pagerduty.py
4.7 KB
Del
OK
pagerduty_util.py
13.48 KB
Del
OK
pam.py
2.01 KB
Del
OK
panos.py
61.05 KB
Del
OK
parallels.py
19.85 KB
Del
OK
parted_partition.py
21.53 KB
Del
OK
pcs.py
14.11 KB
Del
OK
pdbedit.py
10.79 KB
Del
OK
pecl.py
3.79 KB
Del
OK
peeringdb.py
8.39 KB
Del
OK
pf.py
9.51 KB
Del
OK
philips_hue.py
1.55 KB
Del
OK
pillar.py
21.37 KB
Del
OK
pip.py
53.42 KB
Del
OK
pkg_resource.py
12.3 KB
Del
OK
pkgin.py
17.29 KB
Del
OK
pkgng.py
61.07 KB
Del
OK
pkgutil.py
9.85 KB
Del
OK
portage_config.py
22.73 KB
Del
OK
postfix.py
16.24 KB
Del
OK
postgres.py
88.24 KB
Del
OK
poudriere.py
7.85 KB
Del
OK
powerpath.py
2.57 KB
Del
OK
proxy.py
11.49 KB
Del
OK
ps.py
20.89 KB
Del
OK
publish.py
10.25 KB
Del
OK
puppet.py
10.9 KB
Del
OK
purefa.py
33.59 KB
Del
OK
purefb.py
13.69 KB
Del
OK
pushbullet.py
1.88 KB
Del
OK
pushover_notify.py
3.48 KB
Del
OK
pw_group.py
4.62 KB
Del
OK
pw_user.py
12.47 KB
Del
OK
pyenv.py
6.93 KB
Del
OK
qemu_img.py
1.53 KB
Del
OK
qemu_nbd.py
3.28 KB
Del
OK
quota.py
6.43 KB
Del
OK
rabbitmq.py
38.4 KB
Del
OK
rallydev.py
6.09 KB
Del
OK
random_org.py
23.76 KB
Del
OK
rbac_solaris.py
16.05 KB
Del
OK
rbenv.py
10.75 KB
Del
OK
rdp.py
6.08 KB
Del
OK
rebootmgr.py
7.68 KB
Del
OK
redismod.py
16.36 KB
Del
OK
reg.py
16.36 KB
Del
OK
rest_pkg.py
2.26 KB
Del
OK
rest_sample_utils.py
558 B
Del
OK
rest_service.py
3.63 KB
Del
OK
restartcheck.py
24.1 KB
Del
OK
restconf.py
3.15 KB
Del
OK
ret.py
1.27 KB
Del
OK
rh_ip.py
38.55 KB
Del
OK
rh_service.py
16.61 KB
Del
OK
riak.py
5.19 KB
Del
OK
rpm_lowpkg.py
27.67 KB
Del
OK
rpmbuild_pkgbuild.py
24.53 KB
Del
OK
rsync.py
8.04 KB
Del
OK
runit.py
17.17 KB
Del
OK
rvm.py
11.1 KB
Del
OK
s3.py
9.93 KB
Del
OK
s6.py
3.62 KB
Del
OK
salt_proxy.py
4.48 KB
Del
OK
salt_version.py
4.58 KB
Del
OK
saltcheck.py
46.66 KB
Del
OK
saltcloudmod.py
954 B
Del
OK
saltutil.py
57.49 KB
Del
OK
schedule.py
50.81 KB
Del
OK
scp_mod.py
6.22 KB
Del
OK
scsi.py
2.66 KB
Del
OK
sdb.py
2.48 KB
Del
OK
seed.py
8.87 KB
Del
OK
selinux.py
24.2 KB
Del
OK
sensehat.py
7.79 KB
Del
OK
sensors.py
1.3 KB
Del
OK
serverdensity_device.py
8.1 KB
Del
OK
servicenow.py
4.36 KB
Del
OK
slack_notify.py
7.83 KB
Del
OK
slackware_service.py
6.84 KB
Del
OK
slsutil.py
19.04 KB
Del
OK
smartos_imgadm.py
12.04 KB
Del
OK
smartos_nictagadm.py
6.46 KB
Del
OK
smartos_virt.py
5.21 KB
Del
OK
smartos_vmadm.py
26.2 KB
Del
OK
smbios.py
10.05 KB
Del
OK
smf_service.py
8.52 KB
Del
OK
smtp.py
5.41 KB
Del
OK
snapper.py
27.14 KB
Del
OK
solaris_fmadm.py
11.2 KB
Del
OK
solaris_group.py
2.8 KB
Del
OK
solaris_shadow.py
7.98 KB
Del
OK
solaris_system.py
3.72 KB
Del
OK
solaris_user.py
11.06 KB
Del
OK
solarisipspkg.py
18.68 KB
Del
OK
solarispkg.py
15.4 KB
Del
OK
solr.py
45.54 KB
Del
OK
solrcloud.py
14.63 KB
Del
OK
splunk.py
8.14 KB
Del
OK
splunk_search.py
8.76 KB
Del
OK
sqlite3.py
2.54 KB
Del
OK
ssh.py
43.89 KB
Del
OK
ssh_pkg.py
1.08 KB
Del
OK
ssh_service.py
3.39 KB
Del
OK
state.py
82.34 KB
Del
OK
status.py
57.79 KB
Del
OK
statuspage.py
14.67 KB
Del
OK
supervisord.py
11.15 KB
Del
OK
suse_apache.py
2.45 KB
Del
OK
suse_ip.py
35.72 KB
Del
OK
svn.py
10.75 KB
Del
OK
swarm.py
13.5 KB
Del
OK
swift.py
5.53 KB
Del
OK
sysbench.py
6.62 KB
Del
OK
sysfs.py
6.61 KB
Del
OK
syslog_ng.py
31.52 KB
Del
OK
sysmod.py
22.59 KB
Del
OK
sysrc.py
3.38 KB
Del
OK
system.py
19.28 KB
Del
OK
system_profiler.py
3.54 KB
Del
OK
systemd_service.py
46.29 KB
Del
OK
telegram.py
3.28 KB
Del
OK
telemetry.py
12.87 KB
Del
OK
temp.py
831 B
Del
OK
test.py
15.4 KB
Del
OK
test_virtual.py
237 B
Del
OK
testinframod.py
9.92 KB
Del
OK
textfsm_mod.py
16.22 KB
Del
OK
timezone.py
19.98 KB
Del
OK
tls.py
58.63 KB
Del
OK
tomcat.py
18.59 KB
Del
OK
trafficserver.py
10.44 KB
Del
OK
transactional_update.py
35.83 KB
Del
OK
travisci.py
2.05 KB
Del
OK
tuned.py
2.34 KB
Del
OK
twilio_notify.py
2.95 KB
Del
OK
udev.py
3.72 KB
Del
OK
upstart_service.py
16.92 KB
Del
OK
uptime.py
3.23 KB
Del
OK
useradd.py
22.63 KB
Del
OK
uwsgi.py
996 B
Del
OK
vagrant.py
20.4 KB
Del
OK
varnish.py
3.08 KB
Del
OK
vault.py
15.61 KB
Del
OK
vbox_guest.py
10.55 KB
Del
OK
vboxmanage.py
14.71 KB
Del
OK
vcenter.py
1.61 KB
Del
OK
victorops.py
6.54 KB
Del
OK
virt.py
287.71 KB
Del
OK
virtualenv_mod.py
15.09 KB
Del
OK
vmctl.py
9.56 KB
Del
OK
vsphere.py
380.41 KB
Del
OK
webutil.py
3.66 KB
Del
OK
win_auditpol.py
4.74 KB
Del
OK
win_autoruns.py
2.29 KB
Del
OK
win_certutil.py
4.55 KB
Del
OK
win_dacl.py
32.27 KB
Del
OK
win_disk.py
1.8 KB
Del
OK
win_dism.py
20.7 KB
Del
OK
win_dns_client.py
4.19 KB
Del
OK
win_dsc.py
27.54 KB
Del
OK
win_event.py
22.32 KB
Del
OK
win_file.py
64.39 KB
Del
OK
win_firewall.py
20.15 KB
Del
OK
win_groupadd.py
11.27 KB
Del
OK
win_iis.py
68.78 KB
Del
OK
win_ip.py
11.43 KB
Del
OK
win_lgpo.py
491.76 KB
Del
OK
win_lgpo_reg.py
17.9 KB
Del
OK
win_license.py
2.72 KB
Del
OK
win_network.py
13.9 KB
Del
OK
win_ntp.py
1.8 KB
Del
OK
win_path.py
11.12 KB
Del
OK
win_pkg.py
86.43 KB
Del
OK
win_pki.py
15.8 KB
Del
OK
win_powercfg.py
9.85 KB
Del
OK
win_psget.py
8.97 KB
Del
OK
win_servermanager.py
14.21 KB
Del
OK
win_service.py
32.96 KB
Del
OK
win_shadow.py
3.03 KB
Del
OK
win_shortcut.py
16.49 KB
Del
OK
win_smtp_server.py
17.67 KB
Del
OK
win_snmp.py
13.38 KB
Del
OK
win_status.py
16.94 KB
Del
OK
win_system.py
40.61 KB
Del
OK
win_task.py
79.17 KB
Del
OK
win_timezone.py
13.3 KB
Del
OK
win_useradd.py
27.39 KB
Del
OK
win_wua.py
38.29 KB
Del
OK
win_wusa.py
5.88 KB
Del
OK
winrepo.py
6.09 KB
Del
OK
wordpress.py
4.71 KB
Del
OK
x509.py
63.1 KB
Del
OK
x509_v2.py
74.15 KB
Del
OK
xapi_virt.py
24.07 KB
Del
OK
xbpspkg.py
15.84 KB
Del
OK
xfs.py
15.35 KB
Del
OK
xml.py
2.14 KB
Del
OK
xmpp.py
5.28 KB
Del
OK
yaml.py
1.94 KB
Del
OK
yumpkg.py
116.5 KB
Del
OK
zabbix.py
97.55 KB
Del
OK
zcbuildout.py
28.16 KB
Del
OK
zenoss.py
5.64 KB
Del
OK
zfs.py
34.44 KB
Del
OK
zk_concurrency.py
11.16 KB
Del
OK
znc.py
2.26 KB
Del
OK
zoneadm.py
15.05 KB
Del
OK
zonecfg.py
21.85 KB
Del
OK
zookeeper.py
14.72 KB
Del
OK
zpool.py
44.02 KB
Del
OK
zypperpkg.py
94.87 KB
Del
OK
Edit: network.py
""" Module for gathering and managing network information """ import concurrent.futures import datetime import hashlib import logging import os import random import re import socket import time import salt.utils.decorators.path import salt.utils.functools import salt.utils.network import salt.utils.platform import salt.utils.validate.net from salt._compat import ipaddress from salt.exceptions import CommandExecutionError log = logging.getLogger(__name__) def __virtual__(): """ Only work on POSIX-like systems """ # Disable on Windows, a specific file module exists: if salt.utils.platform.is_windows(): return ( False, "The network execution module cannot be loaded on Windows: use win_network" " instead.", ) return True def wol(mac, bcast="255.255.255.255", destport=9): """ Send Wake On Lan packet to a host CLI Example: .. code-block:: bash salt '*' network.wol 08-00-27-13-69-77 salt '*' network.wol 080027136977 255.255.255.255 7 salt '*' network.wol 08:00:27:13:69:77 255.255.255.255 7 """ dest = __utils__["network.mac_str_to_bytes"](mac) sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) sock.sendto(b"\xff" * 6 + dest * 16, (bcast, int(destport))) return True def ping(host, timeout=False, return_boolean=False): """ Performs an ICMP ping to a host .. versionchanged:: 2015.8.0 Added support for SunOS CLI Example: .. code-block:: bash salt '*' network.ping archlinux.org .. versionadded:: 2015.5.0 Return a True or False instead of ping output. .. code-block:: bash salt '*' network.ping archlinux.org return_boolean=True Set the time to wait for a response in seconds. .. code-block:: bash salt '*' network.ping archlinux.org timeout=3 """ if timeout: if __grains__["kernel"] == "SunOS": cmd = "ping -c 4 {} {}".format( __utils__["network.sanitize_host"](host), timeout ) else: cmd = "ping -W {} -c 4 {}".format( timeout, __utils__["network.sanitize_host"](host) ) else: cmd = "ping -c 4 {}".format(__utils__["network.sanitize_host"](host)) if return_boolean: ret = __salt__["cmd.run_all"](cmd) if ret["retcode"] != 0: return False else: return True else: return __salt__["cmd.run"](cmd) # FIXME: Does not work with: netstat 1.42 (2001-04-15) from net-tools # 1.6.0 (Ubuntu 10.10) def _netstat_linux(): """ Return netstat information for Linux distros """ ret = [] cmd = "netstat -tulpnea" out = __salt__["cmd.run"](cmd) for line in out.splitlines(): comps = line.split() if line.startswith("tcp"): ret.append( { "proto": comps[0], "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], "state": comps[5], "user": comps[6], "inode": comps[7], "program": comps[8], } ) if line.startswith("udp"): ret.append( { "proto": comps[0], "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], "user": comps[5], "inode": comps[6], "program": comps[7], } ) return ret def _ss_linux(): """ Return ss information for Linux distros (netstat is deprecated and may not be available) """ ret = [] cmd = "ss -tulpnea" out = __salt__["cmd.run"](cmd) for line in out.splitlines(): comps = line.split() ss_user = 0 ss_inode = 0 ss_program = "" length = len(comps) if line.startswith("tcp") or line.startswith("udp"): i = 6 while i < (length - 1): fields = comps[i].split(":") if fields[0] == "users": users = fields[1].split(",") ss_program = users[0].split('"')[1] if fields[0] == "uid": ss_user = fields[1] if fields[0] == "ino": ss_inode = fields[1] i += 1 if line.startswith("tcp"): ss_state = comps[1] if ss_state == "ESTAB": ss_state = "ESTABLISHED" ret.append( { "proto": comps[0], "recv-q": comps[2], "send-q": comps[3], "local-address": comps[4], "remote-address": comps[5], "state": ss_state, "user": ss_user, "inode": ss_inode, "program": ss_program, } ) if line.startswith("udp"): ret.append( { "proto": comps[0], "recv-q": comps[2], "send-q": comps[3], "local-address": comps[4], "remote-address": comps[5], "user": ss_user, "inode": ss_inode, "program": ss_program, } ) return ret def _netinfo_openbsd(): """ Get process information for network connections using fstat """ ret = {} _fstat_re = re.compile( r"internet(6)? (?:stream tcp 0x\S+ (\S+)|dgram udp (\S+))" r"(?: [<>=-]+ (\S+))?$" ) out = __salt__["cmd.run"]("fstat") for line in out.splitlines(): try: user, cmd, pid, _, details = line.split(None, 4) ipv6, tcp, udp, remote_addr = _fstat_re.match(details).groups() except (ValueError, AttributeError): # Line either doesn't have the right number of columns, or the # regex which looks for address information did not match. Either # way, ignore this line and continue on to the next one. continue if tcp: local_addr = tcp proto = "tcp{}".format("" if ipv6 is None else ipv6) else: local_addr = udp proto = "udp{}".format("" if ipv6 is None else ipv6) if ipv6: # IPv6 addresses have the address part enclosed in brackets (if the # address part is not a wildcard) to distinguish the address from # the port number. Remove them. local_addr = "".join(x for x in local_addr if x not in "[]") # Normalize to match netstat output local_addr = ".".join(local_addr.rsplit(":", 1)) if remote_addr is None: remote_addr = "*.*" else: remote_addr = ".".join(remote_addr.rsplit(":", 1)) ret.setdefault(local_addr, {}).setdefault(remote_addr, {}).setdefault( proto, {} ).setdefault(pid, {})["user"] = user ret[local_addr][remote_addr][proto][pid]["cmd"] = cmd return ret def _netinfo_freebsd_netbsd(): """ Get process information for network connections using sockstat """ ret = {} # NetBSD requires '-n' to disable port-to-service resolution out = __salt__["cmd.run"]( "sockstat -46 {} | tail -n+2".format( "-n" if __grains__["kernel"] == "NetBSD" else "" ), python_shell=True, ) for line in out.splitlines(): user, cmd, pid, _, proto, local_addr, remote_addr = line.split() local_addr = ".".join(local_addr.rsplit(":", 1)) remote_addr = ".".join(remote_addr.rsplit(":", 1)) ret.setdefault(local_addr, {}).setdefault(remote_addr, {}).setdefault( proto, {} ).setdefault(pid, {})["user"] = user ret[local_addr][remote_addr][proto][pid]["cmd"] = cmd return ret def _ppid(): """ Return a dict of pid to ppid mappings """ ret = {} if __grains__["kernel"] == "SunOS": cmd = "ps -a -o pid,ppid | tail +2" else: cmd = "ps -ax -o pid,ppid | tail -n+2" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): pid, ppid = line.split() ret[pid] = ppid return ret def _netstat_bsd(): """ Return netstat information for BSD flavors """ ret = [] if __grains__["kernel"] == "NetBSD": for addr_family in ("inet", "inet6"): cmd = "netstat -f {} -an | tail -n+3".format(addr_family) out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() entry = { "proto": comps[0], "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], } if entry["proto"].startswith("tcp"): entry["state"] = comps[5] ret.append(entry) else: # Lookup TCP connections cmd = "netstat -p tcp -an | tail -n+3" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "proto": comps[0], "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], "state": comps[5], } ) # Lookup UDP connections cmd = "netstat -p udp -an | tail -n+3" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "proto": comps[0], "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], } ) # Add in user and program info ppid = _ppid() if __grains__["kernel"] == "OpenBSD": netinfo = _netinfo_openbsd() elif __grains__["kernel"] in ("FreeBSD", "NetBSD"): netinfo = _netinfo_freebsd_netbsd() for idx, _ in enumerate(ret): local = ret[idx]["local-address"] remote = ret[idx]["remote-address"] proto = ret[idx]["proto"] try: # Make a pointer to the info for this connection for easier # reference below ptr = netinfo[local][remote][proto] except KeyError: continue # Get the pid-to-ppid mappings for this connection conn_ppid = {x: y for x, y in ppid.items() if x in ptr} try: # Master pid for this connection will be the pid whose ppid isn't # in the subset dict we created above master_pid = next(iter(x for x, y in conn_ppid.items() if y not in ptr)) except StopIteration: continue ret[idx]["user"] = ptr[master_pid]["user"] ret[idx]["program"] = "/".join((master_pid, ptr[master_pid]["cmd"])) return ret def _netstat_sunos(): """ Return netstat information for SunOS flavors """ log.warning("User and program not (yet) supported on SunOS") ret = [] for addr_family in ("inet", "inet6"): # Lookup TCP connections cmd = "netstat -f {} -P tcp -an | tail +5".format(addr_family) out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "proto": "tcp6" if addr_family == "inet6" else "tcp", "recv-q": comps[5], "send-q": comps[4], "local-address": comps[0], "remote-address": comps[1], "state": comps[6], } ) # Lookup UDP connections cmd = "netstat -f {} -P udp -an | tail +5".format(addr_family) out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "proto": "udp6" if addr_family == "inet6" else "udp", "local-address": comps[0], "remote-address": comps[1] if len(comps) > 2 else "", } ) return ret def _netstat_aix(): """ Return netstat information for SunOS flavors """ ret = [] ## AIX 6.1 - 7.2, appears to ignore addr_family field contents ## for addr_family in ('inet', 'inet6'): for addr_family in ("inet",): # Lookup connections cmd = "netstat -n -a -f {} | tail -n +3".format(addr_family) out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() if len(comps) < 5: continue proto_seen = None tcp_flag = True if "tcp" == comps[0] or "tcp4" == comps[0]: proto_seen = "tcp" elif "tcp6" == comps[0]: proto_seen = "tcp6" elif "udp" == comps[0] or "udp4" == comps[0]: proto_seen = "udp" tcp_flag = False elif "udp6" == comps[0]: proto_seen = "udp6" tcp_flag = False if tcp_flag: if len(comps) >= 6: ret.append( { "proto": proto_seen, "recv-q": comps[1], "send-q": comps[2], "local-address": comps[3], "remote-address": comps[4], "state": comps[5], } ) else: if len(comps) >= 5: ret.append( { "proto": proto_seen, "local-address": comps[3], "remote-address": comps[4], } ) return ret def _netstat_route_linux(): """ Return netstat routing information for Linux distros """ ret = [] cmd = "netstat -A inet -rn | tail -n+3" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": comps[2], "flags": comps[3], "interface": comps[7], } ) cmd = "netstat -A inet6 -rn | tail -n+3" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() if len(comps) == 6: ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[5], } ) elif len(comps) == 7: ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[6], } ) else: continue return ret def _ip_route_linux(): """ Return ip routing information for Linux distros (netstat is deprecated and may not be available) """ # table main closest to old netstat inet output ret = [] cmd = "ip -4 route show table main" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() # need to fake similar output to that provided by netstat # to maintain output format if comps[0] == "unreachable": continue if comps[0] == "default": ip_interface = "" if comps[3] == "dev": ip_interface = comps[4] ret.append( { "addr_family": "inet", "destination": "0.0.0.0", "gateway": comps[2], "netmask": "0.0.0.0", "flags": "UG", "interface": ip_interface, } ) else: address_mask = convert_cidr(comps[0]) ip_interface = "" if comps[1] == "dev": ip_interface = comps[2] ret.append( { "addr_family": "inet", "destination": address_mask["network"], "gateway": "0.0.0.0", "netmask": address_mask["netmask"], "flags": "U", "interface": ip_interface, } ) # table all closest to old netstat inet6 output cmd = "ip -6 route show table all" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() # need to fake similar output to that provided by netstat # to maintain output format if comps[0] in ( "unicast", "broadcast", "throw", "unreachable", "prohibit", "blackhole", "nat", "anycast", "multicast", ): continue if comps[0] == "default": ip_interface = "" if comps[3] == "dev": ip_interface = comps[4] ret.append( { "addr_family": "inet6", "destination": "::/0", "gateway": comps[2], "netmask": "", "flags": "UG", "interface": ip_interface, } ) elif comps[0] == "local": ip_interface = "" if comps[2] == "dev": ip_interface = comps[3] local_address = comps[1] + "/128" ret.append( { "addr_family": "inet6", "destination": local_address, "gateway": "::", "netmask": "", "flags": "U", "interface": ip_interface, } ) else: address_mask = convert_cidr(comps[0]) ip_interface = "" if comps[1] == "dev": ip_interface = comps[2] ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": "::", "netmask": "", "flags": "U", "interface": ip_interface, } ) return ret def _netstat_route_freebsd(): """ Return netstat routing information for FreeBSD and macOS """ ret = [] cmd = "netstat -f inet -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() if ( __grains__["os"] == "FreeBSD" and int(__grains__.get("osmajorrelease", 0)) < 10 ): ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": comps[2], "flags": comps[3], "interface": comps[5], } ) else: ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[3], } ) cmd = "netstat -f inet6 -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[3], } ) return ret def _netstat_route_netbsd(): """ Return netstat routing information for NetBSD """ ret = [] cmd = "netstat -f inet -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[3], "interface": comps[6], } ) cmd = "netstat -f inet6 -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[3], "interface": comps[6], } ) return ret def _netstat_route_openbsd(): """ Return netstat routing information for OpenBSD """ ret = [] cmd = "netstat -f inet -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[7], } ) cmd = "netstat -f inet6 -rn | tail -n+5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[7], } ) return ret def _netstat_route_sunos(): """ Return netstat routing information for SunOS """ ret = [] cmd = "netstat -f inet -rn | tail +5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[5] if len(comps) >= 6 else "", } ) cmd = "netstat -f inet6 -rn | tail +5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[5] if len(comps) >= 6 else "", } ) return ret def _netstat_route_aix(): """ Return netstat routing information for AIX """ ret = [] cmd = "netstat -f inet -rn | tail -n +5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[5] if len(comps) >= 6 else "", } ) cmd = "netstat -f inet6 -rn | tail -n +5" out = __salt__["cmd.run"](cmd, python_shell=True) for line in out.splitlines(): comps = line.split() ret.append( { "addr_family": "inet6", "destination": comps[0], "gateway": comps[1], "netmask": "", "flags": comps[2], "interface": comps[5] if len(comps) >= 6 else "", } ) return ret def netstat(): """ Return information on open ports and states .. note:: On BSD minions, the output contains PID info (where available) for each netstat entry, fetched from sockstat/fstat output. .. versionchanged:: 2014.1.4 Added support for OpenBSD, FreeBSD, and NetBSD .. versionchanged:: 2015.8.0 Added support for SunOS .. versionchanged:: 2016.11.4 Added support for AIX CLI Example: .. code-block:: bash salt '*' network.netstat """ if __grains__["kernel"] == "Linux": if not __utils__["path.which"]("netstat"): return _ss_linux() else: return _netstat_linux() elif __grains__["kernel"] in ("OpenBSD", "FreeBSD", "NetBSD"): return _netstat_bsd() elif __grains__["kernel"] == "SunOS": return _netstat_sunos() elif __grains__["kernel"] == "AIX": return _netstat_aix() raise CommandExecutionError("Not yet supported on this platform") def active_tcp(): """ Return a dict containing information on all of the running TCP connections (currently linux and solaris only) .. versionchanged:: 2015.8.4 Added support for SunOS CLI Example: .. code-block:: bash salt '*' network.active_tcp """ if __grains__["kernel"] == "Linux": return __utils__["network.active_tcp"]() elif __grains__["kernel"] == "SunOS": # lets use netstat to mimic linux as close as possible ret = {} for connection in _netstat_sunos(): if not connection["proto"].startswith("tcp"): continue if connection["state"] != "ESTABLISHED": continue ret[len(ret) + 1] = { "local_addr": ".".join(connection["local-address"].split(".")[:-1]), "local_port": ".".join(connection["local-address"].split(".")[-1:]), "remote_addr": ".".join(connection["remote-address"].split(".")[:-1]), "remote_port": ".".join(connection["remote-address"].split(".")[-1:]), } return ret elif __grains__["kernel"] == "AIX": # lets use netstat to mimic linux as close as possible ret = {} for connection in _netstat_aix(): if not connection["proto"].startswith("tcp"): continue if connection["state"] != "ESTABLISHED": continue ret[len(ret) + 1] = { "local_addr": ".".join(connection["local-address"].split(".")[:-1]), "local_port": ".".join(connection["local-address"].split(".")[-1:]), "remote_addr": ".".join(connection["remote-address"].split(".")[:-1]), "remote_port": ".".join(connection["remote-address"].split(".")[-1:]), } return ret else: return {} @salt.utils.decorators.path.which("traceroute") def traceroute(host): """ Performs a traceroute to a 3rd party host .. versionchanged:: 2015.8.0 Added support for SunOS .. versionchanged:: 2016.11.4 Added support for AIX CLI Example: .. code-block:: bash salt '*' network.traceroute archlinux.org """ ret = [] cmd = "traceroute {}".format(__utils__["network.sanitize_host"](host)) out = __salt__["cmd.run"](cmd) # Parse version of traceroute if __utils__["platform.is_sunos"]() or __utils__["platform.is_aix"](): traceroute_version = [0, 0, 0] else: version_out = __salt__["cmd.run"]("traceroute --version") try: # Linux traceroute version looks like: # Modern traceroute for Linux, version 2.0.19, Dec 10 2012 # Darwin and FreeBSD traceroute version looks like: Version 1.4a12+[FreeBSD|Darwin] version_raw = re.findall( r".*[Vv]ersion (\d+)\.([\w\+]+)\.*(\w*)", version_out )[0] log.debug("traceroute_version_raw: %s", version_raw) traceroute_version = [] for t in version_raw: try: traceroute_version.append(int(t)) except ValueError: traceroute_version.append(t) if len(traceroute_version) < 3: traceroute_version.append(0) log.debug("traceroute_version: %s", traceroute_version) except IndexError: traceroute_version = [0, 0, 0] for line in out.splitlines(): # Pre requirements for line parsing skip_line = False if " " not in line: skip_line = True if line.startswith("traceroute"): skip_line = True if __utils__["platform.is_aix"](): if line.startswith("trying to get source for"): skip_line = True if line.startswith("source should be"): skip_line = True if line.startswith("outgoing MTU"): skip_line = True if line.startswith("fragmentation required"): skip_line = True if skip_line: log.debug("Skipping traceroute output line: %s", line) continue # Parse output from unix variants if ( "Darwin" in str(traceroute_version[1]) or "FreeBSD" in str(traceroute_version[1]) or __grains__["kernel"] in ("SunOS", "AIX") ): try: traceline = re.findall(r"\s*(\d*)\s+(.*)\s+\((.*)\)\s+(.*)$", line)[0] except IndexError: traceline = re.findall(r"\s*(\d*)\s+(\*\s+\*\s+\*)", line)[0] log.debug("traceline: %s", traceline) delays = re.findall(r"(\d+\.\d+)\s*ms", str(traceline)) try: if traceline[1] == "* * *": result = {"count": traceline[0], "hostname": "*"} else: result = { "count": traceline[0], "hostname": traceline[1], "ip": traceline[2], } for idx, delay in enumerate(delays): result["ms{}".format(idx + 1)] = delay except IndexError: result = {} # Parse output from specific version ranges elif ( traceroute_version[0] >= 2 and traceroute_version[2] >= 14 or traceroute_version[0] >= 2 and traceroute_version[1] > 0 ): comps = line.split(" ") if len(comps) >= 2 and comps[1] == "* * *": result = {"count": int(comps[0]), "hostname": "*"} elif len(comps) >= 5: result = { "count": int(comps[0]), "hostname": comps[1].split()[0], "ip": comps[1].split()[1].strip("()"), "ms1": float(comps[2].split()[0]), "ms2": float(comps[3].split()[0]), "ms3": float(comps[4].split()[0]), } else: result = {} # Parse anything else else: comps = line.split() if len(comps) >= 8: result = { "count": comps[0], "hostname": comps[1], "ip": comps[2], "ms1": comps[4], "ms2": comps[6], "ms3": comps[8], "ping1": comps[3], "ping2": comps[5], "ping3": comps[7], } else: result = {} ret.append(result) if not result: log.warning("Cannot parse traceroute output line: %s", line) return ret @salt.utils.decorators.path.which("dig") def dig(host): """ Performs a DNS lookup with dig CLI Example: .. code-block:: bash salt '*' network.dig archlinux.org """ cmd = "dig {}".format(__utils__["network.sanitize_host"](host)) return __salt__["cmd.run"](cmd) @salt.utils.decorators.path.which("arp") def arp(): """ Return the arp table from the minion .. versionchanged:: 2015.8.0 Added support for SunOS CLI Example: .. code-block:: bash salt '*' network.arp """ ret = {} out = __salt__["cmd.run"]("arp -an") for line in out.splitlines(): comps = line.split() if len(comps) < 4: continue if __grains__["kernel"] == "SunOS": if ":" not in comps[-1]: continue ret[comps[-1]] = comps[1] elif __grains__["kernel"] == "OpenBSD": if comps[0] == "Host" or comps[1] == "(incomplete)": continue ret[comps[1]] = comps[0] elif __grains__["kernel"] == "AIX": if comps[0] in ("bucket", "There"): continue ret[comps[3]] = comps[1].strip("(").strip(")") else: ret[comps[3]] = comps[1].strip("(").strip(")") return ret def interfaces(): """ Return a dictionary of information about all the interfaces on the minion CLI Example: .. code-block:: bash salt '*' network.interfaces """ return __utils__["network.interfaces"]() def hw_addr(iface): """ Return the hardware address (a.k.a. MAC address) for a given interface CLI Example: .. code-block:: bash salt '*' network.hw_addr eth0 """ return __utils__["network.hw_addr"](iface) # Alias hwaddr to preserve backward compat hwaddr = salt.utils.functools.alias_function(hw_addr, "hwaddr") def interface(iface): """ Return the inet address for a given interface .. versionadded:: 2014.7.0 CLI Example: .. code-block:: bash salt '*' network.interface eth0 """ return __utils__["network.interface"](iface) def interface_ip(iface): """ Return the inet address for a given interface .. versionadded:: 2014.7.0 CLI Example: .. code-block:: bash salt '*' network.interface_ip eth0 """ return __utils__["network.interface_ip"](iface) def subnets(interfaces=None): """ Returns a list of IPv4 subnets to which the host belongs CLI Example: .. code-block:: bash salt '*' network.subnets salt '*' network.subnets interfaces=eth1 """ return __utils__["network.subnets"](interfaces) def subnets6(): """ Returns a list of IPv6 subnets to which the host belongs CLI Example: .. code-block:: bash salt '*' network.subnets """ return __utils__["network.subnets6"]() def in_subnet(cidr): """ Returns True if host is within specified subnet, otherwise False. CLI Example: .. code-block:: bash salt '*' network.in_subnet 10.0.0.0/16 """ return __utils__["network.in_subnet"](cidr) def ip_in_subnet(ip_addr, cidr): """ Returns True if given IP is within specified subnet, otherwise False. CLI Example: .. code-block:: bash salt '*' network.ip_in_subnet 172.17.0.4 172.16.0.0/12 """ return __utils__["network.in_subnet"](cidr, ip_addr) def convert_cidr(cidr): """ returns the network address, subnet mask and broadcast address of a cidr address .. versionadded:: 2016.3.0 CLI Example: .. code-block:: bash salt '*' network.convert_cidr 172.31.0.0/16 """ ret = {"network": None, "netmask": None, "broadcast": None} cidr = calc_net(cidr) network_info = ipaddress.ip_network(cidr) ret["network"] = str(network_info.network_address) ret["netmask"] = str(network_info.netmask) ret["broadcast"] = str(network_info.broadcast_address) return ret def calc_net(ip_addr, netmask=None): """ Returns the CIDR of a subnet based on an IP address (CIDR notation supported) and optional netmask. CLI Example: .. code-block:: bash salt '*' network.calc_net 172.17.0.5 255.255.255.240 salt '*' network.calc_net 2a02:f6e:a000:80:84d8:8332:7866:4e07/64 .. versionadded:: 2015.8.0 """ return __utils__["network.calc_net"](ip_addr, netmask) def ip_addrs(interface=None, include_loopback=False, cidr=None, type=None): """ Returns a list of IPv4 addresses assigned to the host. 127.0.0.1 is ignored, unless 'include_loopback=True' is indicated. If 'interface' is provided, then only IP addresses from that interface will be returned. Providing a CIDR via 'cidr="10.0.0.0/8"' will return only the addresses which are within that subnet. If 'type' is 'public', then only public addresses will be returned. Ditto for 'type'='private'. .. versionchanged:: 3001 ``interface`` can now be a single interface name or a list of interfaces. Globbing is also supported. CLI Example: .. code-block:: bash salt '*' network.ip_addrs """ addrs = __utils__["network.ip_addrs"]( interface=interface, include_loopback=include_loopback ) if cidr: return [i for i in addrs if __utils__["network.in_subnet"](cidr, [i])] else: if type == "public": return [i for i in addrs if not is_private(i)] elif type == "private": return [i for i in addrs if is_private(i)] else: return addrs ipaddrs = salt.utils.functools.alias_function(ip_addrs, "ipaddrs") def ip_addrs6(interface=None, include_loopback=False, cidr=None): """ Returns a list of IPv6 addresses assigned to the host. ::1 is ignored, unless 'include_loopback=True' is indicated. If 'interface' is provided, then only IP addresses from that interface will be returned. Providing a CIDR via 'cidr="2000::/3"' will return only the addresses which are within that subnet. .. versionchanged:: 3001 ``interface`` can now be a single interface name or a list of interfaces. Globbing is also supported. CLI Example: .. code-block:: bash salt '*' network.ip_addrs6 """ addrs = __utils__["network.ip_addrs6"]( interface=interface, include_loopback=include_loopback ) if cidr: return [i for i in addrs if __utils__["network.in_subnet"](cidr, [i])] else: return addrs ipaddrs6 = salt.utils.functools.alias_function(ip_addrs6, "ipaddrs6") def get_hostname(): """ Get hostname CLI Example: .. code-block:: bash salt '*' network.get_hostname """ return socket.gethostname() def get_fqdn(): """ Get fully qualified domain name CLI Example: .. code-block:: bash salt '*' network.get_fqdn """ return socket.getfqdn() def mod_hostname(hostname): """ Modify hostname .. versionchanged:: 2015.8.0 Added support for SunOS (Solaris 10, Illumos, SmartOS) CLI Example: .. code-block:: bash salt '*' network.mod_hostname master.saltstack.com """ # # SunOS tested on SmartOS and OmniOS (Solaris 10 compatible) # Oracle Solaris 11 uses smf, currently not supported # # /etc/nodename is the hostname only, not fqdn # /etc/defaultdomain is the domain # /etc/hosts should have both fqdn and hostname entries # if hostname is None: return False hostname_cmd = __utils__["path.which"]("hostnamectl") or __utils__["path.which"]( "hostname" ) if __utils__["platform.is_sunos"](): uname_cmd = ( "/usr/bin/uname" if __utils__["platform.is_smartos"]() else __utils__["path.which"]("uname") ) check_hostname_cmd = __utils__["path.which"]("check-hostname") # Grab the old hostname so we know which hostname to change and then # change the hostname using the hostname command if hostname_cmd.endswith("hostnamectl"): result = __salt__["cmd.run_all"]("{} status".format(hostname_cmd)) if 0 == result["retcode"]: out = result["stdout"] for line in out.splitlines(): line = line.split(":") if "Static hostname" in line[0]: o_hostname = line[1].strip() else: log.debug("%s was unable to get hostname", hostname_cmd) o_hostname = __salt__["network.get_hostname"]() elif not __utils__["platform.is_sunos"](): # don't run hostname -f because -f is not supported on all platforms o_hostname = socket.getfqdn() else: # output: Hostname core OK: fully qualified as core.acheron.be o_hostname = __salt__["cmd.run"](check_hostname_cmd).split(" ")[-1] if hostname_cmd.endswith("hostnamectl"): result = __salt__["cmd.run_all"]( "{} set-hostname {}".format( hostname_cmd, hostname, ) ) if result["retcode"] != 0: log.debug( "%s was unable to set hostname. Error: %s", hostname_cmd, result["stderr"], ) return False elif not __utils__["platform.is_sunos"](): __salt__["cmd.run"]("{} {}".format(hostname_cmd, hostname)) else: __salt__["cmd.run"]("{} -S {}".format(uname_cmd, hostname.split(".")[0])) # Modify the /etc/hosts file to replace the old hostname with the # new hostname with __utils__["files.fopen"]("/etc/hosts", "r") as fp_: host_c = [__utils__["stringutils.to_unicode"](_l) for _l in fp_.readlines()] with __utils__["files.fopen"]("/etc/hosts", "w") as fh_: for host in host_c: host = host.split() try: host[host.index(o_hostname)] = hostname if __utils__["platform.is_sunos"](): # also set a copy of the hostname host[host.index(o_hostname.split(".")[0])] = hostname.split(".")[0] except ValueError: pass fh_.write(__utils__["stringutils.to_str"]("\t".join(host) + "\n")) # Modify the /etc/sysconfig/network configuration file to set the # new hostname if __grains__["os_family"] == "RedHat": with __utils__["files.fopen"]("/etc/sysconfig/network", "r") as fp_: network_c = [ __utils__["stringutils.to_unicode"](_l) for _l in fp_.readlines() ] with __utils__["files.fopen"]("/etc/sysconfig/network", "w") as fh_: for net in network_c: if net.startswith("HOSTNAME"): old_hostname = net.split("=", 1)[1].rstrip() quote_type = __utils__["stringutils.is_quoted"](old_hostname) fh_.write( __utils__["stringutils.to_str"]( "HOSTNAME={1}{0}{1}\n".format( __utils__["stringutils.dequote"](hostname), quote_type ) ) ) else: fh_.write(__utils__["stringutils.to_str"](net)) elif __grains__["os_family"] in ("Debian", "NILinuxRT"): with __utils__["files.fopen"]("/etc/hostname", "w") as fh_: fh_.write(__utils__["stringutils.to_str"](hostname + "\n")) if __grains__["lsb_distrib_id"] == "nilrt": str_hostname = __utils__["stringutils.to_str"](hostname) nirtcfg_cmd = "/usr/local/natinst/bin/nirtcfg" nirtcfg_cmd += ( " --set section=SystemSettings,token='Host_Name',value='{}'".format( str_hostname ) ) if __salt__["cmd.run_all"](nirtcfg_cmd)["retcode"] != 0: raise CommandExecutionError( "Couldn't set hostname to: {}\n".format(str_hostname) ) elif __grains__["os_family"] == "OpenBSD": with __utils__["files.fopen"]("/etc/myname", "w") as fh_: fh_.write(__utils__["stringutils.to_str"](hostname + "\n")) # Update /etc/nodename and /etc/defaultdomain on SunOS if __utils__["platform.is_sunos"](): with __utils__["files.fopen"]("/etc/nodename", "w") as fh_: fh_.write(__utils__["stringutils.to_str"](hostname.split(".")[0] + "\n")) with __utils__["files.fopen"]("/etc/defaultdomain", "w") as fh_: fh_.write( __utils__["stringutils.to_str"]( ".".join(hostname.split(".")[1:]) + "\n" ) ) return True def connect(host, port=None, **kwargs): """ Test connectivity to a host using a particular port from the minion. .. versionadded:: 2014.7.0 CLI Example: .. code-block:: bash salt '*' network.connect archlinux.org 80 salt '*' network.connect archlinux.org 80 timeout=3 salt '*' network.connect archlinux.org 80 timeout=3 family=ipv4 salt '*' network.connect google-public-dns-a.google.com port=53 proto=udp timeout=3 """ ret = {"result": None, "comment": ""} if not host: ret["result"] = False ret["comment"] = "Required argument, host, is missing." return ret if not port: ret["result"] = False ret["comment"] = "Required argument, port, is missing." return ret proto = kwargs.get("proto", "tcp") timeout = kwargs.get("timeout", 5) family = kwargs.get("family", None) if salt.utils.validate.net.ipv4_addr(host) or salt.utils.validate.net.ipv6_addr( host ): address = host else: address = "{}".format(__utils__["network.sanitize_host"](host)) try: if proto == "udp": __proto = socket.SOL_UDP else: __proto = socket.SOL_TCP proto = "tcp" if family: if family == "ipv4": __family = socket.AF_INET elif family == "ipv6": __family = socket.AF_INET6 else: __family = 0 else: __family = 0 (family, socktype, _proto, garbage, _address) = socket.getaddrinfo( address, port, __family, 0, __proto )[0] except socket.gaierror: ret["result"] = False ret["comment"] = "Unable to resolve host {} on {} port {}".format( host, proto, port ) return ret try: skt = socket.socket(family, socktype, _proto) skt.settimeout(timeout) if proto == "udp": # Generate a random string of a # decent size to test UDP connection md5h = hashlib.md5() md5h.update(datetime.datetime.now().strftime("%s")) msg = md5h.hexdigest() skt.sendto(msg, _address) recv, svr = skt.recvfrom(255) skt.close() else: skt.connect(_address) skt.shutdown(2) except Exception as exc: # pylint: disable=broad-except ret["result"] = False ret["comment"] = "Unable to connect to {} ({}) on {} port {}".format( host, _address[0], proto, port ) return ret ret["result"] = True ret["comment"] = "Successfully connected to {} ({}) on {} port {}".format( host, _address[0], proto, port ) return ret def is_private(ip_addr): """ Check if the given IP address is a private address .. versionadded:: 2014.7.0 .. versionchanged:: 2015.8.0 IPv6 support CLI Example: .. code-block:: bash salt '*' network.is_private 10.0.0.3 """ return ipaddress.ip_address(ip_addr).is_private def is_loopback(ip_addr): """ Check if the given IP address is a loopback address .. versionadded:: 2014.7.0 .. versionchanged:: 2015.8.0 IPv6 support CLI Example: .. code-block:: bash salt '*' network.is_loopback 127.0.0.1 """ return ipaddress.ip_address(ip_addr).is_loopback def reverse_ip(ip_addr): """ Returns the reversed IP address .. versionchanged:: 2015.8.0 IPv6 support CLI Example: .. code-block:: bash salt '*' network.reverse_ip 172.17.0.4 """ return ipaddress.ip_address(ip_addr).reverse_pointer def _get_bufsize_linux(iface): """ Return network interface buffer information using ethtool """ ret = {"result": False} cmd = "/sbin/ethtool -g {}".format(iface) out = __salt__["cmd.run"](cmd) pat = re.compile(r"^(.+):\s+(\d+)$") suffix = "max-" for line in out.splitlines(): res = pat.match(line) if res: ret[res.group(1).lower().replace(" ", "-") + suffix] = int(res.group(2)) ret["result"] = True elif line.endswith("maximums:"): suffix = "-max" elif line.endswith("settings:"): suffix = "" if not ret["result"]: parts = out.split() # remove shell cmd prefix from msg if parts[0].endswith("sh:"): out = " ".join(parts[1:]) ret["comment"] = out return ret def get_bufsize(iface): """ Return network buffer sizes as a dict (currently linux only) CLI Example: .. code-block:: bash salt '*' network.get_bufsize eth0 """ if __grains__["kernel"] == "Linux": if os.path.exists("/sbin/ethtool"): return _get_bufsize_linux(iface) return {} def _mod_bufsize_linux(iface, *args, **kwargs): """ Modify network interface buffer sizes using ethtool """ ret = { "result": False, "comment": "Requires rx=<val> tx==<val> rx-mini=<val> and/or rx-jumbo=<val>", } cmd = "/sbin/ethtool -G " + iface if not kwargs: return ret if args: ret["comment"] = "Unknown arguments: " + " ".join([str(item) for item in args]) return ret eargs = "" for kw in ["rx", "tx", "rx-mini", "rx-jumbo"]: value = kwargs.get(kw) if value is not None: eargs += " " + kw + " " + str(value) if not eargs: return ret cmd += eargs out = __salt__["cmd.run"](cmd) if out: ret["comment"] = out else: ret["comment"] = eargs.strip() ret["result"] = True return ret def mod_bufsize(iface, *args, **kwargs): """ Modify network interface buffers (currently linux only) CLI Example: .. code-block:: bash salt '*' network.mod_bufsize tx=<val> rx=<val> rx-mini=<val> rx-jumbo=<val> """ if __grains__["kernel"] == "Linux": if os.path.exists("/sbin/ethtool"): return _mod_bufsize_linux(iface, *args, **kwargs) return False def routes(family=None): """ Return currently configured routes from routing table .. versionchanged:: 2015.8.0 Added support for SunOS (Solaris 10, Illumos, SmartOS) .. versionchanged:: 2016.11.4 Added support for AIX CLI Example: .. code-block:: bash salt '*' network.routes """ if family != "inet" and family != "inet6" and family is not None: raise CommandExecutionError("Invalid address family {}".format(family)) if __grains__["kernel"] == "Linux": if not __utils__["path.which"]("netstat"): routes_ = _ip_route_linux() else: routes_ = _netstat_route_linux() elif __grains__["kernel"] == "SunOS": routes_ = _netstat_route_sunos() elif __grains__["os"] in ["FreeBSD", "MacOS", "Darwin"]: routes_ = _netstat_route_freebsd() elif __grains__["os"] in ["NetBSD"]: routes_ = _netstat_route_netbsd() elif __grains__["os"] in ["OpenBSD"]: routes_ = _netstat_route_openbsd() elif __grains__["os"] in ["AIX"]: routes_ = _netstat_route_aix() else: raise CommandExecutionError("Not yet supported on this platform") if not family: return routes_ else: ret = [route for route in routes_ if route["addr_family"] == family] return ret def default_route(family=None): """ Return default route(s) from routing table .. versionchanged:: 2015.8.0 Added support for SunOS (Solaris 10, Illumos, SmartOS) .. versionchanged:: 2016.11.4 Added support for AIX CLI Example: .. code-block:: bash salt '*' network.default_route """ if family != "inet" and family != "inet6" and family is not None: raise CommandExecutionError("Invalid address family {}".format(family)) _routes = routes(family) default_route = {} if __grains__["kernel"] == "Linux": default_route["inet"] = ["0.0.0.0", "default"] default_route["inet6"] = ["::/0", "default"] elif __grains__["os"] in [ "FreeBSD", "NetBSD", "OpenBSD", "MacOS", "Darwin", ] or __grains__["kernel"] in ("SunOS", "AIX"): default_route["inet"] = ["default"] default_route["inet6"] = ["default"] else: raise CommandExecutionError("Not yet supported on this platform") ret = [] for route in _routes: if family: if route["destination"] in default_route[family]: if __grains__["kernel"] == "SunOS" and route["addr_family"] != family: continue ret.append(route) else: if ( route["destination"] in default_route["inet"] or route["destination"] in default_route["inet6"] ): ret.append(route) return ret def get_route(ip): """ Return routing information for given destination ip .. versionadded:: 2015.5.3 .. versionchanged:: 2015.8.0 Added support for SunOS (Solaris 10, Illumos, SmartOS) Added support for OpenBSD .. versionchanged:: 2016.11.4 Added support for AIX CLI Example: .. code-block:: bash salt '*' network.get_route 10.10.10.10 """ if __grains__["kernel"] == "Linux": cmd = "ip route get {}".format(ip) out = __salt__["cmd.run"](cmd, python_shell=True) regexp = re.compile( r"(via\s+(?P<gateway>[\w\.:]+))?\s+dev\s+(?P<interface>[\w\.\:\-]+)\s+.*src\s+(?P<source>[\w\.:]+)" ) m = regexp.search(out.splitlines()[0]) ret = { "destination": ip, "gateway": m.group("gateway"), "interface": m.group("interface"), "source": m.group("source"), } return ret if __grains__["kernel"] == "SunOS": # [root@nacl ~]# route -n get 172.16.10.123 # route to: 172.16.10.123 # destination: 172.16.10.0 # mask: 255.255.255.0 # interface: net0 # flags: <UP,DONE,KERNEL> # recvpipe sendpipe ssthresh rtt,ms rttvar,ms hopcount mtu expire # 0 0 0 0 0 0 1500 0 cmd = "/usr/sbin/route -n get {}".format(ip) out = __salt__["cmd.run"](cmd, python_shell=False) ret = {"destination": ip, "gateway": None, "interface": None, "source": None} for line in out.splitlines(): line = line.split(":") if "route to" in line[0]: ret["destination"] = line[1].strip() if "gateway" in line[0]: ret["gateway"] = line[1].strip() if "interface" in line[0]: ret["interface"] = line[1].strip() ret["source"] = __utils__["network.interface_ip"](line[1].strip()) return ret if __grains__["kernel"] == "OpenBSD": # [root@exosphere] route -n get blackdot.be # route to: 5.135.127.100 # destination: default # mask: default # gateway: 192.168.0.1 # interface: vio0 # if address: 192.168.0.2 # priority: 8 (static) # flags: <UP,GATEWAY,DONE,STATIC> # use mtu expire # 8352657 0 0 cmd = "route -n get {}".format(ip) out = __salt__["cmd.run"](cmd, python_shell=False) ret = {"destination": ip, "gateway": None, "interface": None, "source": None} for line in out.splitlines(): line = line.split(":") if "route to" in line[0]: ret["destination"] = line[1].strip() if "gateway" in line[0]: ret["gateway"] = line[1].strip() if "interface" in line[0]: ret["interface"] = line[1].strip() if "if address" in line[0]: ret["source"] = line[1].strip() return ret if __grains__["kernel"] == "AIX": # root@la68pp002_pub:~# route -n get 172.29.149.95 # route to: 172.29.149.95 # destination: 172.29.149.95 # gateway: 127.0.0.1 # interface: lo0 # interf addr: 127.0.0.1 # flags: <UP,GATEWAY,HOST,DONE,STATIC> # recvpipe sendpipe ssthresh rtt,msec rttvar hopcount mtu expire # 0 0 0 0 0 0 0 -68642 cmd = "route -n get {}".format(ip) out = __salt__["cmd.run"](cmd, python_shell=False) ret = {"destination": ip, "gateway": None, "interface": None, "source": None} for line in out.splitlines(): line = line.split(":") if "route to" in line[0]: ret["destination"] = line[1].strip() if "gateway" in line[0]: ret["gateway"] = line[1].strip() if "interface" in line[0]: ret["interface"] = line[1].strip() if "interf addr" in line[0]: ret["source"] = line[1].strip() return ret else: raise CommandExecutionError("Not yet supported on this platform") def ifacestartswith(cidr): """ Retrieve the interface name from a specific CIDR .. versionadded:: 2016.11.0 CLI Example: .. code-block:: bash salt '*' network.ifacestartswith 10.0 """ net_list = interfaces() intfnames = [] pattern = str(cidr) size = len(pattern) for ifname, ifval in net_list.items(): if "inet" in ifval: for inet in ifval["inet"]: if inet["address"][0:size] == pattern: if "label" in inet: intfnames.append(inet["label"]) else: intfnames.append(ifname) return intfnames def iphexval(ip): """ Retrieve the hexadecimal representation of an IP address .. versionadded:: 2016.11.0 CLI Example: .. code-block:: bash salt '*' network.iphexval 10.0.0.1 """ a = ip.split(".") hexval = ["%02X" % int(x) for x in a] # pylint: disable=E1321 return "".join(hexval) def ip_networks(interface=None, include_loopback=False, verbose=False): """ .. versionadded:: 3001 Returns a list of IPv4 networks to which the minion belongs. interface Restrict results to the specified interface(s). This value can be either a single interface name or a list of interfaces. Globbing is also supported. CLI Example: .. code-block:: bash salt '*' network.ip_networks salt '*' network.ip_networks interface=docker0 salt '*' network.ip_networks interface=docker0,enp* salt '*' network.ip_networks interface=eth* """ return __utils__["network.ip_networks"]( interface=interface, include_loopback=include_loopback, verbose=verbose ) def ip_networks6(interface=None, include_loopback=False, verbose=False): """ .. versionadded:: 3001 Returns a list of IPv6 networks to which the minion belongs. interface Restrict results to the specified interface(s). This value can be either a single interface name or a list of interfaces. Globbing is also supported. CLI Example: .. code-block:: bash salt '*' network.ip_networks6 salt '*' network.ip_networks6 interface=docker0 salt '*' network.ip_networks6 interface=docker0,enp* salt '*' network.ip_networks6 interface=eth* """ return __utils__["network.ip_networks6"]( interface=interface, include_loopback=include_loopback, verbose=verbose ) def fqdns(): """ Return all known FQDNs for the system by enumerating all interfaces and then trying to reverse resolve them (excluding 'lo' interface). CLI Example: .. code-block:: bash salt '*' network.fqdns """ # Provides: # fqdns # Possible value for h_errno defined in netdb.h HOST_NOT_FOUND = 1 NO_DATA = 4 fqdns = set() def _lookup_fqdn(ip): # Random sleep between 0.005 and 0.025 to avoid hitting # the GLIBC race condition. # For more info, see: # https://sourceware.org/bugzilla/show_bug.cgi?id=19329 time.sleep(random.randint(5, 25) / 1000) try: return [socket.getfqdn(socket.gethostbyaddr(ip)[0])] except socket.herror as err: if err.errno in (0, HOST_NOT_FOUND, NO_DATA): # No FQDN for this IP address, so we don't need to know this all the time. log.debug("Unable to resolve address %s: %s", ip, err) else: log.error("Failed to resolve address %s: %s", ip, err) except Exception as err: # pylint: disable=broad-except log.error("Failed to resolve address %s: %s", ip, err) start = time.time() addresses = salt.utils.network.ip_addrs( include_loopback=False, interface_data=salt.utils.network._get_interfaces() ) addresses.extend( salt.utils.network.ip_addrs6( include_loopback=False, interface_data=salt.utils.network._get_interfaces() ) ) # Create a ThreadPool to process the underlying calls to # 'socket.gethostbyaddr' in parallel. This avoid blocking the execution # when the "fqdn" is not defined for certains IP addresses, which was # causing that "socket.timeout" was reached multiple times sequentially, # blocking execution for several seconds. try: with concurrent.futures.ThreadPoolExecutor(8) as pool: future_lookups = { pool.submit(_lookup_fqdn, address): address for address in addresses } for future in concurrent.futures.as_completed(future_lookups): try: resolved_fqdn = future.result() if resolved_fqdn: fqdns.update(resolved_fqdn) except Exception as exc: # pylint: disable=broad-except address = future_lookups[future] log.error("Failed to resolve address %s: %s", address, exc) except Exception as exc: # pylint: disable=broad-except log.error( "Exception while creating a ThreadPoolExecutor for resolving FQDNs: %s", exc ) elapsed = time.time() - start log.debug("Elapsed time getting FQDNs: %s seconds", elapsed) return {"fqdns": sorted(fqdns)}
Save