Add feature value unpack step to load test

Signed-off-by: khorshuheng <[email protected]>

Author: khorshuheng

main.go

@@ -59,10 +59,11 @@ func main() {
 		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
 		defer cancel()
 		if len(requests) == 1 {
-			_, err := client.GetOnlineFeatures(ctx, &requests[0])
+			resp, err := client.GetOnlineFeatures(ctx, &requests[0])
 			if err != nil {
 				log.Fatalf("%v", err)
 			}
+			postProcessResponse(resp)
 			w.WriteHeader(200)
 		} else {
 			var wg sync.WaitGroup
@@ -75,10 +76,11 @@ func main() {
 				request := request
 				go func() {
 					defer wg.Done()
-					_, err := client.GetOnlineFeatures(ctx, &request)
+					resp, err := client.GetOnlineFeatures(ctx, &request)
 					if err != nil {
 						fatalErrors <- err
 					}
+					postProcessResponse(resp)
 				}()
 			}
 
@@ -120,3 +122,11 @@ func main() {
 	}
 }
 
+func postProcessResponse(resp *feast.OnlineFeaturesResponse) {
+	for _, fieldValue := range resp.RawResponse.FieldValues {
+		for _, field := range fieldValue.Fields {
+			field.GetVal()
+		}
+	}
+}
+