Skip to content

Commit 2f1c90b

Browse files
authored
Merge pull request #1463 from penekk/fix-elastic-cloud-output-params
fix: missing cloudAuth/cloudId pair inserts
2 parents 04a4181 + 842c7e2 commit 2f1c90b

File tree

1 file changed

+16
-0
lines changed
  • apis/fluentd/v1alpha1/plugins/output

1 file changed

+16
-0
lines changed

apis/fluentd/v1alpha1/plugins/output/types.go

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -427,6 +427,22 @@ func (o *Output) elasticsearchPluginCommon(common *ElasticsearchCommon, parent *
427427
parent.InsertPairs("ca_file", fmt.Sprint(*common.CAFile))
428428
}
429429

430+
if common.CloudAuth != nil {
431+
cloudauth, err := loader.LoadSecret(*common.CloudAuth)
432+
if err != nil {
433+
return nil, err
434+
}
435+
parent.InsertPairs("cloud_auth", cloudauth)
436+
}
437+
438+
if common.CloudId != nil {
439+
cloudid, err := loader.LoadSecret(*common.CloudId)
440+
if err != nil {
441+
return nil, err
442+
}
443+
parent.InsertPairs("cloud_id", cloudid)
444+
}
445+
430446
if common.ClientCert != nil {
431447
parent.InsertPairs("client_cert", fmt.Sprint(*common.ClientCert))
432448
}

0 commit comments

Comments
 (0)