From e0d83a125d6b119d60fbe20a61918d2f0b573213 Mon Sep 17 00:00:00 2001 From: Nikolay Osmolovskiy Date: Wed, 5 Apr 2023 23:13:10 +0300 Subject: [PATCH] Fixed config.yaml in chart. fix customFields for kinesis target. Signed-off-by: Nikolay Osmolovskiy --- charts/policy-reporter/config.yaml | 2 +- pkg/config/load.go | 2 +- pkg/target/kinesis/kinesis.go | 3 +-- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/charts/policy-reporter/config.yaml b/charts/policy-reporter/config.yaml index 2a9b6f57..7416b9d8 100644 --- a/charts/policy-reporter/config.yaml +++ b/charts/policy-reporter/config.yaml @@ -165,7 +165,7 @@ s3: bucket: {{ .Values.target.s3.bucket }} bucketKeyEnabled: {{ .Values.target.s3.bucketKeyEnabled }} kmsKeyId: {{ .Values.target.s3.kmsKeyId }} - serverSideEncryption: { .Values.target.s3.serverSideEncryption }} + serverSideEncryption: {{ .Values.target.s3.serverSideEncryption }} pathStyle: {{ .Values.target.s3.pathStyle }} prefix: {{ .Values.target.s3.prefix }} minimumPriority: {{ .Values.target.s3.minimumPriority | quote }} diff --git a/pkg/config/load.go b/pkg/config/load.go index 0389c529..1d2e78a7 100644 --- a/pkg/config/load.go +++ b/pkg/config/load.go @@ -34,7 +34,7 @@ func Load(cmd *cobra.Command) (*Config, error) { v.AutomaticEnv() if err := v.ReadInConfig(); err != nil { - log.Println("[INFO] No configuration file found") + log.Printf("[INFO] No configuration file found: %v\n", err) } if flag := cmd.Flags().Lookup("worker"); flag != nil { diff --git a/pkg/target/kinesis/kinesis.go b/pkg/target/kinesis/kinesis.go index 11784559..c0a52bc8 100644 --- a/pkg/target/kinesis/kinesis.go +++ b/pkg/target/kinesis/kinesis.go @@ -11,7 +11,6 @@ import ( "github.com/kyverno/policy-reporter/pkg/crd/api/policyreport/v1alpha2" "github.com/kyverno/policy-reporter/pkg/helper" "github.com/kyverno/policy-reporter/pkg/target" - "github.com/kyverno/policy-reporter/pkg/target/http" ) // Options to configure the Kinesis target @@ -44,7 +43,7 @@ func (c *client) Send(result v1alpha2.PolicyReportResult) { body := new(bytes.Buffer) - if err := json.NewEncoder(body).Encode(http.NewJSONResult(result)); err != nil { + if err := json.NewEncoder(body).Encode(result); err != nil { zap.L().Error("failed to encode result", zap.String("name", c.Name()), zap.Error(err)) return }