1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
#!/usr/bin/python
# -*- coding: utf-8 -*-
# vim: expandtab:tabstop=4:shiftwidth=4
'''
Filters for configuring resources in openshift-ansible
'''
from ansible import errors
def get_attr(data, attribute=None):
''' This looks up dictionary attributes of the form a.b.c and returns
the value.
Ex: data = {'a': {'b': {'c': 5}}}
attribute = "a.b.c"
returns 5
'''
if not attribute:
raise errors.AnsibleFilterError("|failed expects attribute to be set")
ptr = data
for attr in attribute.split('.'):
ptr = ptr[attr]
return ptr
def set_attr(item, key, value, attr_key=None, attr_value=None):
if attr_key and attr_value:
actual_attr_value = get_attr(item, attr_key)
if str(attr_value) != str(actual_attr_value):
continue # We only want to set the values on hosts with defined attributes
kvp = item
for attr in key.split('.'):
if attr == key.split('.')[len(key.split('.'))-1]:
kvp[attr] = value
continue
if attr not in kvp:
kvp[attr] = {}
kvp = kvp[attr]
return item
def set_attrs(items, key, value, attr_key=None, attr_value=None):
for item in items:
create_update_key(item, key, value, attr_key, attr_value)
return items
def oo_set_node_label(arg, key, value, attr_key=None, attr_value=None):
''' This cycles through openshift node definitions
(from "osc get nodes -o json"), and adds a label.
If attr_key and attr_value are set, this will only set the label on
nodes where the attribute matches the specified value.
Ex:
- shell: osc get nodes -o json
register: output
- set_fact:
node_facts: "{{ output.stdout
| from_json
| oo_set_node_label('region', 'infra',
'metadata.name', '172.16.17.43') }}"
'''
arg['items'] = set_attrs(arg['items'], key, value, attr_key, attr_value)
return arg
def oo_set_resource_node(arg, value):
arg = set_attr(arg, 'template.podTemplate.nodeSelector.region', value)
return arg
class FilterModule(object):
''' FilterModule '''
def filters(self):
''' returns a mapping of filters to methods '''
return {
"oo_set_node_label": oo_set_node_label,
"oo_set_resource_node": oo_set_resource_node
}
|
