Puppet Class: octavia::task_flow

Defined in:
manifests/task_flow.pp

Overview

Class: octavia::task_flow

Setup and configure octavia.conf task_flow section.

Parameters

engine

(optional) TaskFlow engine to use. Defaults to $facts

max_workers

(optional) The maximum number of workers. Defaults to $facts

disable_revert

(optional) If True, disable the controller worker taskflow flows from reverting. Defaults to $facts

jobboard_enabled

(optional) Enable the jobboard feature in taskflow. Defaults to $facts

jobboard_backend_driver

(optional) Jobboard backend driver that will monitor job state. Defaults to $facts

jobboard_backend_hosts

(optional) IP addresses of the redis backend for jobboard. Defaults to $facts

jobboard_backend_port

(optional) The port of jobboard backend server. Defaults to $facts

jobboard_backend_username

(optional) User name for the jobboard backend server. Defaults to $facts

jobboard_backend_password

(optional) Password for the jobboard backend server. Defaults to $facts

jobboard_backend_namespace

(optional) The name used for the job id on the backend server. Defaults to $facts

jobboard_redis_sentinel

(optional) Sentinel name if it is used for Redis. Defaults to $facts

jobboard_redis_backend_ssl_options

(optional) Redis jobboard backend ssl configuration options Defaults to $facts

jobboard_zookeeper_ssl_options

(optional) Zookeeper jobboard backend ssl configuration options. Defaults to $facts

jobboard_expiration_time

(optional) Expiration time in seconds for jobboard tasks. Defaults to $facts

jobboard_save_logbook

(optional) Save logbook info. Defaults to $facts

persistence_connection

(optional) Url used to connect to the persistence database. Defaults to $facts

Parameters:

  • engine (Any) (defaults to: $facts['os_service_default'])
  • max_workers (Any) (defaults to: $facts['os_service_default'])
  • disable_revert (Any) (defaults to: $facts['os_service_default'])
  • jobboard_enabled (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_driver (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_hosts (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_port (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_username (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_password (Any) (defaults to: $facts['os_service_default'])
  • jobboard_backend_namespace (Any) (defaults to: $facts['os_service_default'])
  • jobboard_redis_sentinel (Any) (defaults to: $facts['os_service_default'])
  • jobboard_redis_backend_ssl_options (Any) (defaults to: $facts['os_service_default'])
  • jobboard_zookeeper_ssl_options (Any) (defaults to: $facts['os_service_default'])
  • jobboard_expiration_time (Any) (defaults to: $facts['os_service_default'])
  • jobboard_save_logbook (Any) (defaults to: $facts['os_service_default'])
  • persistence_connection (Any) (defaults to: $facts['os_service_default']) 


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
 
# File 'manifests/task_flow.pp', line 72

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_backend_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'],
) {

  include octavia::deps

  $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_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), ','),
  }

  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_backend_ssl_options' : value => $jobboard_redis_backend_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;
  }
}