feat: subscribe to the correct event name when registering a docker scaler (#31)

legosandorigami · scriptnull · web-flow · commit 660f572aec95 · 2024-08-16T21:26:07.000+05:30
Co-authored-by: Vishnu Bharathi &lt;vishnubharathi04@gmail.com&gt;
diff --git a/internal/scaler/docker/docker.go b/internal/scaler/docker/docker.go
@@ -37,7 +37,7 @@ func (s *Scaler) Register(ctx context.Context) error {
 	}
 	cli.NegotiateAPIVersion(ctx)
 
-	event.B.Subscribe(s.namespacedID, func(_ []byte) {
+	event.B.Subscribe(fmt.Sprintf("%s.input", s.namespacedID), func(_ []byte) {
 		s.log.Verbose("start")
 
 		imageFullName := fmt.Sprintf("%s:%s", s.imageName, s.imageTag)

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ func (s *Scaler) Register(ctx context.Context) error {`
`37`	`37`	`}`
`38`	`38`	`cli.NegotiateAPIVersion(ctx)`
`39`	`39`
`40`		`- event.B.Subscribe(s.namespacedID, func(_ []byte) {`
	`40`	`+ event.B.Subscribe(fmt.Sprintf("%s.input", s.namespacedID), func(_ []byte) {`
`41`	`41`	`s.log.Verbose("start")`
`42`	`42`
`43`	`43`	`imageFullName := fmt.Sprintf("%s:%s", s.imageName, s.imageTag)`