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

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


The following commit(s) were added to refs/heads/master by this push:
     new 20eb64ea fix: object type should be apisix_upstream and endpointslice 
and apisix_cluster_config (#1268)
20eb64ea is described below

commit 20eb64ea568ee8acd2e2b1f576cdd154935b6a14
Author: Xin Rong <[email protected]>
AuthorDate: Thu Aug 25 11:02:38 2022 +0800

    fix: object type should be apisix_upstream and endpointslice and 
apisix_cluster_config (#1268)
---
 pkg/providers/apisix/apisix_cluster_config.go | 2 +-
 pkg/providers/apisix/apisix_upstream.go       | 2 +-
 pkg/providers/k8s/endpoint/endpointslice.go   | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/pkg/providers/apisix/apisix_cluster_config.go 
b/pkg/providers/apisix/apisix_cluster_config.go
index d611cbb9..7c1f2c50 100644
--- a/pkg/providers/apisix/apisix_cluster_config.go
+++ b/pkg/providers/apisix/apisix_cluster_config.go
@@ -307,7 +307,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/providers/apisix/apisix_upstream.go 
b/pkg/providers/apisix/apisix_upstream.go
index ff9d0678..92b091ec 100644
--- a/pkg/providers/apisix/apisix_upstream.go
+++ b/pkg/providers/apisix/apisix_upstream.go
@@ -339,7 +339,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/providers/k8s/endpoint/endpointslice.go 
b/pkg/providers/k8s/endpoint/endpointslice.go
index 56faffbf..972ecb5a 100644
--- a/pkg/providers/k8s/endpoint/endpointslice.go
+++ b/pkg/providers/k8s/endpoint/endpointslice.go
@@ -147,7 +147,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