go-sdk: fixes typo (#42)

Signed-off-by: Takeshi Yoneda <[email protected]>

Author: mathetake

go/delay.go

@@ -51,10 +51,10 @@ func (p *delayFilter) RequestHeaders(e gosdk.EnvoyHttpFilter, endOfStream bool)
 	return gosdk.RequestHeadersStatusStopIteration
 }
 
-// Sheduled implements gosdk.HttpFilter.
-func (p *delayFilter) Sheduled(e gosdk.EnvoyHttpFilter, eventID uint64) {
+// Scheduled implements gosdk.HttpFilter.
+func (p *delayFilter) Scheduled(e gosdk.EnvoyHttpFilter, eventID uint64) {
 	if eventID != 0 {
-		panic("unexpected eventID in Sheduled: " + strconv.Itoa(int(eventID)))
+		panic("unexpected eventID in Scheduled: " + strconv.Itoa(int(eventID)))
 	}
 	p.delayLapsed = time.Since(p.onRequestHeaders)
 	// We can insert some headers at this phase.

go/gosdk/abi.go

@@ -301,7 +301,7 @@ func envoy_dynamic_module_on_http_filter_scheduled(
 	eventID C.uint64_t) {
 	pinned := unwrapPinnedHttpFilter(uintptr(filterModulePtr))
 	// Call the Scheduled method of the filter.
-	pinned.obj.Sheduled(envoyFilter{raw: uintptr(filterEnvoyPtr)}, uint64(eventID))
+	pinned.obj.Scheduled(envoyFilter{raw: uintptr(filterEnvoyPtr)}, uint64(eventID))
 }
 
 // GetRequestHeader implements [EnvoyHttpFilter].

go/gosdk/gosdk.go

@@ -103,7 +103,7 @@ type HttpFilter interface {
 
 	// Scheuled is called when the filter is scheduled to run on the Envoy worker thread.
 	// Such event is created via [Scheduler.Commit] and the eventID is the unique identifier for the event.
-	Sheduled(e EnvoyHttpFilter, eventID uint64)
+	Scheduled(e EnvoyHttpFilter, eventID uint64)
 
 	// Destroy is called when the stream is destroyed.
 	Destroy()

go/header_auth.go

@@ -28,8 +28,8 @@ func (p headerAuthFilterConfig) NewFilter() gosdk.HttpFilter {
 	return &headerAuthFilter{authHeaderName: p.authHeaderName}
 }
 
-// Sheduled implements gosdk.HttpFilter.
-func (p headerAuthFilter) Sheduled(gosdk.EnvoyHttpFilter, uint64) {}
+// Scheduled implements gosdk.HttpFilter.
+func (p headerAuthFilter) Scheduled(gosdk.EnvoyHttpFilter, uint64) {}
 
 // Destroy implements [gosdk.HttpFilter].
 func (p *headerAuthFilter) Destroy() {}

go/passthrough.go

@@ -20,8 +20,8 @@ func (p passthroughFilterConfig) Destroy() {}
 // NewFilter implements [gosdk.HttpFilterConfig].
 func (p passthroughFilterConfig) NewFilter() gosdk.HttpFilter { return passthroughFilter{} }
 
-// Sheduled implements gosdk.HttpFilter.
-func (p passthroughFilter) Sheduled(gosdk.EnvoyHttpFilter, uint64) {}
+// Scheduled implements gosdk.HttpFilter.
+func (p passthroughFilter) Scheduled(gosdk.EnvoyHttpFilter, uint64) {}
 
 // Destroy implements [gosdk.HttpFilter].
 func (p passthroughFilter) Destroy() {}

integration/main_test.go

@@ -149,7 +149,7 @@ func TestIntegration(t *testing.T) {
 			t.Logf("response: headers=%v, body=%s", resp.Header, string(body))
 			require.Equal(t, 200, resp.StatusCode)
 
-			// Check the request header "delay-filter-on-scheduled: yes" added in the Sheduled phase.
+			// Check the request header "delay-filter-on-scheduled: yes" added in the Scheduled phase.
 			type httpBinHeadersBody struct {
 				Headers map[string][]string `json:"headers"`
 			}