change istio json struct

bentol · Jul 27, 2021 · 6cab48e · 6cab48e
1 parent 4e93c2c
commit 6cab48e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/parser/istioparser/istioparser.go b/parser/istioparser/istioparser.go
@@ -63,6 +63,7 @@ func (j *IstioParser) ParseString(line string) (map[string]string, error) {
 		"status":                 j.GetValue(fields, "response_code", ""),
 		"time_local":             j.GetValue(fields, "start_time", ""),
 		"upstream_cluster":       j.GetUpstreamCluster(fields),
+		"authority":              j.GetValue(fields, "authority", ""),
 	}
 	return result, nil
 }

diff --git a/parser/istioparser/istioparser_test.go b/parser/istioparser/istioparser_test.go
@@ -28,6 +28,7 @@ func TestIstioParse(t *testing.T) {
 		"request":                "PUT /v1/order/2145 HTTP/1.1",
 		"request_method":         "PUT",
 		"upstream_cluster":       "payment-service",
+		"authority":              "payment.example.com",
 	}
 	if !reflect.DeepEqual(got, want) {
 		t.Errorf("IstioParser.Parse(), got:\n%v\nwant\n%v", got, want)