You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@apisix.apache.org by zh...@apache.org on 2022/09/02 01:57:03 UTC

[apisix-ingress-controller] branch v1.5.0 updated: [v1.5] fix: type assertion failed (#1303)

This is an automated email from the ASF dual-hosted git repository.

zhangjintao pushed a commit to branch v1.5.0
in repository https://gitbox.apache.org/repos/asf/apisix-ingress-controller.git


The following commit(s) were added to refs/heads/v1.5.0 by this push:
     new 4abed4d7 [v1.5] fix: type assertion failed (#1303)
4abed4d7 is described below

commit 4abed4d7759b9175233cd1f3049d7782f1f7f2bc
Author: Xin Rong <ro...@api7.ai>
AuthorDate: Fri Sep 2 09:56:58 2022 +0800

    [v1.5] fix: type assertion failed (#1303)
---
 pkg/ingress/apisix_cluster_config.go | 2 +-
 pkg/ingress/apisix_consumer.go       | 2 +-
 pkg/ingress/apisix_upstream.go       | 2 +-
 pkg/ingress/endpointslice.go         | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/pkg/ingress/apisix_cluster_config.go b/pkg/ingress/apisix_cluster_config.go
index fa346381..6f1390e3 100644
--- 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
index 581239dd..a0790e30 100644
--- 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
index 526ba977..d7b7bc0f 100644
--- 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
index 63bd05d3..2b55f091 100644
--- 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