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
|
# Class: zookeeper
#
# This module manages ZooKeeper
class zookeeper(
# meta options
String $ensure = $::zookeeper::params::ensure,
Variant[Boolean,String] $ensure_account = $::zookeeper::params::ensure_account,
Boolean $ensure_cron = $::zookeeper::params::ensure_cron,
String $group = $::zookeeper::params::group,
Boolean $system_group = $::zookeeper::params::system_group,
Array[String] $packages = $::zookeeper::params::packages,
String $shell = $::zookeeper::params::shell,
String $user = $::zookeeper::params::user,
Boolean $system_user = $::zookeeper::params::system_user,
# installation options
Hash $archive_checksum = $::zookeeper::params::archive_checksum,
String $archive_dl_site = $::zookeeper::params::archive_dl_site,
Integer $archive_dl_timeout = $::zookeeper::params::archive_dl_timeout,
Optional[String] $archive_dl_url = $::zookeeper::params::archive_dl_url,
String $archive_install_dir = $::zookeeper::params::archive_install_dir,
Boolean $archive_symlink = $::zookeeper::params::archive_symlink,
String $archive_symlink_name = $::zookeeper::params::archive_symlink_name,
String $archive_version = $::zookeeper::params::archive_version,
Optional[String] $cdhver = $::zookeeper::params::cdhver,
Boolean $install_java = $::zookeeper::params::install_java,
String $install_method = $::zookeeper::params::install_method,
String $java_bin = $::zookeeper::params::java_bin,
String $java_opts = $::zookeeper::params::java_opts,
Optional[String] $java_package = $::zookeeper::params::java_package,
Optional[Variant[String,Hash]] $repo = $::zookeeper::params::repo,
# service options
Boolean $manage_service = $::zookeeper::params::manage_service,
Boolean $manage_service_file = $::zookeeper::params::manage_service_file,
String $pid_dir = $::zookeeper::params::pid_dir,
Optional[String] $pid_file = $::zookeeper::params::pid_file,
Boolean $restart_on_change = $::zookeeper::params::restart_on_change,
String $service_ensure = $::zookeeper::params::service_ensure,
String $service_name = $::zookeeper::params::service_name,
Optional[String] $service_provider = $::zookeeper::params::service_provider,
Optional[String] $systemd_unit_want = $::zookeeper::params::systemd_unit_want,
String $systemd_unit_after = $::zookeeper::params::systemd_unit_after,
String $systemd_path = $::zookeeper::params::systemd_path,
String $zk_dir = $::zookeeper::params::zk_dir,
# zookeeper config
String $cfg_dir = $::zookeeper::params::cfg_dir,
String $cleanup_sh = $::zookeeper::params::cleanup_sh,
Optional[String] $client_ip = $::zookeeper::params::client_ip,
Integer $client_port = $::zookeeper::params::client_port,
String $datastore = $::zookeeper::params::datastore,
Optional[String] $datalogstore = $::zookeeper::params::datalogstore,
Integer $election_port = $::zookeeper::params::election_port,
String $export_tag = $::zookeeper::params::export_tag,
String $id = $::zookeeper::params::id,
Integer $init_limit = $::zookeeper::params::init_limit,
Boolean $initialize_datastore = $::zookeeper::params::initialize_datastore,
Boolean $leader = $::zookeeper::params::leader,
Integer $leader_port = $::zookeeper::params::leader_port,
String $log_dir = $::zookeeper::params::log_dir,
Boolean $manual_clean = $::zookeeper::params::manual_clean,
Optional[Integer] $max_session_timeout = $::zookeeper::params::max_session_timeout,
Optional[Integer] $min_session_timeout = $::zookeeper::params::min_session_timeout,
Array[String] $observers = $::zookeeper::params::observers,
Integer $purge_interval = $::zookeeper::params::purge_interval,
Variant[Array[String],Hash[String,String]] $servers = $::zookeeper::params::servers,
Integer $snap_count = $::zookeeper::params::snap_count,
Integer $snap_retain_count = $::zookeeper::params::snap_retain_count,
Integer $sync_limit = $::zookeeper::params::sync_limit,
Integer $tick_time = $::zookeeper::params::tick_time,
Boolean $use_sasl_auth = $::zookeeper::params::use_sasl_auth,
String $zoo_dir = $::zookeeper::params::zoo_dir,
String $zoo_main = $::zookeeper::params::zoo_main,
# log4j properties
String $environment_file = $::zookeeper::params::environment_file,
String $log4j_prop = $::zookeeper::params::log4j_prop,
String $maxfilesize = $::zookeeper::params::maxfilesize,
Integer $maxbackupindex = $::zookeeper::params::maxbackupindex,
Optional[Integer] $max_allowed_connections = $::zookeeper::params::max_allowed_connections,
String $peer_type = $::zookeeper::params::peer_type,
String $rollingfile_threshold = $::zookeeper::params::rollingfile_threshold,
String $tracefile_threshold = $::zookeeper::params::tracefile_threshold,
String $console_threshold = $::zookeeper::params::console_threshold,
# sasl options
Hash[String, String] $sasl_users = $::zookeeper::params::sasl_users,
String $keytab_path = $::zookeeper::params::keytab_path,
String $principal = $::zookeeper::params::principal,
String $realm = $::zookeeper::params::realm,
Boolean $sasl_krb5 = $::zookeeper::params::sasl_krb5,
Boolean $store_key = $::zookeeper::params::store_key,
Boolean $use_keytab = $::zookeeper::params::use_keytab,
Boolean $use_ticket_cache = $::zookeeper::params::use_ticket_cache,
Boolean $remove_host_principal = $::zookeeper::params::remove_host_principal,
Boolean $remove_realm_principal = $::zookeeper::params::remove_realm_principal,
) inherits ::zookeeper::params {
if $pid_file {
$pid_path = $pid_file
} else {
$pid_path = "${pid_dir}/zookeeper.pid"
}
$repo_source = $repo ? {
Hash => 'custom',
String => $repo,
default => undef,
}
if $::zookeeper::ensure_account {
group { $group:
ensure => $ensure_account,
system => $system_group,
}
user { $user:
ensure => $ensure_account,
home => $datastore,
comment => 'Zookeeper',
gid => $group,
shell => $shell,
system => $system_user,
require => Group[$group],
}
}
include zookeeper::install
include zookeeper::config
anchor { 'zookeeper::start': }
-> Class['zookeeper::install']
-> Class['zookeeper::config']
if ($use_sasl_auth) {
include zookeeper::sasl
Class['zookeeper::config']
-> Class['zookeeper::sasl']
-> Class['zookeeper::service']
}
if ($manage_service) and ($service_provider != 'exhibitor') {
include zookeeper::service
Class['zookeeper::config']
-> Class['zookeeper::service']
-> Anchor['zookeeper::end']
}
anchor { 'zookeeper::end': }
}
|
