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
|
# ============LICENSE_START=======================================================
# org.onap.dcae
# ================================================================================
# Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
# ================================================================================
# 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.
# ============LICENSE_END=========================================================
#
# ECOMP is a trademark and service mark of AT&T Intellectual Property.
_CONFIG_PATH = "/opt/onap/config.txt" # Path to config file on the Cloudify Manager host
_CONSUL_KEY = "k8s-plugin" # Key under which CM configuration is stored in Consul
# Default configuration values
DCAE_NAMESPACE = "dcae"
CONSUL_DNS_NAME = "consul"
FB_LOG_PATH = "/var/log/onap"
FB_DATA_PATH = "/usr/share/filebeat/data"
FB_CONFIG_PATH = "/usr/share/filebeat/filebeat.yml"
FB_CONFIG_SUBPATH = "filebeat.yml"
FB_CONFIG_MAP = "filebeat-conf"
FB_IMAGE = "docker.elastic.co/beats/filebeat:5.5.0"
TLS_CERT_PATH = "/opt/tls/shared"
TLS_IMAGE = "tls-init:latest"
def _set_defaults():
""" Set default configuration parameters """
return {
"namespace" : DCAE_NAMESPACE, # k8s namespace to use for DCAE
"consul_dns_name" : CONSUL_DNS_NAME, # k8s internal DNS name for Consul
"image_pull_secrets" : [], # list of k8s secrets for accessing Docker registries
"filebeat": { # Configuration for setting up filebeat container
"log_path" : FB_LOG_PATH, # mount point for log volume in filebeat container
"data_path" : FB_DATA_PATH, # mount point for data volume in filebeat container
"config_path" : FB_CONFIG_PATH, # mount point for config volume in filebeat container
"config_subpath" : FB_CONFIG_SUBPATH, # subpath for config data in filebeat container
"config_map" : FB_CONFIG_MAP, # ConfigMap holding the filebeat configuration
"image": FB_IMAGE # Docker image to use for filebeat
},
"tls": { # Configuration for setting up TLS init container
"cert_path" : TLS_CERT_PATH, # mount point for certificate volume in TLS init container
"image": TLS_IMAGE # Docker image to use for TLS init container
}
}
def configure(config_path=_CONFIG_PATH, key = _CONSUL_KEY):
"""
Get configuration information from local file and Consul.
Note that the Cloudify context ("ctx") isn't available at
module load time.
"""
from cloudify.exceptions import NonRecoverableError
import ConfigParser
from k8splugin import discovery
config = _set_defaults()
try:
# Get Consul address from a config file
c = ConfigParser.ConfigParser()
c.read(config_path)
config["consul_host"] = c.get('consul','address')
# Get the rest of the config from Consul
conn = discovery.create_kv_conn(config["consul_host"])
val = discovery.get_kv_value(conn, key)
# Merge Consul results into the config
config.update(val)
except discovery.DiscoveryKVEntryNotFoundError as e:
# Don't reraise error, assume defaults are wanted.
pass
except Exception as e:
raise NonRecoverableError(e)
return config
|
