65 lines
2.0 KiB
Smarty
65 lines
2.0 KiB
Smarty
#!/bin/bash
|
|
{{/*
|
|
Copyright 2017 The Openstack-Helm Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/}}
|
|
|
|
{{ $envAll := . }}
|
|
|
|
set -ex
|
|
|
|
function contains() {
|
|
[[ $1 =~ (^|[[:space:]])$2($|[[:space:]]) ]] && return 0 || return 1
|
|
}
|
|
|
|
function register_snapshot_repository() {
|
|
result=$(curl -K- <<< "--user ${ELASTICSEARCH_USERNAME}:${ELASTICSEARCH_PASSWORD}" \
|
|
"${ELASTICSEARCH_HOST}/_snapshot/$1" \
|
|
-H 'Content-Type: application/json' -d'
|
|
{
|
|
"type": "s3",
|
|
"settings": {
|
|
"endpoint": "'"$RGW_HOST"'",
|
|
"protocol": "http",
|
|
"bucket": "'"$S3_BUCKET"'"
|
|
}
|
|
}' | python -c "import sys, json; print(json.load(sys.stdin)['acknowledged'])")
|
|
if [ "$result" == "True" ];
|
|
then
|
|
echo "Snapshot repository $1 created!";
|
|
else
|
|
echo "Snapshot repository $1 not created!";
|
|
exit 1;
|
|
fi
|
|
}
|
|
|
|
function verify_snapshot_repository() {
|
|
curl -K- <<< "--user ${ELASTICSEARCH_USERNAME}:${ELASTICSEARCH_PASSWORD}" \
|
|
-XPOST "${ELASTICSEARCH_HOST}/_snapshot/$1/_verify"
|
|
}
|
|
|
|
# Get names of all current snapshot repositories
|
|
snapshot_repos=$(curl -K- <<< "--user ${ELASTICSEARCH_USERNAME}:${ELASTICSEARCH_PASSWORD}" \
|
|
"${ELASTICSEARCH_HOST}"/_cat/repositories?format=json | jq -r '.[].id')
|
|
|
|
# Create snapshot repositories if they don't exist
|
|
{{ range $repository := $envAll.Values.conf.elasticsearch.snapshots.repositories }}
|
|
if contains "$snapshot_repos" {{$repository.name}}; then
|
|
echo "Snapshot repository {{$repository.name}} exists!"
|
|
else
|
|
register_snapshot_repository {{$repository.name}}
|
|
verify_snapshot_repository {{$repository.name}}
|
|
fi
|
|
{{ end }}
|