[v1.5] fix: type assertion failed (#1303)

apache · Sep 2, 2022 · 4abed4d · 4abed4d
1 parent 8241b15
commit 4abed4d
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/pkg/ingress/apisix_cluster_config.go b/pkg/ingress/apisix_cluster_config.go
@@ -293,7 +293,7 @@ func (c *apisixClusterConfigController) handleSyncErr(obj interface{}, err error
 	if k8serrors.IsNotFound(err) && event.Type != types.EventDelete {
 		log.Infow("sync ApisixClusterConfig but not found, ignore",
 			zap.String("event_type", event.Type.String()),
-			zap.String("ApisixClusterConfig", event.Object.(string)),
+			zap.Any("ApisixClusterConfig", event.Object.(kube.ApisixClusterConfigEvent)),
 		)
 		c.workqueue.Forget(event)
 		return

diff --git a/pkg/ingress/apisix_consumer.go b/pkg/ingress/apisix_consumer.go
@@ -201,7 +201,7 @@ func (c *apisixConsumerController) handleSyncErr(obj interface{}, err error) {
 	if k8serrors.IsNotFound(err) && event.Type != types.EventDelete {
 		log.Infow("sync ApisixConsumer but not found, ignore",
 			zap.String("event_type", event.Type.String()),
-			zap.String("ApisixConsumer", event.Object.(string)),
+			zap.Any("ApisixConsumer", event.Object.(kube.ApisixConsumerEvent)),
 		)
 		c.workqueue.Forget(event)
 		return

diff --git a/pkg/ingress/apisix_upstream.go b/pkg/ingress/apisix_upstream.go
@@ -323,7 +323,7 @@ func (c *apisixUpstreamController) handleSyncErr(obj interface{}, err error) {
 	if k8serrors.IsNotFound(err) && event.Type != types.EventDelete {
 		log.Infow("sync ApisixUpstream but not found, ignore",
 			zap.String("event_type", event.Type.String()),
-			zap.String("ApisixUpstream", event.Object.(string)),
+			zap.Any("ApisixUpstream", event.Object.(kube.ApisixUpstreamEvent)),
 		)
 		c.workqueue.Forget(event)
 		return

diff --git a/pkg/ingress/endpointslice.go b/pkg/ingress/endpointslice.go
@@ -130,7 +130,7 @@ func (c *endpointSliceController) handleSyncErr(obj interface{}, err error) {
 	if k8serrors.IsNotFound(err) && event.Type != types.EventDelete {
 		log.Infow("sync endpointSlice but not found, ignore",
 			zap.String("event_type", event.Type.String()),
-			zap.String("endpointSlice", event.Object.(string)),
+			zap.Any("endpointSlice", event.Object.(endpointSliceEvent)),
 		)
 		c.workqueue.Forget(event)
 		return