mirror of
https://github.com/ansible-collections/community.general.git
synced 2025-06-27 10:40:22 -07:00
6bbd1dd7f5
* feat(maintenance): Add cluster maintenance mode checks for pacemaker * bug(fix): Correct substring typo and unit test This commit corrects a substring check for determining if the pacemaker cluster is in maintenance mode. Additionally, unit test is corrected with correct output from pacemaker when in maintenance mode. * feat(maintenance): Add force argument for absent resources This commit adds in --force argument for resources intended to be absent within a cluster that is in maintenance mode. Without this argument, the cluster will not attempt to remove the resource due to maintenance mode. The resource will be declared as orphaned and exiting maintenance mode will allow the cluster to remove the resource completely. * refactor(review): Apply code review changes This commit adds refactors to enhance code quality. * doc(changelog): Add fragment for maintenance mode addition
68 lines
2.3 KiB
Python
68 lines
2.3 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Copyright (c) 2025, Dexter Le <dextersydney2001@gmail.com>
|
|
# GNU General Public License v3.0+ (see LICENSES/GPL-3.0-or-later.txt or https://www.gnu.org/licenses/gpl-3.0.txt)
|
|
# SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
from __future__ import absolute_import, division, print_function
|
|
__metaclass__ = type
|
|
|
|
from ansible_collections.community.general.plugins.module_utils.cmd_runner import CmdRunner, cmd_runner_fmt
|
|
|
|
|
|
_state_map = {
|
|
"present": "create",
|
|
"absent": "remove",
|
|
"status": "status",
|
|
"enabled": "enable",
|
|
"disabled": "disable"
|
|
}
|
|
|
|
|
|
def fmt_resource_type(value):
|
|
return [value[k] for k in ['resource_standard', 'resource_provider', 'resource_name'] if value.get(k) is not None]
|
|
|
|
|
|
def fmt_resource_operation(value):
|
|
cmd = []
|
|
for op in value:
|
|
cmd.append("op")
|
|
cmd.append(op.get('operation_action'))
|
|
for operation_option in op.get('operation_option'):
|
|
cmd.append(operation_option)
|
|
|
|
return cmd
|
|
|
|
|
|
def fmt_resource_argument(value):
|
|
return ['--group' if value['argument_action'] == 'group' else value['argument_action']] + value['argument_option']
|
|
|
|
|
|
def get_pacemaker_maintenance_mode(runner):
|
|
with runner("config") as ctx:
|
|
rc, out, err = ctx.run()
|
|
maintenance_mode_output = list(filter(lambda string: "maintenance-mode=true" in string.lower(), out.splitlines()))
|
|
return bool(maintenance_mode_output)
|
|
|
|
|
|
def pacemaker_runner(module, cli_action=None, **kwargs):
|
|
runner_command = ['pcs']
|
|
if cli_action:
|
|
runner_command.append(cli_action)
|
|
runner = CmdRunner(
|
|
module,
|
|
command=runner_command,
|
|
arg_formats=dict(
|
|
state=cmd_runner_fmt.as_map(_state_map),
|
|
name=cmd_runner_fmt.as_list(),
|
|
resource_type=cmd_runner_fmt.as_func(fmt_resource_type),
|
|
resource_option=cmd_runner_fmt.as_list(),
|
|
resource_operation=cmd_runner_fmt.as_func(fmt_resource_operation),
|
|
resource_meta=cmd_runner_fmt.stack(cmd_runner_fmt.as_opt_val)("meta"),
|
|
resource_argument=cmd_runner_fmt.as_func(fmt_resource_argument),
|
|
wait=cmd_runner_fmt.as_opt_eq_val("--wait"),
|
|
config=cmd_runner_fmt.as_fixed("config"),
|
|
force=cmd_runner_fmt.as_bool("--force"),
|
|
),
|
|
**kwargs
|
|
)
|
|
return runner
|