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: debian_ip.py
""" The networking module for Debian-based distros References: * http://www.debian.org/doc/manuals/debian-reference/ch05.en.html """ import functools import io import logging import os import os.path import re import time import jinja2 import jinja2.exceptions import salt.utils.dns import salt.utils.files import salt.utils.odict import salt.utils.stringutils import salt.utils.templates import salt.utils.validate.net log = logging.getLogger(__name__) # Set up template environment JINJA = jinja2.Environment( loader=jinja2.FileSystemLoader( os.path.join(salt.utils.templates.TEMPLATE_DIRNAME, "debian_ip") ) ) # Define the module's virtual name __virtualname__ = "ip" def __virtual__(): """ Confine this module to Debian-based distros """ if __grains__["os_family"] == "Debian": return __virtualname__ return (False, "The debian_ip module could not be loaded: unsupported OS family") _ETHTOOL_CONFIG_OPTS = { "speed": "link-speed", "duplex": "link-duplex", "autoneg": "ethernet-autoneg", "ethernet-port": "ethernet-port", "wol": "ethernet-wol", "driver-message-level": "driver-message-level", "ethernet-pause-rx": "ethernet-pause-rx", "ethernet-pause-tx": "ethernet-pause-tx", "ethernet-pause-autoneg": "ethernet-pause-autoneg", "rx": "offload-rx", "tx": "offload-tx", "sg": "offload-sg", "tso": "offload-tso", "ufo": "offload-ufo", "gso": "offload-gso", "gro": "offload-gro", "lro": "offload-lro", "hardware-irq-coalesce-adaptive-rx": "hardware-irq-coalesce-adaptive-rx", "hardware-irq-coalesce-adaptive-tx": "hardware-irq-coalesce-adaptive-tx", "hardware-irq-coalesce-rx-usecs": "hardware-irq-coalesce-rx-usecs", "hardware-irq-coalesce-rx-frames": "hardware-irq-coalesce-rx-frames", "hardware-dma-ring-rx": "hardware-dma-ring-rx", "hardware-dma-ring-rx-mini": "hardware-dma-ring-rx-mini", "hardware-dma-ring-rx-jumbo": "hardware-dma-ring-rx-jumbo", "hardware-dma-ring-tx": "hardware-dma-ring-tx", } _REV_ETHTOOL_CONFIG_OPTS = { "link-speed": "speed", "link-duplex": "duplex", "ethernet-autoneg": "autoneg", "ethernet-port": "ethernet-port", "ethernet-wol": "wol", "driver-message-level": "driver-message-level", "ethernet-pause-rx": "ethernet-pause-rx", "ethernet-pause-tx": "ethernet-pause-tx", "ethernet-pause-autoneg": "ethernet-pause-autoneg", "offload-rx": "rx", "offload-tx": "tx", "offload-sg": "sg", "offload-tso": "tso", "offload-ufo": "ufo", "offload-gso": "gso", "offload-lro": "lro", "offload-gro": "gro", "hardware-irq-coalesce-adaptive-rx": "hardware-irq-coalesce-adaptive-rx", "hardware-irq-coalesce-adaptive-tx": "hardware-irq-coalesce-adaptive-tx", "hardware-irq-coalesce-rx-usecs": "hardware-irq-coalesce-rx-usecs", "hardware-irq-coalesce-rx-frames": "hardware-irq-coalesce-rx-frames", "hardware-dma-ring-rx": "hardware-dma-ring-rx", "hardware-dma-ring-rx-mini": "hardware-dma-ring-rx-mini", "hardware-dma-ring-rx-jumbo": "hardware-dma-ring-rx-jumbo", "hardware-dma-ring-tx": "hardware-dma-ring-tx", } _DEB_CONFIG_PPPOE_OPTS = { "user": "user", "password": "password", "provider": "provider", "pppoe_iface": "pppoe_iface", "noipdefault": "noipdefault", "usepeerdns": "usepeerdns", "defaultroute": "defaultroute", "holdoff": "holdoff", "maxfail": "maxfail", "hide-password": "hide-password", "lcp-echo-interval": "lcp-echo-interval", "lcp-echo-failure": "lcp-echo-failure", "connect": "connect", "noauth": "noauth", "persist": "persist", "mtu": "mtu", "noaccomp": "noaccomp", "linkname": "linkname", } _DEB_ROUTES_FILE = "/etc/network/routes" _DEB_NETWORK_FILE = "/etc/network/interfaces" _DEB_NETWORK_DIR = "/etc/network/interfaces.d/" _DEB_NETWORK_UP_DIR = "/etc/network/if-up.d/" _DEB_NETWORK_DOWN_DIR = "/etc/network/if-down.d/" _DEB_NETWORK_CONF_FILES = "/etc/modprobe.d/" _DEB_NETWORKING_FILE = "/etc/default/networking" _DEB_HOSTNAME_FILE = "/etc/hostname" _DEB_RESOLV_FILE = "/etc/resolv.conf" _DEB_PPP_DIR = "/etc/ppp/peers/" _CONFIG_TRUE = ["yes", "on", "true", "1", True] _CONFIG_FALSE = ["no", "off", "false", "0", False] _IFACE_TYPES = [ "eth", "bond", "alias", "clone", "ipsec", "dialup", "bridge", "slave", "vlan", "pppoe", "source", ] def _error_msg_iface(iface, option, expected): """ Build an appropriate error message from a given option and a list of expected values. """ msg = "Invalid option -- Interface: {0}, Option: {1}, Expected: [{2}]" return msg.format(iface, option, "|".join(str(e) for e in expected)) def _error_msg_routes(iface, option, expected): """ Build an appropriate error message from a given option and a list of expected values. """ msg = "Invalid option -- Route interface: {0}, Option: {1}, Expected: [{2}]" return msg.format(iface, option, expected) def _log_default_iface(iface, opt, value): log.info( "Using default option -- Interface: %s Option: %s Value: %s", iface, opt, value ) def _error_msg_network(option, expected): """ Build an appropriate error message from a given option and a list of expected values. """ msg = "Invalid network setting -- Setting: {0}, Expected: [{1}]" return msg.format(option, "|".join(str(e) for e in expected)) def _log_default_network(opt, value): log.info("Using existing setting -- Setting: %s Value: %s", opt, value) def _raise_error_iface(iface, option, expected): """ Log and raise an error with a logical formatted message. """ msg = _error_msg_iface(iface, option, expected) log.error(msg) raise AttributeError(msg) def _raise_error_network(option, expected): """ Log and raise an error with a logical formatted message. """ msg = _error_msg_network(option, expected) log.error(msg) raise AttributeError(msg) def _raise_error_routes(iface, option, expected): """ Log and raise an error with a logical formatted message. """ msg = _error_msg_routes(iface, option, expected) log.error(msg) raise AttributeError(msg) def _read_file(path): """ Reads and returns the contents of a text file """ try: with salt.utils.files.flopen(path, "rb") as contents: return [ salt.utils.stringutils.to_str(line) for line in contents.readlines() ] except OSError: return "" def _parse_resolve(): """ Parse /etc/resolv.conf """ return salt.utils.dns.parse_resolv(_DEB_RESOLV_FILE) def _parse_domainname(): """ Parse /etc/resolv.conf and return domainname """ return _parse_resolve().get("domain", "") def _parse_searchdomain(): """ Parse /etc/resolv.conf and return searchdomain """ return _parse_resolve().get("search", "") def _parse_hostname(): """ Parse /etc/hostname and return hostname """ contents = _read_file(_DEB_HOSTNAME_FILE) if contents: return contents[0].split("\n")[0] else: return "" def _parse_current_network_settings(): """ Parse /etc/default/networking and return current configuration """ opts = salt.utils.odict.OrderedDict() opts["networking"] = "" if os.path.isfile(_DEB_NETWORKING_FILE): with salt.utils.files.fopen(_DEB_NETWORKING_FILE) as contents: for line in contents: salt.utils.stringutils.to_unicode(line) if line.startswith("#"): continue elif line.startswith("CONFIGURE_INTERFACES"): opts["networking"] = line.split("=", 1)[1].strip() hostname = _parse_hostname() domainname = _parse_domainname() searchdomain = _parse_searchdomain() opts["hostname"] = hostname opts["domainname"] = domainname opts["searchdomain"] = searchdomain return opts # def __validator_func(value): # return (valid: True/False, (transformed) value, error message) def __ipv4_quad(value): """validate an IPv4 address""" return (salt.utils.validate.net.ipv4_addr(value), value, "dotted IPv4 address") def __ipv6(value): """validate an IPv6 address""" return (salt.utils.validate.net.ipv6_addr(value), value, "IPv6 address") def __mac(value): """validate a mac address""" return (salt.utils.validate.net.mac(value), value, "MAC address") def __anything(value): return (True, value, None) def __int(value): """validate an integer""" valid, _value = False, value try: _value = int(value) valid = True except ValueError: pass return (valid, _value, "integer") def __float(value): """validate a float""" valid, _value = False, value try: _value = float(value) valid = True except ValueError: pass return (valid, _value, "float") def __ipv4_netmask(value): """validate an IPv4 dotted quad or integer CIDR netmask""" valid, errmsg = False, "dotted quad or integer CIDR (0->32)" valid, value, _ = __int(value) if not (valid and 0 <= value <= 32): valid = salt.utils.validate.net.netmask(value) return (valid, value, errmsg) def __ipv6_netmask(value): """validate an IPv6 integer netmask""" valid, errmsg = False, "IPv6 netmask (0->128)" valid, value, _ = __int(value) valid = valid and 0 <= value <= 128 return (valid, value, errmsg) def __within2(value, within=None, errmsg=None, dtype=None): """validate that a value is in ``within`` and optionally a ``dtype``""" valid, _value = False, value if dtype: try: _value = dtype(value) # TODO: this is a bit loose when dtype is a class valid = _value in within except ValueError: pass else: valid = _value in within if errmsg is None: if dtype: typename = getattr( dtype, "__name__", hasattr(dtype, "__class__") and getattr(dtype.__class__, "name", dtype), ) errmsg = "{} within '{}'".format(typename, within) else: errmsg = "within '{}'".format(within) return (valid, _value, errmsg) def __within(within=None, errmsg=None, dtype=None): return functools.partial(__within2, within=within, errmsg=errmsg, dtype=dtype) def __space_delimited_list(value): """validate that a value contains one or more space-delimited values""" if isinstance(value, str): value = value.strip().split() if hasattr(value, "__iter__") and value != []: return (True, value, "space-delimited string") else: return ( False, value, "{} is not a valid space-delimited value.\n".format(value), ) SALT_ATTR_TO_DEBIAN_ATTR_MAP = { "dns": "dns-nameservers", "search": "dns-search", "hwaddr": "hwaddress", # TODO: this limits bootp functionality "ipaddr": "address", "ipaddrs": "addresses", } DEBIAN_ATTR_TO_SALT_ATTR_MAP = {v: k for (k, v) in SALT_ATTR_TO_DEBIAN_ATTR_MAP.items()} # TODO DEBIAN_ATTR_TO_SALT_ATTR_MAP["address"] = "address" DEBIAN_ATTR_TO_SALT_ATTR_MAP["hwaddress"] = "hwaddress" IPV4_VALID_PROTO = ["bootp", "dhcp", "static", "manual", "loopback", "ppp"] IPV4_ATTR_MAP = { "proto": __within(IPV4_VALID_PROTO, dtype=str), # ipv4 static & manual "address": __ipv4_quad, "addresses": __anything, "netmask": __ipv4_netmask, "broadcast": __ipv4_quad, "metric": __int, "gateway": __ipv4_quad, # supports a colon-delimited list "pointopoint": __ipv4_quad, "hwaddress": __mac, "mtu": __int, "scope": __within(["global", "link", "host"], dtype=str), # dhcp "hostname": __anything, "leasehours": __int, "leasetime": __int, "vendor": __anything, "client": __anything, # bootp "bootfile": __anything, "server": __ipv4_quad, "hwaddr": __mac, # tunnel "mode": __within(["gre", "GRE", "ipip", "IPIP", "802.3ad"], dtype=str), "endpoint": __ipv4_quad, "dstaddr": __ipv4_quad, "local": __ipv4_quad, "ttl": __int, # bond "slaves": __anything, # ppp "provider": __anything, "unit": __int, "options": __anything, # resolvconf "dns-nameservers": __space_delimited_list, "dns-search": __space_delimited_list, # "vlan-raw-device": __anything, # "network": __anything, # i don't know what this is "test": __anything, # TODO "enable_ipv4": __anything, # TODO "enable_ipv6": __anything, # TODO } IPV6_VALID_PROTO = ["auto", "loopback", "static", "manual", "dhcp", "v4tunnel", "6to4"] IPV6_ATTR_MAP = { "proto": __within(IPV6_VALID_PROTO), # ipv6 static & manual "address": __ipv6, "addresses": __anything, "netmask": __ipv6_netmask, "broadcast": __ipv6, "gateway": __ipv6, # supports a colon-delimited list "hwaddress": __mac, "mtu": __int, "scope": __within(["global", "site", "link", "host"], dtype=str), # inet6 auto "privext": __within([0, 1, 2], dtype=int), "dhcp": __within([0, 1], dtype=int), # inet6 static & manual & dhcp "media": __anything, "accept_ra": __within([0, 1, 2], dtype=int), "autoconf": __within([0, 1], dtype=int), "preferred-lifetime": __int, "dad-attempts": __int, # 0 to disable "dad-interval": __float, # bond "slaves": __anything, # tunnel "mode": __within(["gre", "GRE", "ipip", "IPIP", "802.3ad"], dtype=str), "endpoint": __ipv4_quad, "local": __ipv4_quad, "ttl": __int, # resolvconf "dns-nameservers": __space_delimited_list, "dns-search": __space_delimited_list, # "vlan-raw-device": __anything, "test": __anything, # TODO "enable_ipv4": __anything, # TODO "enable_ipv6": __anything, # TODO } WIRELESS_ATTR_MAP = { "wireless-essid": __anything, "wireless-mode": __anything, # TODO "wpa-ap-scan": __within([0, 1, 2], dtype=int), # TODO "wpa-conf": __anything, "wpa-driver": __anything, "wpa-group": __anything, "wpa-key-mgmt": __anything, "wpa-pairwise": __anything, "wpa-psk": __anything, "wpa-proto": __anything, # partial(__within, "wpa-roam": __anything, "wpa-ssid": __anything, # TODO } ATTRMAPS = { "inet": [IPV4_ATTR_MAP, WIRELESS_ATTR_MAP], "inet6": [IPV6_ATTR_MAP, WIRELESS_ATTR_MAP], } def _validate_interface_option(attr, value, addrfam="inet"): """lookup the validation function for a [addrfam][attr] and return the results :param attr: attribute name :param value: raw setting value :param addrfam: address family (inet, inet6, """ valid, _value, errmsg = False, value, "Unknown validator" attrmaps = ATTRMAPS.get(addrfam, []) for attrmap in attrmaps: if attr in attrmap: validate_func = attrmap[attr] (valid, _value, errmsg) = validate_func(value) break return (valid, _value, errmsg) def _attrmaps_contain_attr(attr): return attr in WIRELESS_ATTR_MAP or attr in IPV4_ATTR_MAP or attr in IPV6_ATTR_MAP def _parse_interfaces(interface_files=None): """ Parse /etc/network/interfaces and return current configured interfaces """ if interface_files is None: interface_files = [] # Add this later. if os.path.exists(_DEB_NETWORK_DIR): interface_files += [ "{}/{}".format(_DEB_NETWORK_DIR, dir) for dir in os.listdir(_DEB_NETWORK_DIR) ] if os.path.isfile(_DEB_NETWORK_FILE): interface_files.insert(0, _DEB_NETWORK_FILE) adapters = salt.utils.odict.OrderedDict() method = -1 for interface_file in interface_files: with salt.utils.files.fopen(interface_file) as interfaces: # This ensures iface_dict exists, but does not ensure we're not reading a new interface. iface_dict = {} for line in interfaces: line = salt.utils.stringutils.to_unicode(line) # Identify the clauses by the first word of each line. # Go to the next line if the current line is a comment # or all spaces. if line.lstrip().startswith("#") or line.isspace(): continue # Parse the iface clause if line.startswith("iface"): sline = line.split() if len(sline) != 4: msg = "Interface file malformed: {0}." msg = msg.format(sline) log.error(msg) raise AttributeError(msg) iface_name = sline[1] addrfam = sline[2] method = sline[3] # Create item in dict, if not already there if iface_name not in adapters: adapters[iface_name] = salt.utils.odict.OrderedDict() # Create item in dict, if not already there if "data" not in adapters[iface_name]: adapters[iface_name]["data"] = salt.utils.odict.OrderedDict() if addrfam not in adapters[iface_name]["data"]: adapters[iface_name]["data"][ addrfam ] = salt.utils.odict.OrderedDict() iface_dict = adapters[iface_name]["data"][addrfam] iface_dict["addrfam"] = addrfam iface_dict["proto"] = method iface_dict["filename"] = interface_file # Parse the detail clauses. elif line[0].isspace(): sline = line.split() # conf file attr: dns-nameservers # salt states.network attr: dns attr, valuestr = line.rstrip().split(None, 1) if _attrmaps_contain_attr(attr): if "-" in attr: attrname = attr.replace("-", "_") else: attrname = attr (valid, value, errmsg) = _validate_interface_option( attr, valuestr, addrfam ) if attrname == "address" and "address" in iface_dict: if "addresses" not in iface_dict: iface_dict["addresses"] = [] iface_dict["addresses"].append(value) else: iface_dict[attrname] = value elif attr in _REV_ETHTOOL_CONFIG_OPTS: if "ethtool" not in iface_dict: iface_dict["ethtool"] = salt.utils.odict.OrderedDict() iface_dict["ethtool"][attr] = valuestr elif attr.startswith("bond"): opt = re.split(r"[_-]", attr, maxsplit=1)[1] if "bonding" not in iface_dict: iface_dict["bonding"] = salt.utils.odict.OrderedDict() iface_dict["bonding"][opt] = valuestr elif attr.startswith("bridge"): opt = re.split(r"[_-]", attr, maxsplit=1)[1] if "bridging" not in iface_dict: iface_dict["bridging"] = salt.utils.odict.OrderedDict() iface_dict["bridging"][opt] = valuestr elif attr in [ "up", "pre-up", "post-up", "down", "pre-down", "post-down", ]: cmd = valuestr cmd_key = "{}_cmds".format(re.sub("-", "_", attr)) if cmd_key not in iface_dict: iface_dict[cmd_key] = [] iface_dict[cmd_key].append(cmd) elif line.startswith("auto"): for word in line.split()[1:]: if word not in adapters: adapters[word] = salt.utils.odict.OrderedDict() adapters[word]["enabled"] = True elif line.startswith("allow-hotplug"): for word in line.split()[1:]: if word not in adapters: adapters[word] = salt.utils.odict.OrderedDict() adapters[word]["hotplug"] = True elif line.startswith("source"): if "source" not in adapters: adapters["source"] = salt.utils.odict.OrderedDict() # Create item in dict, if not already there if "data" not in adapters["source"]: adapters["source"]["data"] = salt.utils.odict.OrderedDict() adapters["source"]["data"]["sources"] = [] adapters["source"]["data"]["sources"].append(line.split()[1]) adapters = _filter_malformed_interfaces(adapters=adapters) return adapters def _filter_malformed_interfaces(*, adapters): # Return a sorted list of the keys for bond, bridge and ethtool options to # ensure a consistent order for iface_name in list(adapters): if iface_name == "source": continue if "data" not in adapters[iface_name]: msg = "Interface file malformed for interface: {}.".format(iface_name) log.error(msg) adapters.pop(iface_name) continue for opt in ["ethtool", "bonding", "bridging"]: for inet in ["inet", "inet6"]: if inet in adapters[iface_name]["data"]: if opt in adapters[iface_name]["data"][inet]: opt_keys = sorted( adapters[iface_name]["data"][inet][opt].keys() ) adapters[iface_name]["data"][inet][opt + "_keys"] = opt_keys return adapters def _parse_ethtool_opts(opts, iface): """ Filters given options and outputs valid settings for ETHTOOLS_OPTS If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ config = {} if "autoneg" in opts: if opts["autoneg"] in _CONFIG_TRUE: config.update({"autoneg": "on"}) elif opts["autoneg"] in _CONFIG_FALSE: config.update({"autoneg": "off"}) else: _raise_error_iface(iface, "autoneg", _CONFIG_TRUE + _CONFIG_FALSE) if "duplex" in opts: valid = ["full", "half"] if opts["duplex"] in valid: config.update({"duplex": opts["duplex"]}) else: _raise_error_iface(iface, "duplex", valid) if "speed" in opts: valid = ["10", "100", "1000", "10000"] if str(opts["speed"]) in valid: config.update({"speed": opts["speed"]}) else: _raise_error_iface(iface, opts["speed"], valid) valid = _CONFIG_TRUE + _CONFIG_FALSE for option in ("rx", "tx", "sg", "tso", "ufo", "gso", "gro", "lro"): if option in opts: if opts[option] in _CONFIG_TRUE: config.update({option: "on"}) elif opts[option] in _CONFIG_FALSE: config.update({option: "off"}) else: _raise_error_iface(iface, option, valid) return config def _parse_ethtool_pppoe_opts(opts, iface): """ Filters given options and outputs valid settings for ETHTOOLS_PPPOE_OPTS If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ config = {} for opt in _DEB_CONFIG_PPPOE_OPTS: if opt in opts: config[opt] = opts[opt] if "provider" in opts and not opts["provider"]: _raise_error_iface(iface, "provider", _CONFIG_TRUE + _CONFIG_FALSE) valid = _CONFIG_TRUE + _CONFIG_FALSE for option in ( "noipdefault", "usepeerdns", "defaultroute", "hide-password", "noauth", "persist", "noaccomp", ): if option in opts: if opts[option] in _CONFIG_TRUE: config.update({option: "True"}) elif opts[option] in _CONFIG_FALSE: config.update({option: "False"}) else: _raise_error_iface(iface, option, valid) return config def _parse_settings_bond(opts, iface): """ Filters given options and outputs valid settings for requested operation. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond_def = { # 803.ad aggregation selection logic # 0 for stable (default) # 1 for bandwidth # 2 for count "ad_select": "0", # Max number of transmit queues (default = 16) "tx_queues": "16", # Link monitoring in milliseconds. Most NICs support this "miimon": "100", # ARP interval in milliseconds "arp_interval": "250", # Delay before considering link down in milliseconds (miimon * 2) "downdelay": "200", # lacp_rate 0: Slow - every 30 seconds # lacp_rate 1: Fast - every 1 second "lacp_rate": "0", # Max bonds for this driver "max_bonds": "1", # Specifies the time, in milliseconds, to wait before # enabling a slave after a link recovery has been # detected. Only used with miimon. "updelay": "0", # Used with miimon. # On: driver sends mii # Off: ethtool sends mii "use_carrier": "on", # Default. Don't change unless you know what you are doing. "xmit_hash_policy": "layer2", } if opts["mode"] in ["balance-rr", "0"]: log.info("Device: %s Bonding Mode: load balancing (round-robin)", iface) return _parse_settings_bond_0(opts, iface, bond_def) elif opts["mode"] in ["active-backup", "1"]: log.info("Device: %s Bonding Mode: fault-tolerance (active-backup)", iface) return _parse_settings_bond_1(opts, iface, bond_def) elif opts["mode"] in ["balance-xor", "2"]: log.info("Device: %s Bonding Mode: load balancing (xor)", iface) return _parse_settings_bond_2(opts, iface, bond_def) elif opts["mode"] in ["broadcast", "3"]: log.info("Device: %s Bonding Mode: fault-tolerance (broadcast)", iface) return _parse_settings_bond_3(opts, iface, bond_def) elif opts["mode"] in ["802.3ad", "4"]: log.info( "Device: %s Bonding Mode: IEEE 802.3ad Dynamic link aggregation", iface ) return _parse_settings_bond_4(opts, iface, bond_def) elif opts["mode"] in ["balance-tlb", "5"]: log.info("Device: %s Bonding Mode: transmit load balancing", iface) return _parse_settings_bond_5(opts, iface, bond_def) elif opts["mode"] in ["balance-alb", "6"]: log.info("Device: %s Bonding Mode: adaptive load balancing", iface) return _parse_settings_bond_6(opts, iface, bond_def) else: valid = [ "0", "1", "2", "3", "4", "5", "6", "balance-rr", "active-backup", "balance-xor", "broadcast", "802.3ad", "balance-tlb", "balance-alb", ] _raise_error_iface(iface, "mode", valid) def _parse_settings_bond_0(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond0. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "0"} # ARP targets in n.n.n.n form valid = ["list of ips (up to 16)"] if "arp_ip_target" in opts: if isinstance(opts["arp_ip_target"], list): if 1 <= len(opts["arp_ip_target"]) <= 16: bond.update({"arp_ip_target": ""}) for ip in opts["arp_ip_target"]: # pylint: disable=C0103 if len(bond["arp_ip_target"]) > 0: bond["arp_ip_target"] = bond["arp_ip_target"] + "," + ip else: bond["arp_ip_target"] = ip else: _raise_error_iface(iface, "arp_ip_target", valid) else: _raise_error_iface(iface, "arp_ip_target", valid) else: _raise_error_iface(iface, "arp_ip_target", valid) if "arp_interval" in opts: try: int(opts["arp_interval"]) bond.update({"arp_interval": opts["arp_interval"]}) except ValueError: _raise_error_iface(iface, "arp_interval", ["integer"]) else: _log_default_iface(iface, "arp_interval", bond_def["arp_interval"]) bond.update({"arp_interval": bond_def["arp_interval"]}) return bond def _parse_settings_bond_1(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond1. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "1"} for binding in ["miimon", "downdelay", "updelay"]: if binding in opts: try: int(opts[binding]) bond.update({binding: opts[binding]}) except ValueError: _raise_error_iface(iface, binding, ["integer"]) else: _log_default_iface(iface, binding, bond_def[binding]) bond.update({binding: bond_def[binding]}) if "primary" in opts: bond.update({"primary": opts["primary"]}) if not (__grains__["os"] == "Ubuntu" and __grains__["osrelease_info"][0] >= 16): if "use_carrier" in opts: if opts["use_carrier"] in _CONFIG_TRUE: bond.update({"use_carrier": "1"}) elif opts["use_carrier"] in _CONFIG_FALSE: bond.update({"use_carrier": "0"}) else: valid = _CONFIG_TRUE + _CONFIG_FALSE _raise_error_iface(iface, "use_carrier", valid) else: _log_default_iface(iface, "use_carrier", bond_def["use_carrier"]) bond.update({"use_carrier": bond_def["use_carrier"]}) return bond def _parse_settings_bond_2(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond2. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "2"} valid = ["list of ips (up to 16)"] if "arp_ip_target" in opts: if isinstance(opts["arp_ip_target"], list): if 1 <= len(opts["arp_ip_target"]) <= 16: bond.update({"arp_ip_target": ""}) for ip in opts["arp_ip_target"]: # pylint: disable=C0103 if len(bond["arp_ip_target"]) > 0: bond["arp_ip_target"] = bond["arp_ip_target"] + "," + ip else: bond["arp_ip_target"] = ip else: _raise_error_iface(iface, "arp_ip_target", valid) else: _raise_error_iface(iface, "arp_ip_target", valid) else: _raise_error_iface(iface, "arp_ip_target", valid) if "arp_interval" in opts: try: int(opts["arp_interval"]) bond.update({"arp_interval": opts["arp_interval"]}) except ValueError: _raise_error_iface(iface, "arp_interval", ["integer"]) else: _log_default_iface(iface, "arp_interval", bond_def["arp_interval"]) bond.update({"arp_interval": bond_def["arp_interval"]}) if "hashing-algorithm" in opts: valid = ["layer2", "layer2+3", "layer3+4"] if opts["hashing-algorithm"] in valid: bond.update({"xmit_hash_policy": opts["hashing-algorithm"]}) else: _raise_error_iface(iface, "hashing-algorithm", valid) return bond def _parse_settings_bond_3(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond3. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "3"} for binding in ["miimon", "downdelay", "updelay"]: if binding in opts: try: int(opts[binding]) bond.update({binding: opts[binding]}) except ValueError: _raise_error_iface(iface, binding, ["integer"]) else: _log_default_iface(iface, binding, bond_def[binding]) bond.update({binding: bond_def[binding]}) if "use_carrier" in opts: if opts["use_carrier"] in _CONFIG_TRUE: bond.update({"use_carrier": "1"}) elif opts["use_carrier"] in _CONFIG_FALSE: bond.update({"use_carrier": "0"}) else: valid = _CONFIG_TRUE + _CONFIG_FALSE _raise_error_iface(iface, "use_carrier", valid) else: _log_default_iface(iface, "use_carrier", bond_def["use_carrier"]) bond.update({"use_carrier": bond_def["use_carrier"]}) return bond def _parse_settings_bond_4(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond4. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "4"} for binding in ["miimon", "downdelay", "updelay", "lacp_rate", "ad_select"]: if binding in opts: if binding == "lacp_rate": if opts[binding] == "fast": opts.update({binding: "1"}) if opts[binding] == "slow": opts.update({binding: "0"}) valid = ["fast", "1", "slow", "0"] else: valid = ["integer"] try: int(opts[binding]) bond.update({binding: opts[binding]}) except ValueError: _raise_error_iface(iface, binding, valid) else: _log_default_iface(iface, binding, bond_def[binding]) bond.update({binding: bond_def[binding]}) if "use_carrier" in opts: if opts["use_carrier"] in _CONFIG_TRUE: bond.update({"use_carrier": "1"}) elif opts["use_carrier"] in _CONFIG_FALSE: bond.update({"use_carrier": "0"}) else: valid = _CONFIG_TRUE + _CONFIG_FALSE _raise_error_iface(iface, "use_carrier", valid) else: _log_default_iface(iface, "use_carrier", bond_def["use_carrier"]) bond.update({"use_carrier": bond_def["use_carrier"]}) if "hashing-algorithm" in opts: valid = ["layer2", "layer2+3", "layer3+4"] if opts["hashing-algorithm"] in valid: bond.update({"xmit_hash_policy": opts["hashing-algorithm"]}) else: _raise_error_iface(iface, "hashing-algorithm", valid) return bond def _parse_settings_bond_5(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond5. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "5"} for binding in ["miimon", "downdelay", "updelay"]: if binding in opts: try: int(opts[binding]) bond.update({binding: opts[binding]}) except ValueError: _raise_error_iface(iface, binding, ["integer"]) else: _log_default_iface(iface, binding, bond_def[binding]) bond.update({binding: bond_def[binding]}) if "use_carrier" in opts: if opts["use_carrier"] in _CONFIG_TRUE: bond.update({"use_carrier": "1"}) elif opts["use_carrier"] in _CONFIG_FALSE: bond.update({"use_carrier": "0"}) else: valid = _CONFIG_TRUE + _CONFIG_FALSE _raise_error_iface(iface, "use_carrier", valid) else: _log_default_iface(iface, "use_carrier", bond_def["use_carrier"]) bond.update({"use_carrier": bond_def["use_carrier"]}) if "primary" in opts: bond.update({"primary": opts["primary"]}) return bond def _parse_settings_bond_6(opts, iface, bond_def): """ Filters given options and outputs valid settings for bond6. If an option has a value that is not expected, this function will log what the Interface, Setting and what it was expecting. """ bond = {"mode": "6"} for binding in ["miimon", "downdelay", "updelay"]: if binding in opts: try: int(opts[binding]) bond.update({binding: opts[binding]}) except ValueError: _raise_error_iface(iface, binding, ["integer"]) else: _log_default_iface(iface, binding, bond_def[binding]) bond.update({binding: bond_def[binding]}) if "use_carrier" in opts: if opts["use_carrier"] in _CONFIG_TRUE: bond.update({"use_carrier": "1"}) elif opts["use_carrier"] in _CONFIG_FALSE: bond.update({"use_carrier": "0"}) else: valid = _CONFIG_TRUE + _CONFIG_FALSE _raise_error_iface(iface, "use_carrier", valid) else: _log_default_iface(iface, "use_carrier", bond_def["use_carrier"]) bond.update({"use_carrier": bond_def["use_carrier"]}) if "primary" in opts: bond.update({"primary": opts["primary"]}) return bond def _parse_bridge_opts(opts, iface): """ Filters given options and outputs valid settings for BRIDGING_OPTS If an option has a value that is not expected, this function will log the Interface, Setting and what was expected. """ config = {} if "ports" in opts: if isinstance(opts["ports"], list): opts["ports"] = " ".join(opts["ports"]) config.update({"ports": opts["ports"]}) for opt in ["ageing", "fd", "gcint", "hello", "maxage"]: if opt in opts: try: float(opts[opt]) config.update({opt: opts[opt]}) except ValueError: _raise_error_iface(iface, opt, ["float"]) for opt in ["bridgeprio", "maxwait"]: if opt in opts: if isinstance(opts[opt], int): config.update({opt: opts[opt]}) else: _raise_error_iface(iface, opt, ["integer"]) if "hw" in opts: # match 12 hex digits with either : or - as separators between pairs if re.match( "[0-9a-f]{2}([-:])[0-9a-f]{2}(\\1[0-9a-f]{2}){4}$", opts["hw"].lower() ): config.update({"hw": opts["hw"]}) else: _raise_error_iface(iface, "hw", ["valid MAC address"]) for opt in ["pathcost", "portprio"]: if opt in opts: try: port, cost_or_prio = opts[opt].split() int(cost_or_prio) config.update({opt: "{} {}".format(port, cost_or_prio)}) except ValueError: _raise_error_iface(iface, opt, ["interface integer"]) if "stp" in opts: if opts["stp"] in _CONFIG_TRUE: config.update({"stp": "on"}) elif opts["stp"] in _CONFIG_FALSE: config.update({"stp": "off"}) else: _raise_error_iface(iface, "stp", _CONFIG_TRUE + _CONFIG_FALSE) if "waitport" in opts: if isinstance(opts["waitport"], int): config.update({"waitport": opts["waitport"]}) else: values = opts["waitport"].split() waitport_time = values.pop(0) if waitport_time.isdigit() and values: config.update( {"waitport": "{} {}".format(waitport_time, " ".join(values))} ) else: _raise_error_iface(iface, opt, ["integer [interfaces]"]) return config def _parse_settings_eth(opts, iface_type, enabled, iface): """ Filters given options and outputs valid settings for a network interface. """ adapters = salt.utils.odict.OrderedDict() adapters[iface] = salt.utils.odict.OrderedDict() adapters[iface]["type"] = iface_type adapters[iface]["data"] = salt.utils.odict.OrderedDict() iface_data = adapters[iface]["data"] iface_data["inet"] = salt.utils.odict.OrderedDict() iface_data["inet6"] = salt.utils.odict.OrderedDict() if enabled: adapters[iface]["enabled"] = True if opts.get("hotplug", False): adapters[iface]["hotplug"] = True if opts.get("enable_ipv6", None) and opts.get("iface_type", "") == "vlan": iface_data["inet6"]["vlan_raw_device"] = re.sub(r"\.\d*", "", iface) for addrfam in ["inet", "inet6"]: if iface_type not in ["bridge"]: tmp_ethtool = _parse_ethtool_opts(opts, iface) if tmp_ethtool: ethtool = {} for item in tmp_ethtool: ethtool[_ETHTOOL_CONFIG_OPTS[item]] = tmp_ethtool[item] iface_data[addrfam]["ethtool"] = ethtool # return a list of sorted keys to ensure consistent order iface_data[addrfam]["ethtool_keys"] = sorted(ethtool) if iface_type == "bridge": bridging = _parse_bridge_opts(opts, iface) if bridging: iface_data[addrfam]["bridging"] = bridging iface_data[addrfam]["bridging_keys"] = sorted(bridging) iface_data[addrfam]["addrfam"] = addrfam elif iface_type == "bond": bonding = _parse_settings_bond(opts, iface) if bonding: iface_data[addrfam]["bonding"] = bonding iface_data[addrfam]["bonding"]["slaves"] = opts["slaves"] iface_data[addrfam]["bonding_keys"] = sorted(bonding) iface_data[addrfam]["addrfam"] = addrfam elif iface_type == "slave": adapters[iface]["master"] = opts["master"] opts["proto"] = "manual" iface_data[addrfam]["master"] = adapters[iface]["master"] iface_data[addrfam]["addrfam"] = addrfam elif iface_type == "vlan": iface_data[addrfam]["vlan_raw_device"] = re.sub(r"\.\d*", "", iface) iface_data[addrfam]["addrfam"] = addrfam elif iface_type == "pppoe": tmp_ethtool = _parse_ethtool_pppoe_opts(opts, iface) if tmp_ethtool: for item in tmp_ethtool: adapters[iface]["data"][addrfam][ _DEB_CONFIG_PPPOE_OPTS[item] ] = tmp_ethtool[item] iface_data[addrfam]["addrfam"] = addrfam opts.pop("mode", None) for opt, val in opts.items(): inet = None if opt.startswith("ipv4"): opt = opt[4:] inet = "inet" iface_data["inet"]["addrfam"] = "inet" elif opt.startswith("ipv6"): iface_data["inet6"]["addrfam"] = "inet6" opt = opt[4:] inet = "inet6" elif opt in [ "ipaddr", "address", "ipaddresses", "addresses", "gateway", "proto", ]: iface_data["inet"]["addrfam"] = "inet" inet = "inet" _opt = SALT_ATTR_TO_DEBIAN_ATTR_MAP.get(opt, opt) _debopt = _opt.replace("-", "_") for addrfam in ["inet", "inet6"]: (valid, value, errmsg) = _validate_interface_option( _opt, val, addrfam=addrfam ) if not valid: continue if inet is None and _debopt not in iface_data[addrfam]: iface_data[addrfam][_debopt] = value elif inet == addrfam: iface_data[addrfam][_debopt] = value for opt in [ "up_cmds", "pre_up_cmds", "post_up_cmds", "down_cmds", "pre_down_cmds", "post_down_cmds", ]: if opt in opts: iface_data["inet"][opt] = opts[opt] iface_data["inet6"][opt] = opts[opt] # Remove incomplete/disabled inet blocks for (addrfam, opt) in [("inet", "enable_ipv4"), ("inet6", "enable_ipv6")]: if opts.get(opt, None) is False: iface_data.pop(addrfam) elif iface_data[addrfam].get("addrfam", "") != addrfam: iface_data.pop(addrfam) return adapters def _parse_settings_source(opts, iface_type, enabled, iface): """ Filters given options and outputs valid settings for a network interface. """ adapters = salt.utils.odict.OrderedDict() adapters[iface] = salt.utils.odict.OrderedDict() adapters[iface]["type"] = iface_type adapters[iface]["data"] = salt.utils.odict.OrderedDict() iface_data = adapters[iface]["data"] iface_data["sources"] = [opts["source"]] return adapters def _parse_network_settings(opts, current): """ Filters given options and outputs valid settings for the global network settings file. """ # Normalize keys opts = {k.lower(): v for (k, v) in opts.items()} current = {k.lower(): v for (k, v) in current.items()} result = {} valid = _CONFIG_TRUE + _CONFIG_FALSE if "enabled" not in opts: try: opts["networking"] = current["networking"] _log_default_network("networking", current["networking"]) except ValueError: _raise_error_network("networking", valid) else: opts["networking"] = opts["enabled"] if opts["networking"] in valid: if opts["networking"] in _CONFIG_TRUE: result["networking"] = "yes" elif opts["networking"] in _CONFIG_FALSE: result["networking"] = "no" else: _raise_error_network("networking", valid) if "hostname" not in opts: try: opts["hostname"] = current["hostname"] _log_default_network("hostname", current["hostname"]) except ValueError: _raise_error_network("hostname", ["server1.example.com"]) if opts["hostname"]: result["hostname"] = opts["hostname"] else: _raise_error_network("hostname", ["server1.example.com"]) if "search" in opts: result["search"] = opts["search"] return result def _parse_routes(iface, opts): """ Filters given options and outputs valid settings for the route settings file. """ # Normalize keys opts = {k.lower(): v for (k, v) in opts.items()} result = {} if "routes" not in opts: _raise_error_routes(iface, "routes", "List of routes") for opt in opts: result[opt] = opts[opt] return result def _write_file(iface, data, folder, pattern): """ Writes a file to disk """ filename = os.path.join(folder, pattern.format(iface)) if not os.path.exists(folder): msg = "{0} cannot be written. {1} does not exist" msg = msg.format(filename, folder) log.error(msg) raise AttributeError(msg) with salt.utils.files.flopen(filename, "w") as fout: fout.write(salt.utils.stringutils.to_str(data)) return filename def _write_file_routes(iface, data, folder, pattern): """ Writes a file to disk """ # ifup / ifdown is executing given folder via run-parts. # according to run-parts man-page, only filenames with this pattern are # executed: (^[a-zA-Z0-9_-]+$) # In order to make the routes file work for vlan interfaces # (default would have been in example /etc/network/if-up.d/route-bond0.12) # these dots in the iface name need to be replaced by underscores, so it # can be executed by run-parts iface = iface.replace(".", "_") filename = os.path.join(folder, pattern.format(iface)) if not os.path.exists(folder): msg = "{0} cannot be written. {1} does not exist" msg = msg.format(filename, folder) log.error(msg) raise AttributeError(msg) with salt.utils.files.flopen(filename, "w") as fout: fout.write(salt.utils.stringutils.to_str(data)) __salt__["file.set_mode"](filename, "0755") return filename def _write_file_network(data, filename, create=False): """ Writes a file to disk If file does not exist, only create if create argument is True """ if not os.path.exists(filename) and not create: msg = "{0} cannot be written. {0} does not exist and create is setto False".format( filename ) log.error(msg) raise AttributeError(msg) with salt.utils.files.flopen(filename, "w") as fout: fout.write(salt.utils.stringutils.to_str(data)) def _read_temp(data): """ Return what would be written to disk """ tout = io.StringIO() tout.write(data) tout.seek(0) output = tout.readlines() tout.close() return output def _read_temp_ifaces(iface, data): """ Return what would be written to disk for interfaces """ try: template = JINJA.get_template("debian_eth.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template debian_eth.jinja") return "" ifcfg = template.render({"name": iface, "data": data}) # Return as an array so the difflib works return [item + "\n" for item in ifcfg.split("\n")] def _write_file_ifaces(iface, data, **settings): """ Writes a file to disk """ try: eth_template = JINJA.get_template("debian_eth.jinja") source_template = JINJA.get_template("debian_source.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template debian_eth.jinja") return "" # Read /etc/network/interfaces into a dict adapters = _parse_interfaces() # Apply supplied settings over on-disk settings adapters[iface] = data ifcfg = "" for adapter in adapters: if "type" in adapters[adapter] and adapters[adapter]["type"] == "source": tmp = source_template.render({"name": adapter, "data": adapters[adapter]}) else: tmp = eth_template.render({"name": adapter, "data": adapters[adapter]}) ifcfg = ifcfg + tmp if adapter == iface: saved_ifcfg = tmp _SEPARATE_FILE = False if "filename" in settings: if not settings["filename"].startswith("/"): filename = "{}/{}".format(_DEB_NETWORK_DIR, settings["filename"]) else: filename = settings["filename"] _SEPARATE_FILE = True else: if "filename" in adapters[adapter]["data"]: filename = adapters[adapter]["data"] else: filename = _DEB_NETWORK_FILE if not os.path.exists(os.path.dirname(filename)): msg = "{0} cannot be written." msg = msg.format(os.path.dirname(filename)) log.error(msg) raise AttributeError(msg) with salt.utils.files.flopen(filename, "w") as fout: if _SEPARATE_FILE: fout.write(salt.utils.stringutils.to_str(saved_ifcfg)) else: fout.write(salt.utils.stringutils.to_str(ifcfg)) # Return as an array so the difflib works return saved_ifcfg.split("\n") def _write_file_ppp_ifaces(iface, data): """ Writes a file to disk """ try: template = JINJA.get_template("debian_ppp_eth.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template debian_ppp_eth.jinja") return "" adapters = _parse_interfaces() adapters[iface] = data ifcfg = "" tmp = template.render({"data": adapters[iface]}) ifcfg = tmp + ifcfg filename = _DEB_PPP_DIR + "/" + adapters[iface]["data"]["inet"]["provider"] if not os.path.exists(os.path.dirname(filename)): msg = "{0} cannot be written." msg = msg.format(os.path.dirname(filename)) log.error(msg) raise AttributeError(msg) with salt.utils.files.fopen(filename, "w") as fout: fout.write(salt.utils.stringutils.to_str(ifcfg)) # Return as an array so the difflib works return filename def build_bond(iface, **settings): """ Create a bond script in /etc/modprobe.d with the passed settings and load the bonding kernel module. CLI Example: .. code-block:: bash salt '*' ip.build_bond bond0 mode=balance-alb """ deb_major = __grains__["osrelease"][:1] opts = _parse_settings_bond(settings, iface) try: template = JINJA.get_template("conf.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template conf.jinja") return "" data = template.render({"name": iface, "bonding": opts}) if "test" in settings and settings["test"]: return _read_temp(data) _write_file(iface, data, _DEB_NETWORK_CONF_FILES, "{}.conf".format(iface)) path = os.path.join(_DEB_NETWORK_CONF_FILES, "{}.conf".format(iface)) if deb_major == "5": for line_type in ("alias", "options"): cmd = [ "sed", "-i", "-e", r"/^{}\s{}.*/d".format(line_type, iface), "/etc/modprobe.conf", ] __salt__["cmd.run"](cmd, python_shell=False) __salt__["file.append"]("/etc/modprobe.conf", path) # Load kernel module __salt__["kmod.load"]("bonding") # install ifenslave __salt__["pkg.install"]("ifenslave") return _read_file(path) def build_interface(iface, iface_type, enabled, **settings): """ Build an interface script for a network interface. CLI Example: .. code-block:: bash salt '*' ip.build_interface eth0 eth <settings> """ iface_type = iface_type.lower() if iface_type not in _IFACE_TYPES: _raise_error_iface(iface, iface_type, _IFACE_TYPES) if iface_type == "slave": settings["slave"] = "yes" if "master" not in settings: msg = "master is a required setting for slave interfaces" log.error(msg) raise AttributeError(msg) elif iface_type == "vlan": settings["vlan"] = "yes" __salt__["pkg.install"]("vlan") elif iface_type == "pppoe": settings["pppoe"] = "yes" if not __salt__["pkg.version"]("ppp"): inst = __salt__["pkg.install"]("ppp") elif iface_type == "bond": if "slaves" not in settings: msg = "slaves is a required setting for bond interfaces" log.error(msg) raise AttributeError(msg) elif iface_type == "bridge": if "ports" not in settings: msg = ( "ports is a required setting for bridge interfaces on Debian " "or Ubuntu based systems" ) log.error(msg) raise AttributeError(msg) __salt__["pkg.install"]("bridge-utils") if iface_type in ["eth", "bond", "bridge", "slave", "vlan", "pppoe"]: opts = _parse_settings_eth(settings, iface_type, enabled, iface) if iface_type in ["source"]: opts = _parse_settings_source(settings, iface_type, enabled, iface) if "test" in settings and settings["test"]: return _read_temp_ifaces(iface, opts[iface]) ifcfg = _write_file_ifaces(iface, opts[iface], **settings) if iface_type == "pppoe": _write_file_ppp_ifaces(iface, opts[iface]) # ensure lines in list end with newline, so difflib works return [item + "\n" for item in ifcfg] def build_routes(iface, **settings): """ Add route scripts for a network interface using up commands. CLI Example: .. code-block:: bash salt '*' ip.build_routes eth0 <settings> """ opts = _parse_routes(iface, settings) try: template = JINJA.get_template("route_eth.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template route_eth.jinja") return "" add_routecfg = template.render(route_type="add", routes=opts["routes"], iface=iface) del_routecfg = template.render(route_type="del", routes=opts["routes"], iface=iface) if "test" in settings and settings["test"]: return _read_temp(add_routecfg + del_routecfg) filename = _write_file_routes(iface, add_routecfg, _DEB_NETWORK_UP_DIR, "route-{0}") results = _read_file(filename) filename = _write_file_routes( iface, del_routecfg, _DEB_NETWORK_DOWN_DIR, "route-{0}" ) results += _read_file(filename) return results def down(iface, iface_type): """ Shutdown a network interface CLI Example: .. code-block:: bash salt '*' ip.down eth0 eth """ # Slave devices are controlled by the master. # Source 'interfaces' aren't brought down. if iface_type not in ["slave", "source"]: return __salt__["cmd.run"](["ifdown", iface]) return None def get_bond(iface): """ Return the content of a bond script CLI Example: .. code-block:: bash salt '*' ip.get_bond bond0 """ path = os.path.join(_DEB_NETWORK_CONF_FILES, "{}.conf".format(iface)) return _read_file(path) def get_interface(iface): """ Return the contents of an interface script CLI Example: .. code-block:: bash salt '*' ip.get_interface eth0 """ adapters = _parse_interfaces() if iface in adapters: try: if iface == "source": template = JINJA.get_template("debian_source.jinja") else: template = JINJA.get_template("debian_eth.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template debian_eth.jinja") return "" ifcfg = template.render({"name": iface, "data": adapters[iface]}) # ensure lines in list end with newline, so difflib works return [item + "\n" for item in ifcfg.split("\n")] else: return [] def up(iface, iface_type): # pylint: disable=C0103 """ Start up a network interface CLI Example: .. code-block:: bash salt '*' ip.up eth0 eth """ # Slave devices are controlled by the master. # Source 'interfaces' aren't brought up. if iface_type not in ("slave", "source"): return __salt__["cmd.run"](["ifup", iface]) return None def get_network_settings(): """ Return the contents of the global network script. CLI Example: .. code-block:: bash salt '*' ip.get_network_settings """ skip_etc_default_networking = ( __grains__["osfullname"] == "Ubuntu" and int(__grains__["osrelease"].split(".")[0]) >= 12 ) if skip_etc_default_networking: settings = {} if __salt__["service.available"]("networking"): if __salt__["service.status"]("networking"): settings["networking"] = "yes" else: settings["networking"] = "no" else: settings["networking"] = "no" hostname = _parse_hostname() domainname = _parse_domainname() settings["hostname"] = hostname settings["domainname"] = domainname else: settings = _parse_current_network_settings() try: template = JINJA.get_template("display-network.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template display-network.jinja") return "" network = template.render(settings) return _read_temp(network) def get_routes(iface): """ Return the routes for the interface CLI Example: .. code-block:: bash salt '*' ip.get_routes eth0 """ filename = os.path.join(_DEB_NETWORK_UP_DIR, "route-{}".format(iface)) results = _read_file(filename) filename = os.path.join(_DEB_NETWORK_DOWN_DIR, "route-{}".format(iface)) results += _read_file(filename) return results def apply_network_settings(**settings): """ Apply global network configuration. CLI Example: .. code-block:: bash salt '*' ip.apply_network_settings """ if "require_reboot" not in settings: settings["require_reboot"] = False if "apply_hostname" not in settings: settings["apply_hostname"] = False hostname_res = True if settings["apply_hostname"] in _CONFIG_TRUE: if "hostname" in settings: hostname_res = __salt__["network.mod_hostname"](settings["hostname"]) else: log.warning( "The network state sls is trying to apply hostname " "changes but no hostname is defined." ) hostname_res = False res = True if settings["require_reboot"] in _CONFIG_TRUE: log.warning( "The network state sls is requiring a reboot of the system to " "properly apply network configuration." ) res = True else: stop = __salt__["service.stop"]("networking") time.sleep(2) res = stop and __salt__["service.start"]("networking") return hostname_res and res def build_network_settings(**settings): """ Build the global network script. CLI Example: .. code-block:: bash salt '*' ip.build_network_settings <settings> """ changes = [] # Read current configuration and store default values current_network_settings = _parse_current_network_settings() # Build settings opts = _parse_network_settings(settings, current_network_settings) # Ubuntu has moved away from /etc/default/networking # beginning with the 12.04 release so we disable or enable # the networking related services on boot skip_etc_default_networking = ( __grains__["osfullname"] == "Ubuntu" and int(__grains__["osrelease"].split(".")[0]) >= 12 ) if skip_etc_default_networking: if opts["networking"] == "yes": service_cmd = "service.enable" else: service_cmd = "service.disable" if __salt__["service.available"]("NetworkManager"): __salt__[service_cmd]("NetworkManager") if __salt__["service.available"]("networking"): __salt__[service_cmd]("networking") else: try: template = JINJA.get_template("network.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template network.jinja") return "" network = template.render(opts) if "test" in settings and settings["test"]: return _read_temp(network) # Write settings _write_file_network(network, _DEB_NETWORKING_FILE, True) # Get hostname and domain from opts sline = opts["hostname"].split(".", 1) opts["hostname"] = sline[0] current_domainname = current_network_settings["domainname"] current_searchdomain = current_network_settings["searchdomain"] new_domain = False if len(sline) > 1: new_domainname = sline[1] if new_domainname != current_domainname: domainname = new_domainname opts["domainname"] = new_domainname new_domain = True else: domainname = current_domainname opts["domainname"] = domainname else: domainname = current_domainname opts["domainname"] = domainname new_search = False if "search" in opts: new_searchdomain = opts["search"] if new_searchdomain != current_searchdomain: searchdomain = new_searchdomain opts["searchdomain"] = new_searchdomain new_search = True else: searchdomain = current_searchdomain opts["searchdomain"] = searchdomain else: searchdomain = current_searchdomain opts["searchdomain"] = searchdomain # If the domain changes, then we should write the resolv.conf file. if new_domain or new_search: # Look for existing domain line and update if necessary resolve = _parse_resolve() domain_prog = re.compile(r"domain\s+") search_prog = re.compile(r"search\s+") new_contents = [] for item in _read_file(_DEB_RESOLV_FILE): if domain_prog.match(item): item = "domain {}".format(domainname) elif search_prog.match(item): item = "search {}".format(searchdomain) new_contents.append(item) # A domain line didn't exist so we'll add one in # with the new domainname if "domain" not in resolve: new_contents.insert(0, "domain {}".format(domainname)) # A search line didn't exist so we'll add one in # with the new search domain if "search" not in resolve: new_contents.insert("domain" in resolve, "search {}".format(searchdomain)) new_resolv = "\n".join(new_contents) # Write /etc/resolv.conf if not ("test" in settings and settings["test"]): _write_file_network(new_resolv, _DEB_RESOLV_FILE) # used for returning the results back try: template = JINJA.get_template("display-network.jinja") except jinja2.exceptions.TemplateNotFound: log.error("Could not load template display-network.jinja") return "" network = template.render(opts) changes.extend(_read_temp(network)) return changes
Save