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 <[email protected]>
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

Reply via email to