fix(aggregate-validation): Adding validation step for FieldAggregate.

Signed-off-by: mereta <mereta.degutyte@hotmail.co.uk>

diff --git a/pkg/hubble/exporter/cell/cell.go b/pkg/hubble/exporter/cell/cell.go
index 7ccd7509c5463f9ee254e52c139bfacc09be8360..1478954ef73f51081dfa2e476125b24d5094313e 100644 (file)
--- a/pkg/hubble/exporter/cell/cell.go
+++ b/pkg/hubble/exporter/cell/cell.go
@@ -89,6 +89,12 @@ func (cfg Config) Validate() error {
                        return fmt.Errorf("hubble-export-fieldmask contains invalid fieldmask '%v': %w", fm, err)
                }
        }
+       if fa := cfg.ExportFieldAggregate; len(fa) > 0 {
+               _, err := fieldmaskpb.New(&flowpb.Flow{}, fa...)
+               if err != nil {
+                       return fmt.Errorf("hubble-export-fieldaggregate contains invalid fieldaggregate '%v': %w", fa, err)
+               }
+       }
        return nil
 }