Merge pull request #66 from tetratelabs/cleanup-examples

mathetake · web-flow · commit d359ac1451e3 · 2020-10-01T18:23:33.000+09:00
cleanup examples
diff --git a/Makefile b/Makefile
@@ -25,4 +25,5 @@ run:
 	docker run --entrypoint='/usr/local/bin/envoy' \
 		-p 18000:18000 -p 8099:8099 \
 		-w /tmp/envoy -v $(shell pwd):/tmp/envoy getenvoy/proxy-wasm-go-sdk-ci:istio-${ISTIO_VERSION} \
-		-c /tmp/envoy/examples/${name}/envoy.yaml --concurrency 2
+		-c /tmp/envoy/examples/${name}/envoy.yaml --concurrency 2 \
+		--log-format-prefix-with-location '0' --log-format '%v' # --log-format-prefix-with-location will be removed at 1.17.0 release
diff --git a/examples/helloworld/README.md b/examples/helloworld/README.md
@@ -1,27 +1,14 @@
 ## helloworld
 
-this example handles http request/response headers events and log all headers.
+this example periodically logs the current time in nanoseconds
 
-
-```bash
-proxy_1  | [2020-03-25 09:04:56.149][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127096149656000
-proxy_1  | [2020-03-25 09:04:56.154][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127096154901000
-proxy_1  | [2020-03-25 09:04:56.172][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127096172849000
-proxy_1  | [2020-03-25 09:04:56.174][15][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127096174829000
-proxy_1  | [2020-03-25 09:04:56.177][14][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127096177651000
-proxy_1  | [2020-03-25 09:04:57.149][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127097149361000
-proxy_1  | [2020-03-25 09:04:57.155][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127097155247000
-proxy_1  | [2020-03-25 09:04:57.174][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127097174066000
-proxy_1  | [2020-03-25 09:04:57.176][15][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127097176042000
-proxy_1  | [2020-03-25 09:04:57.178][14][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127097178863000
-proxy_1  | [2020-03-25 09:04:58.149][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127098149674000
-proxy_1  | [2020-03-25 09:04:58.155][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127098155890000
-proxy_1  | [2020-03-25 09:04:58.173][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127098173918000
-proxy_1  | [2020-03-25 09:04:58.176][15][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127098176045000
-proxy_1  | [2020-03-25 09:04:58.178][14][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127098178962000
-proxy_1  | [2020-03-25 09:04:59.150][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127099150824000
-proxy_1  | [2020-03-25 09:04:59.156][1][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127099156638000
-proxy_1  | [2020-03-25 09:04:59.174][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127099174223000
-proxy_1  | [2020-03-25 09:04:59.176][15][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127099176272000
-proxy_1  | [2020-03-25 09:04:59.179][14][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_root_id: OnTick on 1, it's 1585127099179191000
+```
+wasm log helloworld: proxy_on_vm_start from Go!
+wasm log helloworld: proxy_on_vm_start from Go!
+wasm log helloworld: OnTick on 1, it's 1601543078943978000
+wasm log helloworld: OnTick on 1, it's 1601543078947916000
+wasm log helloworld: OnTick on 1, it's 1601543078951979000
+wasm log helloworld: OnTick on 1, it's 1601543079947462000
+wasm log helloworld: OnTick on 1, it's 1601543079951503000
+wasm log helloworld: OnTick on 1, it's 1601543079955484000
 ```
diff --git a/examples/http_auth_random/README.md b/examples/http_auth_random/README.md
@@ -2,7 +2,8 @@
 
 this example authorize requests depending on the hash values of a response from http://httpbin.org/uuid.
 
-```bash
+### message on clients
+```
 $ curl localhost:18000/uuid -v
 *   Trying ::1...
 * TCP_NODELAY set
@@ -46,4 +47,47 @@ $ curl localhost:18000/uuid -v
 * Connection #0 to host localhost left intact
 access forbidden
 
-```
+```
+
+### message on Envoy
+
+```
+wasm log: request header from: :authority: localhost:18000
+wasm log: request header from: :path: /uuid
+wasm log: request header from: :method: GET
+wasm log: request header from: user-agent: curl/7.68.0
+wasm log: request header from: accept: */*
+wasm log: request header from: x-forwarded-proto: http
+wasm log: request header from: x-request-id: fddeac7b-db59-453c-9956-7f1050dbf6d5
+wasm log: http call dispatched to httpbin
+wasm log: response header from httpbin: :status: 200
+wasm log: response header from httpbin: date: Thu, 01 Oct 2020 09:07:32 GMT
+wasm log: response header from httpbin: content-type: application/json
+wasm log: response header from httpbin: content-length: 53
+wasm log: response header from httpbin: connection: keep-alive
+wasm log: response header from httpbin: server: gunicorn/19.9.0
+wasm log: response header from httpbin: access-control-allow-origin: *
+wasm log: response header from httpbin: access-control-allow-credentials: true
+wasm log: response header from httpbin: x-envoy-upstream-service-time: 340
+wasm log: access granted
+wasm log: 2 finished
+wasm log: request header from: :authority: localhost:18000
+wasm log: request header from: :path: /uuid
+wasm log: request header from: :method: GET
+wasm log: request header from: user-agent: curl/7.68.0
+wasm log: request header from: accept: */*
+wasm log: request header from: x-forwarded-proto: http
+wasm log: request header from: x-request-id: 02628dd2-b985-4c4f-a2d2-164589c16f53
+wasm log: http call dispatched to httpbin
+wasm log: response header from httpbin: :status: 200
+wasm log: response header from httpbin: date: Thu, 01 Oct 2020 09:07:34 GMT
+wasm log: response header from httpbin: content-type: application/json
+wasm log: response header from httpbin: content-length: 53
+wasm log: response header from httpbin: connection: keep-alive
+wasm log: response header from httpbin: server: gunicorn/19.9.0
+wasm log: response header from httpbin: access-control-allow-origin: *
+wasm log: response header from httpbin: access-control-allow-credentials: true
+wasm log: response header from httpbin: x-envoy-upstream-service-time: 350
+wasm log: access forbidden
+wasm log: 3 finished
+```
diff --git a/examples/http_headers/README.md b/examples/http_headers/README.md
@@ -2,20 +2,19 @@
 
 this example handles http request/response headers events and log all headers.
 
-
-```bash
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: :authority: localhost:18000
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: :path: /
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: :method: GET
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: user-agent: curl/7.54.0
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: accept: */*
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: hello: Go
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: x-forwarded-proto: http
-proxy_1  | [2020-03-25 09:09:24.937][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: request header: x-request-id: 6542a4ca-b6b3-4667-b41d-7ef4c3392946
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: :status: 200
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: content-length: 13
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: content-type: text/plain
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: date: Wed, 25 Mar 2020 09:09:24 GMT
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: server: envoy
-proxy_1  | [2020-03-25 09:09:24.942][16][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:1077] wasm log my_plugin my_root_id: response header: x-envoy-upstream-service-time: 2
+```
+wasm log: request header --> :authority: localhost:18000
+wasm log: request header --> :path: /uuid
+wasm log: request header --> :method: GET
+wasm log: request header --> user-agent: curl/7.68.0
+wasm log: request header --> accept: */*
+wasm log: request header --> x-forwarded-proto: http
+wasm log: request header --> x-request-id: 5692b633-fd9c-4700-b4dd-7a58e2853eb4
+wasm log: response header <-- :status: 200
+wasm log: response header <-- content-length: 13
+wasm log: response header <-- content-type: text/plain
+wasm log: response header <-- date: Thu, 01 Oct 2020 09:10:09 GMT
+wasm log: response header <-- server: envoy
+wasm log: response header <-- x-envoy-upstream-service-time: 0
+wasm log: 2 finished
 ```
diff --git a/examples/http_headers/main.go b/examples/http_headers/main.go
@@ -41,7 +41,7 @@ func (ctx *httpHeaders) OnHttpRequestHeaders(int, bool) types.Action {
 	}
 
 	for _, h := range hs {
-		proxywasm.LogInfof("request header: %s: %s", h[0], h[1])
+		proxywasm.LogInfof("request header --> %s: %s", h[0], h[1])
 	}
 	return types.ActionContinue
 }
@@ -54,7 +54,7 @@ func (ctx *httpHeaders) OnHttpResponseHeaders(int, bool) types.Action {
 	}
 
 	for _, h := range hs {
-		proxywasm.LogInfof("response header: %s: %s", h[0], h[1])
+		proxywasm.LogInfof("response header <-- %s: %s", h[0], h[1])
 	}
 	return types.ActionContinue
 }
diff --git a/examples/http_headers/main_test.go b/examples/http_headers/main_test.go
@@ -21,8 +21,8 @@ func TestHttpHeaders_OnHttpRequestHeaders(t *testing.T) {
 	logs := host.GetLogs(types.LogLevelInfo)
 	require.Greater(t, len(logs), 1)
 
-	assert.Equal(t, "request header: key2: value2", logs[len(logs)-1])
-	assert.Equal(t, "request header: key1: value1", logs[len(logs)-2])
+	assert.Equal(t, "request header --> key2: value2", logs[len(logs)-1])
+	assert.Equal(t, "request header --> key1: value1", logs[len(logs)-2])
 }
 
 func TestHttpHeaders_OnHttpResponseHeaders(t *testing.T) {
@@ -36,6 +36,6 @@ func TestHttpHeaders_OnHttpResponseHeaders(t *testing.T) {
 	logs := host.GetLogs(types.LogLevelInfo)
 	require.Greater(t, len(logs), 1)
 
-	assert.Equal(t, "response header: key2: value2", logs[len(logs)-1])
-	assert.Equal(t, "response header: key1: value1", logs[len(logs)-2])
+	assert.Equal(t, "response header <-- key2: value2", logs[len(logs)-1])
+	assert.Equal(t, "response header <-- key1: value1", logs[len(logs)-2])
 }
diff --git a/examples/metrics/README.md b/examples/metrics/README.md
@@ -4,20 +4,16 @@
 this example creates simple request counter
 
 ```
-[2020-09-07 16:14:52.723][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 0
-[2020-09-07 16:14:52.723][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:53.586][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 1
-[2020-09-07 16:14:53.586][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:54.235][293742][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 2
-[2020-09-07 16:14:54.235][293742][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:54.747][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 3
-[2020-09-07 16:14:54.747][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:55.267][293722][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 4
-[2020-09-07 16:14:55.267][293722][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:55.778][293742][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 5
-[2020-09-07 16:14:55.778][293742][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:56.474][293722][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 6
-[2020-09-07 16:14:56.474][293722][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-[2020-09-07 16:14:57.051][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: previous value of proxy_wasm_go.request_counter: 7
-[2020-09-07 16:14:57.051][293724][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: incremented
-```
+wasm log: previous value of proxy_wasm_go.request_counter: 0
+wasm log: incremented
+wasm log: previous value of proxy_wasm_go.request_counter: 1
+wasm log: incremented
+wasm log: previous value of proxy_wasm_go.request_counter: 2
+wasm log: incremented
+wasm log: previous value of proxy_wasm_go.request_counter: 3
+wasm log: incremented
+wasm log: previous value of proxy_wasm_go.request_counter: 4
+wasm log: incremented
+wasm log: previous value of proxy_wasm_go.request_counter: 5
+wasm log: incremented
+```
diff --git a/examples/network/README.md b/examples/network/README.md
@@ -4,23 +4,24 @@ this example handles tcp connections and output data into the log stream.
 
 
 ```bash
-[2020-09-23 15:19:57.054][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: new connection!
-[2020-09-23 15:19:57.055][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: downstream data received: GET /uuid HTTP/1.1
+wasm log: new connection!
+wasm log: >>>>>> downstream data received >>>>>>
+GET /uuid HTTP/1.1
 Host: localhost:18000
 User-Agent: curl/7.68.0
 Accept: */*
 
 
-[2020-09-23 15:19:57.055][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: remote address: 127.0.0.1:8099
-[2020-09-23 15:19:57.055][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: upstream data received: HTTP/1.1 200 OK
+wasm log: remote address: 127.0.0.1:8099
+wasm log: <<<<<< upstream data received <<<<<<
+HTTP/1.1 200 OK
 content-length: 13
 content-type: text/plain
-date: Wed, 23 Sep 2020 06:19:56 GMT
+date: Thu, 01 Oct 2020 09:16:33 GMT
 server: envoy
 
 example body
 
-[2020-09-23 15:19:57.055][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: remote address: 127.0.0.1:8099
-[2020-09-23 15:19:57.055][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: downstream connection close!
-[2020-09-23 15:19:57.056][1008407][info][wasm] [external/envoy/source/extensions/common/wasm/context.cc:997] wasm log: connection complete!
+wasm log: downstream connection close!
+wasm log: connection complete!
 ```
diff --git a/examples/network/main.go b/examples/network/main.go
@@ -46,8 +46,6 @@ func (ctx context) OnNewConnection() types.Action {
 }
 
 func (ctx context) OnDownstreamData(dataSize int, _ bool) types.Action {
-	// TODO: dispatch http call
-
 	if dataSize == 0 {
 		return types.ActionContinue
 	}
@@ -57,7 +55,7 @@ func (ctx context) OnDownstreamData(dataSize int, _ bool) types.Action {
 		proxywasm.LogCritical(err.Error())
 	}
 
-	proxywasm.LogInfof("downstream data received: %s", string(data))
+	proxywasm.LogInfof(">>>>>> downstream data received >>>>>>\n%s", string(data))
 	return types.ActionContinue
 }
 
@@ -67,22 +65,23 @@ func (ctx context) OnDownstreamClose(types.PeerType) {
 }
 
 func (ctx context) OnUpstreamData(dataSize int, _ bool) types.Action {
+	if dataSize == 0 {
+		return types.ActionContinue
+	}
+
 	ret, err := proxywasm.HostCallGetProperty([]string{"upstream", "address"})
 	if err != nil {
 		proxywasm.LogCritical(err.Error())
 	}
 
 	proxywasm.LogInfof("remote address: %s", string(ret))
-	if dataSize == 0 {
-		return types.ActionContinue
-	}
 
 	data, err := proxywasm.HostCallGetUpstreamData(0, dataSize)
 	if err != nil && err != types.ErrorStatusNotFound {
 		proxywasm.LogCritical(err.Error())
 	}
 
-	proxywasm.LogInfof("upstream data received: %s", string(data))
+	proxywasm.LogInfof("<<<<<< upstream data received <<<<<<\n%s", string(data))
 	return types.ActionContinue
 }
 
diff --git a/examples/shared_data/README.md b/examples/shared_data/README.md
diff --git a/examples/shared_queue/README.md b/examples/shared_queue/README.md
diff --git a/examples/vm_plugin_configuration/README.md b/examples/vm_plugin_configuration/README.md

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ func (ctx *httpHeaders) OnHttpRequestHeaders(int, bool) types.Action {`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`for _, h := range hs {`
`44`		`- proxywasm.LogInfof("request header: %s: %s", h[0], h[1])`
	`44`	`+ proxywasm.LogInfof("request header --> %s: %s", h[0], h[1])`
`45`	`45`	`}`
`46`	`46`	`return types.ActionContinue`
`47`	`47`	`}`
`@@ -54,7 +54,7 @@ func (ctx *httpHeaders) OnHttpResponseHeaders(int, bool) types.Action {`
`54`	`54`	`}`
`55`	`55`
`56`	`56`	`for _, h := range hs {`
`57`		`- proxywasm.LogInfof("response header: %s: %s", h[0], h[1])`
	`57`	`+ proxywasm.LogInfof("response header <-- %s: %s", h[0], h[1])`
`58`	`58`	`}`
`59`	`59`	`return types.ActionContinue`
`60`	`60`	`}`
Original file line number	Diff line number	Diff line change
`@@ -46,8 +46,6 @@ func (ctx context) OnNewConnection() types.Action {`
`46`	`46`	`}`
`47`	`47`
`48`	`48`	`func (ctx context) OnDownstreamData(dataSize int, _ bool) types.Action {`
`49`		`- // TODO: dispatch http call`
`50`		`-`
`51`	`49`	`if dataSize == 0 {`
`52`	`50`	`return types.ActionContinue`
`53`	`51`	`}`
`@@ -57,7 +55,7 @@ func (ctx context) OnDownstreamData(dataSize int, _ bool) types.Action {`
`57`	`55`	`proxywasm.LogCritical(err.Error())`
`58`	`56`	`}`
`59`	`57`
`60`		`- proxywasm.LogInfof("downstream data received: %s", string(data))`
	`58`	`+ proxywasm.LogInfof(">>>>>> downstream data received >>>>>>\n%s", string(data))`
`61`	`59`	`return types.ActionContinue`
`62`	`60`	`}`
`63`	`61`
`@@ -67,22 +65,23 @@ func (ctx context) OnDownstreamClose(types.PeerType) {`
`67`	`65`	`}`
`68`	`66`
`69`	`67`	`func (ctx context) OnUpstreamData(dataSize int, _ bool) types.Action {`
	`68`	`+ if dataSize == 0 {`
	`69`	`+ return types.ActionContinue`
	`70`	`+ }`
	`71`	`+`
`70`	`72`	`ret, err := proxywasm.HostCallGetProperty([]string{"upstream", "address"})`
`71`	`73`	`if err != nil {`
`72`	`74`	`proxywasm.LogCritical(err.Error())`
`73`	`75`	`}`
`74`	`76`
`75`	`77`	`proxywasm.LogInfof("remote address: %s", string(ret))`
`76`		`- if dataSize == 0 {`
`77`		`- return types.ActionContinue`
`78`		`- }`
`79`	`78`
`80`	`79`	`data, err := proxywasm.HostCallGetUpstreamData(0, dataSize)`
`81`	`80`	`if err != nil && err != types.ErrorStatusNotFound {`
`82`	`81`	`proxywasm.LogCritical(err.Error())`
`83`	`82`	`}`
`84`	`83`
`85`		`- proxywasm.LogInfof("upstream data received: %s", string(data))`
	`84`	`+ proxywasm.LogInfof("<<<<<< upstream data received <<<<<<\n%s", string(data))`
`86`	`85`	`return types.ActionContinue`
`87`	`86`	`}`
`88`	`87`