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
|
# Simple? gluster module by James
# Copyright (C) 2010-2013+ James Shubin
# Written by James Shubin <james@shubin.ca>
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
define gluster::volume(
$bricks = [],
$transport = 'tcp',
$replica = 1,
$stripe = 1,
$vip = '', # vip of the cluster (optional but recommended)
$start = undef # start volume ? true, false (stop it) or undef
) {
# TODO: if using rdma, maybe we should pull in the rdma package... ?
$valid_transport = $transport ? {
'rdma' => 'rdma',
'tcp,rdma' => 'tcp,rdma',
default => 'tcp',
}
$valid_replica = $replica ? {
'1' => '',
default => "replica ${replica} ",
}
$valid_stripe = $stripe ? {
'1' => '',
default => "stripe ${stripe} ",
}
# returns interface name that has vip, or '' if none are found.
$vipif = inline_template("<%= interfaces.split(',').find_all {|x| '${vip}' == scope.lookupvar('ipaddress_'+x) }[0,1].join('') %>")
#Gluster::Brick[$bricks] -> Gluster::Volume[$name] # volume requires bricks
# get the bricks that match our fqdn, and append /$name to their path.
# return only these paths, which can be used to build the volume dirs.
$volume_dirs = split(inline_template("<%= bricks.find_all{|x| x.split(':')[0] == '${fqdn}' }.collect {|y| y.split(':')[1].chomp('/')+'/${name}' }.join(' ') %>"), ' ')
file { $volume_dirs:
ensure => directory, # make sure this is a directory
recurse => false, # don't recurse into directory
purge => false, # don't purge unmanaged files
force => false, # don't purge subdirs and links
before => Exec["gluster-volume-create-${name}"],
require => Gluster::Brick[$bricks],
}
# add /${name} to the end of each: brick:/path entry
$brick_spec = inline_template("<%= bricks.collect {|x| ''+x.chomp('/')+'/${name}' }.join(' ') %>")
# run if vip not defined (bypass mode) or if vip exists on this machine
if ($vip == '' or $vipif != '') {
# NOTE: This should only happen on one host!
# NOTE: There's maybe a theoretical race condition if this runs
# at exactly the same time on more than one host. That's why it
# is advisable to use a vip.
# NOTE: This could probably fail on at least N-1 nodes (without
# vip) or one (the vip node, when using vip) before it succeeds
# because it shouldn't work until all the bricks are available,
# which per node will happen right before this runs.
# EXAMPLE: gluster volume create test replica 2 transport tcp annex1.example.com:/storage1a/test annex2.example.com:/storage2a/test annex3.example.com:/storage3b/test annex4.example.com:/storage4b/test annex1.example.com:/storage1c/test annex2.example.com:/storage2c/test annex3.example.com:/storage3d/test annex4.example.com:/storage4d/test
exec { "/usr/sbin/gluster volume create ${name} ${valid_replica}${valid_stripe}transport ${valid_transport} ${brick_spec}":
logoutput => on_failure,
unless => "/usr/sbin/gluster volume list | /bin/grep -qxF '${name}' -", # add volume if it doesn't exist
#before => TODO?,
#require => Gluster::Brick[$bricks],
alias => "gluster-volume-create-${name}",
}
}
# TODO:
#if $shorewall {
# shorewall::rule { 'gluster-TODO':
# rule => "
# ACCEPT ${zone} $FW tcp 24009:${endport}
# ",
# comment => 'TODO',
# before => Service['glusterd'],
# }
#}
# run if vip not defined (by pass mode) or vip exists on this machine
if ($vip == '' or $vipif != '') {
if $start == true {
# try to start volume if stopped
exec { "/usr/sbin/gluster volume start ${name}":
logoutput => on_failure,
unless => "/usr/sbin/gluster volume status ${name}", # returns false if stopped
require => Exec["gluster-volume-create-${name}"],
alias => "gluster-volume-start-${name}",
}
} elsif ( $start == false ) {
# try to stop volume if running
# NOTE: this will still succeed even if a client is mounted
# NOTE: This uses `yes` to workaround the: Stopping volume will
# make its data inaccessible. Do you want to continue? (y/n)
# TODO: http://community.gluster.org/q/how-can-i-make-automatic-scripts/
# TODO: gluster --mode=script volume stop ...
exec { "/usr/bin/yes | /usr/sbin/gluster volume stop ${name}":
logoutput => on_failure,
onlyif => "/usr/sbin/gluster volume status ${name}", # returns true if started
require => Exec["gluster-volume-create-${name}"],
alias => "gluster-volume-stop-${name}",
}
} else { # 'undef'-ined
# don't manage volume run state
}
}
}
# vim: ts=8
|
