[release-1.14] fix: pass application context to receive adapter (#477)

knative-prow-robot · Cali0707 · creydr · web-flow · commit 3ec95705c1b9 · 2024-05-13T15:17:48.000Z
* fix: pass application context to receive adapter

Signed-off-by: Calum Murray &lt;cmurray@redhat.com&gt;

* Update cmd/receive_adapter/main.go

Co-authored-by: Christoph Stäbler &lt;cstabler@redhat.com&gt;

---------

Signed-off-by: Calum Murray &lt;cmurray@redhat.com&gt;
Co-authored-by: Calum Murray &lt;cmurray@redhat.com&gt;
Co-authored-by: Christoph Stäbler &lt;cstabler@redhat.com&gt;
diff --git a/cmd/receive_adapter/main.go b/cmd/receive_adapter/main.go
@@ -18,10 +18,14 @@ package main
 
 import (
 	"knative.dev/eventing/pkg/adapter/v2"
+	"knative.dev/pkg/signals"
 
 	cephadapter "knative.dev/eventing-ceph/pkg/adapter"
 )
 
 func main() {
-	adapter.Main("cephsource", cephadapter.NewEnvConfig, cephadapter.NewAdapter)
+	ctx := signals.NewContext()
+	ctx = adapter.WithInjectorEnabled(ctx)
+
+	adapter.MainWithContext(ctx, "cephsource", cephadapter.NewEnvConfig, cephadapter.NewAdapter)
 }

Original file line number	Diff line number	Diff line change
`@@ -18,10 +18,14 @@ package main`
`18`	`18`
`19`	`19`	`import (`
`20`	`20`	`"knative.dev/eventing/pkg/adapter/v2"`
	`21`	`+ "knative.dev/pkg/signals"`
`21`	`22`
`22`	`23`	`cephadapter "knative.dev/eventing-ceph/pkg/adapter"`
`23`	`24`	`)`
`24`	`25`
`25`	`26`	`func main() {`
`26`		`- adapter.Main("cephsource", cephadapter.NewEnvConfig, cephadapter.NewAdapter)`
	`27`	`+ ctx := signals.NewContext()`
	`28`	`+ ctx = adapter.WithInjectorEnabled(ctx)`
	`29`	`+`
	`30`	`+ adapter.MainWithContext(ctx, "cephsource", cephadapter.NewEnvConfig, cephadapter.NewAdapter)`
`27`	`31`	`}`