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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
# == Class: octavia::task_flow
#
# Setup and configure octavia.conf task_flow section.
#
# === Parameters
#
# [*engine*]
# (optional) TaskFlow engine to use.
# Defaults to $facts['os_service_default']
#
# [*max_workers*]
# (optional) The maximum number of workers.
# Defaults to $facts['os_service_default']
#
# [*disable_revert*]
# (optional) If True, disable the controller worker taskflow flows from
# reverting.
# Defaults to $facts['os_service_default']
#
# [*jobboard_enabled*]
# (optional) Enable the jobboard feature in taskflow.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_driver*]
# (optional) Jobboard backend driver that will monitor job state.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_hosts*]
# (optional) IP addresses of the redis backend for jobboard.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_port*]
# (optional) The port of jobboard backend server.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_username*]
# (optional) User name for the jobboard backend server.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_password*]
# (optional) Password for the jobboard backend server.
# Defaults to $facts['os_service_default']
#
# [*jobboard_backend_namespace*]
# (optional) The name used for the job id on the backend server.
# Defaults to $facts['os_service_default']
#
# [*jobboard_redis_sentinel*]
# (optional) Sentinel name if it is used for Redis.
# Defaults to $facts['os_service_default']
#
# [*jobboard_redis_sentinel_username*]
# (optional) Redis Sentinel server user name.
# Defaults to $facts['os_service_default']
#
# [*jobboard_redis_sentinel_password*]
# (optional) Redis Sentinel server password.
# Defaults to $facts['os_service_default']
#
# [*jobboard_redis_backend_ssl_options*]
# (optional) Redis jobboard backend ssl configuration options
# Defaults to $facts['os_service_default']
#
# [*jobboard_redis_sentinel_ssl_options*]
# (optional) Redis sentinel ssl configuration options
# Defaults to $facts['os_service_default']
#
# [*jobboard_zookeeper_ssl_options*]
# (optional) Zookeeper jobboard backend ssl configuration options.
# Defaults to $facts['os_service_default']
#
# [*jobboard_expiration_time*]
# (optional) Expiration time in seconds for jobboard tasks.
# Defaults to $facts['os_service_default']
#
# [*jobboard_save_logbook*]
# (optional) Save logbook info.
# Defaults to $facts['os_service_default']
#
# [*persistence_connection*]
# (optional) Url used to connect to the persistence database.
# Defaults to $facts['os_service_default']
#
# [*manage_backend_package*]
# (Optional) Whether to install the backend package.
# Defaults to true.
#
# [*package_ensure*]
# (Optional) ensure state for package.
# Defaults to 'present'
#
class octavia::task_flow (
$engine = $facts['os_service_default'],
$max_workers = $facts['os_service_default'],
$disable_revert = $facts['os_service_default'],
$jobboard_enabled = $facts['os_service_default'],
$jobboard_backend_driver = $facts['os_service_default'],
$jobboard_backend_hosts = $facts['os_service_default'],
$jobboard_backend_port = $facts['os_service_default'],
$jobboard_backend_username = $facts['os_service_default'],
$jobboard_backend_password = $facts['os_service_default'],
$jobboard_backend_namespace = $facts['os_service_default'],
$jobboard_redis_sentinel = $facts['os_service_default'],
$jobboard_redis_sentinel_username = $facts['os_service_default'],
$jobboard_redis_sentinel_password = $facts['os_service_default'],
$jobboard_redis_backend_ssl_options = $facts['os_service_default'],
$jobboard_redis_sentinel_ssl_options = $facts['os_service_default'],
$jobboard_zookeeper_ssl_options = $facts['os_service_default'],
$jobboard_expiration_time = $facts['os_service_default'],
$jobboard_save_logbook = $facts['os_service_default'],
$persistence_connection = $facts['os_service_default'],
Boolean $manage_backend_package = true,
$package_ensure = 'present',
) {
include octavia::deps
include octavia::params
$jobboard_redis_backend_ssl_options_real = $jobboard_redis_backend_ssl_options ? {
Hash => join(join_keys_to_values($jobboard_redis_backend_ssl_options, ':'), ','),
default => join(any2array($jobboard_redis_backend_ssl_options), ','),
}
$jobboard_redis_sentinel_ssl_options_real = $jobboard_redis_sentinel_ssl_options ? {
Hash => join(join_keys_to_values($jobboard_redis_sentinel_ssl_options, ':'), ','),
default => join(any2array($jobboard_redis_sentinel_ssl_options), ','),
}
$jobboard_zookeeper_ssl_options_real = $jobboard_zookeeper_ssl_options ? {
Hash => join(join_keys_to_values($jobboard_zookeeper_ssl_options, ':'), ','),
default => join(any2array($jobboard_zookeeper_ssl_options), ','),
}
if $manage_backend_package {
$jobboard_backend_driver_real = is_service_default($jobboard_backend_driver) ? {
true => 'redis_taskflow_driver',
default => $jobboard_backend_driver,
}
case $jobboard_backend_driver_real {
'zookeeper_taskflow_driver': {
ensure_packages('python-kazoo', {
name => $::octavia::params::python_kazoo_package_name,
ensure => $package_ensure,
tag => ['openstack'],
})
Anchor['octavia::install::begin']
-> Package['python-kazoo']
-> Anchor['octavia::install::end']
}
'redis_taskflow_driver': {
ensure_packages('python-redis', {
name => $::octavia::params::python_redis_package_name,
ensure => $package_ensure,
tag => ['openstack'],
})
Anchor['octavia::install::begin']
-> Package['python-redis']
-> Anchor['octavia::install::end']
}
default: {
fail('unsupported taskflow backend')
}
}
}
octavia_config {
'task_flow/engine' : value => $engine;
'task_flow/max_workers' : value => $max_workers;
'task_flow/disable_revert' : value => $disable_revert;
'task_flow/jobboard_enabled' : value => $jobboard_enabled;
'task_flow/jobboard_backend_driver' : value => $jobboard_backend_driver;
'task_flow/jobboard_backend_hosts' : value => join(any2array($jobboard_backend_hosts), ',');
'task_flow/jobboard_backend_port' : value => $jobboard_backend_port;
'task_flow/jobboard_backend_username' : value => $jobboard_backend_username;
'task_flow/jobboard_backend_password' : value => $jobboard_backend_password, secret => true;
'task_flow/jobboard_backend_namespace' : value => $jobboard_backend_namespace;
'task_flow/jobboard_redis_sentinel' : value => $jobboard_redis_sentinel;
'task_flow/jobboard_redis_sentinel_username' : value => $jobboard_redis_sentinel_username;
'task_flow/jobboard_redis_sentinel_password' : value => $jobboard_redis_sentinel_password, secret => true;
'task_flow/jobboard_redis_backend_ssl_options' : value => $jobboard_redis_backend_ssl_options_real;
'task_flow/jobboard_redis_sentinel_ssl_options' : value => $jobboard_redis_sentinel_ssl_options_real;
'task_flow/jobboard_zookeeper_ssl_options' : value => $jobboard_zookeeper_ssl_options_real;
'task_flow/jobboard_expiration_time' : value => $jobboard_expiration_time;
'task_flow/jobboard_save_logbook' : value => $jobboard_save_logbook;
'task_flow/persistence_connection' : value => $persistence_connection;
}
}
|
