lbagent: telegraf: add params influx_db_output_unsafe_ssl

This commit is contained in:
Yousong Zhou
2019-03-12 03:39:20 +00:00
parent c6648ed0da
commit 8016a27abf
4 changed files with 17 additions and 12 deletions
+5 -3
View File
@@ -79,9 +79,10 @@ type SLoadbalancerAgentParamsHaproxy struct {
}
type SLoadbalancerAgentParamsTelegraf struct {
InfluxDbOutputUrl string
InfluxDbOutputName string
HaproxyInputInterval int
InfluxDbOutputUrl string
InfluxDbOutputName string
InfluxDbOutputUnsafeSsl bool
HaproxyInputInterval int
}
type SLoadbalancerAgentParams struct {
@@ -524,6 +525,7 @@ listen stats
[[outputs.influxdb]]
urls = ["{{ .telegraf.influx_db_output_url }}"]
database = "{{ .telegraf.influx_db_output_name }}"
insecure_skip_verify = {{ .telegraf.influx_db_output_unsafe_ssl }}
[[inputs.haproxy]]
interval = "{{ .telegraf.haproxy_input_interval }}s"
+4 -3
View File
@@ -55,9 +55,10 @@ func NewAgentParams(agent *models.LoadbalancerAgent) (*AgentParams, error) {
"log_normal": agent.Params.Haproxy.LogNormal,
}
dataTelegraf := map[string]interface{}{
"influx_db_output_url": agent.Params.Telegraf.InfluxDbOutputUrl,
"influx_db_output_name": agent.Params.Telegraf.InfluxDbOutputName,
"haproxy_input_interval": agent.Params.Telegraf.HaproxyInputInterval,
"influx_db_output_url": agent.Params.Telegraf.InfluxDbOutputUrl,
"influx_db_output_name": agent.Params.Telegraf.InfluxDbOutputName,
"influx_db_output_unsafe_ssl": agent.Params.Telegraf.InfluxDbOutputUnsafeSsl,
"haproxy_input_interval": agent.Params.Telegraf.HaproxyInputInterval,
}
data := map[string]map[string]interface{}{
"agent": dataAgent,
+4 -3
View File
@@ -195,9 +195,10 @@ type LoadbalancerAgentParamsHaproxy struct {
}
type LoadbalancerAgentParamsTelegraf struct {
InfluxDbOutputUrl string
InfluxDbOutputName string
HaproxyInputInterval int
InfluxDbOutputUrl string
InfluxDbOutputName string
InfluxDbOutputUnsafeSsl bool
HaproxyInputInterval int
}
type LoadbalancerAgentParams struct {
+4 -3
View File
@@ -26,9 +26,10 @@ type LoadbalancerAgentParamsOptions struct {
HaproxyLogTcp string `choices:"true|false"`
HaproxyLogNormal string `choices:"true|false"`
TelegrafInfluxDbOutputUrl string
TelegrafInfluxDbOutputName string
TelegrafHaproxyInputInterval int
TelegrafInfluxDbOutputUrl string
TelegrafInfluxDbOutputName string
TelegrafInfluxDbOutputUnsafeSsl *bool
TelegrafHaproxyInputInterval int
}
func (opts *LoadbalancerAgentParamsOptions) setPrefixedParams(params *jsonutils.JSONDict, pref string) {