Drive/sunetdrive
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge branch 'main' into stable

Browse source
This commit is contained in:
Micke Nordin 2023-07-25 08:15:40 +02:00
commit d0ca012129
Signed by untrusted user: Micke
GPG key ID: 0DA0A7A5708FE257
4 changed files with 30 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
manifests/db_type.pp
View file

@ -5,7 +5,6 @@ define sunetdrive::db_type(
$location=undef, $location=undef,
$override_config = undef, $override_config = undef,
$override_compose = undef, $override_compose = undef,
$replicate_rewrite_db = undef,
) )
{ {

2
manifests/mariadb.pp
View file

@ -5,7 +5,6 @@ class sunetdrive::mariadb (
$tag_mariadb = undef, $tag_mariadb = undef,
$override_config = undef, $override_config = undef,
$override_compose = undef, $override_compose = undef,
$replicate_rewrite_db = undef,
) { ) {
$quorum_id = $facts['networking']['fqdn'] $quorum_id = $facts['networking']['fqdn']
@ -14,7 +13,6 @@ class sunetdrive::mariadb (
bootstrap => $bootstrap, bootstrap => $bootstrap,
tag_mariadb => $tag_mariadb, tag_mariadb => $tag_mariadb,
location => $location, location => $location,
replicate_rewrite_db => $replicate_rewrite_db,
} }
file { '/etc/quorum.conf': file { '/etc/quorum.conf':
ensure => file, ensure => file,

4
templates/mariadb/my.cnf.erb
View file

@ -19,10 +19,6 @@ gtid_strict_mode = ON
log_bin = binlog log_bin = binlog
log_slave_updates = ON log_slave_updates = ON
server_id = <%= @server_id %> server_id = <%= @server_id %>
<% if not @replicate_rewrite_db.nil? -%>
replicate-rewrite-db = "<%= @replicate_rewrite_db %>->nextcloud"
replicate-wild-do-table = <%= @replicate_rewrite_db %>.%
<% end -%>
# Innodb # Innodb
innodb_autoinc_lock_mode = 2 innodb_autoinc_lock_mode = 2

57
templates/script/restart-db-cluster.erb
View file

@ -51,7 +51,7 @@ def remove_downtime(fqdn: str,
def main() -> int: def main() -> int:
customer = "<%= @customer %>" customers = ["<%= @customer %>"]
environment = "<%= @environment %>" environment = "<%= @environment %>"
apikey_test = "<%= @apikey_test %>" apikey_test = "<%= @apikey_test %>"
apikey_prod = "<%= @apikey_prod %>" apikey_prod = "<%= @apikey_prod %>"
@ -59,38 +59,41 @@ def main() -> int:
reboot_command = ['sudo /usr/local/bin/safer_reboot'] reboot_command = ['sudo /usr/local/bin/safer_reboot']
for number in reversed(range(1, 4)): if customers[0] == "common":
fqdn = build_fqdn(customer, environment, number) customers = ["gss", "lookup", "multinode"]
ipv4, _ = get_ips_for_hostname(fqdn) for customer in customers:
ip = ipv4[0] for number in reversed(range(1, 4)):
print("Upgrading: {} with ip: {}".format(fqdn, ip)) fqdn = build_fqdn(customer, environment, number)
add_downtime(fqdn, apikey_test) ipv4, _ = get_ips_for_hostname(fqdn)
add_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se") ip = ipv4[0]
print("Upgrading: {} with ip: {}".format(fqdn, ip))
add_downtime(fqdn, apikey_test)
add_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")
run_remote_command(fqdn, reboot_command, user = user) run_remote_command(fqdn, reboot_command, user = user)
success = False success = False
for testnumber in reversed(range(1, 32, 2)): for testnumber in reversed(range(1, 32, 2)):
print("\tSleeping for {} seconds before smoketest on {}".format( print("\tSleeping for {} seconds before smoketest on {}".format(
testnumber, fqdn)) testnumber, fqdn))
time.sleep(testnumber) time.sleep(testnumber)
if smoketest_db_node(fqdn, user = user): if smoketest_db_node(fqdn, user = user):
success = True success = True
break break
remove_downtime(fqdn, apikey_test) remove_downtime(fqdn, apikey_test)
remove_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se") remove_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")
if success: if success:
print("Upgrade cycle succeeded on {} ".format(fqdn)) print("Upgrade cycle succeeded on {} ".format(fqdn))
else: else:
print("Smoketest failed on {} after server reboot command".format( print("Smoketest failed on {} after server reboot command".format(
fqdn)) fqdn))
return 5 return 5
print("All {}-servers successfully upgraded for {}".format( print("All {}-servers successfully upgraded for {}".format(
environment, customer)) environment, customer))
return 0 return 0