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