diff --git a/process/aggregate.go b/process/aggregate.go index 57a80565..fe89fb19 100644 --- a/process/aggregate.go +++ b/process/aggregate.go @@ -41,7 +41,7 @@ type procAggregateOptions struct { // // This is only used when handling objects and defaults to an // empty string. - Key string `json:"aggregate_key"` + Key string `json:"key"` // Separator is the string that joins aggregated data. // // This is only used when handling data and defaults to an empty diff --git a/process/capture.go b/process/capture.go index 79fa9909..1bb72a9a 100644 --- a/process/capture.go +++ b/process/capture.go @@ -28,7 +28,7 @@ type procCaptureOptions struct { // // - find_all: applies the FindAll(String)?Submatch function (see count) // - // - namedprocGroup: applies the Find(String)?Submatch function and stores + // - named_group: applies the Find(String)?Submatch function and stores // values as objects using subexpressions Type string `json:"type"` // Count manages the number of repeated capture groups. @@ -106,7 +106,7 @@ func (p procCapture) Apply(ctx context.Context, capsule config.Capsule) (config. capsule.SetData(match[1]) return capsule, nil - case "namedprocGroup": + case "named_group": newCapsule := config.NewCapsule() names := re.SubexpNames() diff --git a/process/capture_test.go b/process/capture_test.go index b285192c..e2257f98 100644 --- a/process/capture_test.go +++ b/process/capture_test.go @@ -61,10 +61,10 @@ var captureTests = []struct { nil, }, { - "namedprocGroup", + "named_group", procCapture{ Options: procCaptureOptions{ - Type: "namedprocGroup", + Type: "named_group", Expression: "(?P[a-zA-Z]+) (?P[a-zA-Z]+)", }, },