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
|
# File 'modules/profile/manifests/cassandra.pp', line 3
class profile::cassandra(
Hash $all_instances = lookup('profile::cassandra::instances'),
String $rack = lookup('profile::cassandra::rack'),
Hash $cassandra_settings = lookup('profile::cassandra::settings'),
Stdlib::Host $graphite_host = lookup('graphite_host'),
Array[Stdlib::Host] $prometheus_nodes = lookup('prometheus_nodes'),
Array[Stdlib::IP::Address] $client_ips = lookup('profile::cassandra::client_ips', {'default_value' => []}),
Boolean $allow_analytics = lookup('profile::cassandra::allow_analytics'),
Boolean $monitor_enabled = lookup('profile::cassandra::monitor_enabled', {'default_value' => true}),
Hash[String, String] $cassandra_passwords = lookup('profile::cassandra::user_credentials', {'default_value' => {}}),
){
include ::passwords::cassandra
contain ::profile::java
$instances = $all_instances[$::fqdn]
# We get the cassandra seeds from $all_instances, with a template hack
# This is preferred over a very specialized parser function.
$all_seeds = split(template('profile/cassandra/seeds.erb'), '\|')
$seeds = split($all_seeds[0], ',')
$ferm_seeds = split($all_seeds[1], ',')
$base_settings = {
'instances' => $instances,
'rack' => $rack,
'seeds' => $seeds,
'logstash_host' => 'localhost',
'cassandra_passwords' => $cassandra_passwords,
}
$cassandra_real_settings = merge($base_settings, $cassandra_settings)
create_resources('class', {'::cassandra' => $cassandra_real_settings})
# rsyslog forwards json messages sent to localhost along to logstash via kafka
if $cassandra_real_settings['logstash_host'] == 'localhost' {
class { '::profile::rsyslog::udp_json_logback_compat': }
}
class { '::cassandra::logging': }
class { '::cassandra::twcs': }
class { '::cassandra::sysctl':
# Queue page flushes at 24MB intervals
vm_dirty_background_bytes => 25165824,
}
if $instances {
$instance_names = keys($instances)
::cassandra::instance::monitoring{ $instance_names:
monitor_enabled => $monitor_enabled,
instances => $instances,
tls_cluster_name => $cassandra_settings['tls_cluster_name'],
}
} else {
$default_instances = {
'default' => {
'listen_address' => $::cassandra::listen_address,
}}
::cassandra::instance::monitoring{ 'default':
monitor_enabled => $monitor_enabled,
instances => $default_instances,
tls_cluster_name => $cassandra_settings['tls_cluster_name'],
}
}
system::role { 'cassandra':
description => 'Cassandra server',
}
$cassandra_hosts_ferm = join($ferm_seeds, ' ')
$prometheus_nodes_ferm = join($prometheus_nodes, ' ')
$client_ips_ferm = join($client_ips, ' ')
# Cassandra intra-node messaging
ferm::service { 'cassandra-intra-node':
proto => 'tcp',
port => '7000',
srange => "@resolve((${cassandra_hosts_ferm}))",
}
if $cassandra_settings['tls_cluster_name'] {
# Cassandra intra-node SSL messaging
ferm::service { 'cassandra-intra-node-ssl':
proto => 'tcp',
port => '7001',
srange => "@resolve((${cassandra_hosts_ferm}))",
}
}
# Cassandra JMX/RMI
ferm::service { 'cassandra-jmx-rmi':
proto => 'tcp',
# hardcoded limit of 4 instances per host
port => '7199:7202',
srange => "@resolve((${cassandra_hosts_ferm}))",
}
# Cassandra CQL query interface
# Note: $client_ips is presumed to be IPs and not be resolved
ferm::service { 'cassandra-cql':
proto => 'tcp',
port => '9042',
srange => "(@resolve((${cassandra_hosts_ferm})) ${client_ips_ferm})",
}
# Prometheus jmx_exporter for Cassandra
ferm::service { 'cassandra-jmx_exporter':
proto => 'tcp',
port => '7800',
srange => "@resolve((${prometheus_nodes_ferm}))",
}
if $allow_analytics {
include ::network::constants
$analytics_networks = join($network::constants::analytics_networks, ' ')
ferm::service { 'cassandra-analytics-cql':
proto => 'tcp',
port => '9042',
srange => "(@resolve((${cassandra_hosts_ferm})) ${analytics_networks})",
}
}
}
|