summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--cloud/pkg/edgecontroller/controller/upstream.go8
-rw-r--r--common/constants/default.go6
-rw-r--r--pkg/apis/componentconfig/cloudcore/v1alpha1/default.go6
-rw-r--r--pkg/apis/componentconfig/cloudcore/v1alpha1/types.go18
4 files changed, 0 insertions, 38 deletions
diff --git a/cloud/pkg/edgecontroller/controller/upstream.go b/cloud/pkg/edgecontroller/controller/upstream.go
index f1c135c66..a07880d36 100644
--- a/cloud/pkg/edgecontroller/controller/upstream.go
+++ b/cloud/pkg/edgecontroller/controller/upstream.go
@@ -110,8 +110,6 @@ type UpstreamController struct {
secretChan chan model.Message
serviceAccountTokenChan chan model.Message
configMapChan chan model.Message
- serviceChan chan model.Message
- endpointsChan chan model.Message
persistentVolumeChan chan model.Message
persistentVolumeClaimChan chan model.Message
volumeAttachmentChan chan model.Message
@@ -129,8 +127,6 @@ type UpstreamController struct {
podLister corelisters.PodLister
configMapLister corelisters.ConfigMapLister
secretLister corelisters.SecretLister
- serviceLister corelisters.ServiceLister
- endpointLister corelisters.EndpointsLister
nodeLister corelisters.NodeLister
leaseLister coordinationlisters.LeaseLister
}
@@ -1353,8 +1349,6 @@ func NewUpstreamController(config *v1alpha1.EdgeController, factory k8sinformer.
config: *config,
}
uc.nodeLister = factory.Core().V1().Nodes().Lister()
- uc.endpointLister = factory.Core().V1().Endpoints().Lister()
- uc.serviceLister = factory.Core().V1().Services().Lister()
uc.podLister = factory.Core().V1().Pods().Lister()
uc.configMapLister = factory.Core().V1().ConfigMaps().Lister()
uc.secretLister = factory.Core().V1().Secrets().Lister()
@@ -1365,8 +1359,6 @@ func NewUpstreamController(config *v1alpha1.EdgeController, factory k8sinformer.
uc.configMapChan = make(chan model.Message, config.Buffer.QueryConfigMap)
uc.secretChan = make(chan model.Message, config.Buffer.QuerySecret)
uc.serviceAccountTokenChan = make(chan model.Message, config.Buffer.ServiceAccountToken)
- uc.serviceChan = make(chan model.Message, config.Buffer.QueryService)
- uc.endpointsChan = make(chan model.Message, config.Buffer.QueryEndpoints)
uc.persistentVolumeChan = make(chan model.Message, config.Buffer.QueryPersistentVolume)
uc.persistentVolumeClaimChan = make(chan model.Message, config.Buffer.QueryPersistentVolumeClaim)
uc.volumeAttachmentChan = make(chan model.Message, config.Buffer.QueryVolumeAttachment)
diff --git a/common/constants/default.go b/common/constants/default.go
index 9f0ac3677..27a572584 100644
--- a/common/constants/default.go
+++ b/common/constants/default.go
@@ -82,8 +82,6 @@ const (
DefaultUpdateNodeStatusWorkers = 1
DefaultQueryConfigMapWorkers = 4
DefaultQuerySecretWorkers = 4
- DefaultQueryServiceWorkers = 4
- DefaultQueryEndpointsWorkers = 4
DefaultQueryPersistentVolumeWorkers = 4
DefaultQueryPersistentVolumeClaimWorkers = 4
DefaultQueryVolumeAttachmentWorkers = 4
@@ -102,8 +100,6 @@ const (
DefaultUpdateNodeStatusBuffer = 1024
DefaultQueryConfigMapBuffer = 1024
DefaultQuerySecretBuffer = 1024
- DefaultQueryServiceBuffer = 1024
- DefaultQueryEndpointsBuffer = 1024
DefaultQueryPersistentVolumeBuffer = 1024
DefaultQueryPersistentVolumeClaimBuffer = 1024
DefaultQueryVolumeAttachmentBuffer = 1024
@@ -120,8 +116,6 @@ const (
DefaultPodEventBuffer = 1
DefaultConfigMapEventBuffer = 1
DefaultSecretEventBuffer = 1
- DefaultServiceEventBuffer = 1
- DefaultEndpointsEventBuffer = 1
DefaultRulesEventBuffer = 1
DefaultRuleEndpointsEventBuffer = 1
diff --git a/pkg/apis/componentconfig/cloudcore/v1alpha1/default.go b/pkg/apis/componentconfig/cloudcore/v1alpha1/default.go
index 1c73e2b47..e78bdddd6 100644
--- a/pkg/apis/componentconfig/cloudcore/v1alpha1/default.go
+++ b/pkg/apis/componentconfig/cloudcore/v1alpha1/default.go
@@ -85,13 +85,9 @@ func NewDefaultCloudCoreConfig() *CloudCoreConfig {
UpdateNodeStatus: constants.DefaultUpdateNodeStatusBuffer,
QueryConfigMap: constants.DefaultQueryConfigMapBuffer,
QuerySecret: constants.DefaultQuerySecretBuffer,
- QueryService: constants.DefaultQueryServiceBuffer,
- QueryEndpoints: constants.DefaultQueryEndpointsBuffer,
PodEvent: constants.DefaultPodEventBuffer,
ConfigMapEvent: constants.DefaultConfigMapEventBuffer,
SecretEvent: constants.DefaultSecretEventBuffer,
- ServiceEvent: constants.DefaultServiceEventBuffer,
- EndpointsEvent: constants.DefaultEndpointsEventBuffer,
RulesEvent: constants.DefaultRulesEventBuffer,
RuleEndpointsEvent: constants.DefaultRuleEndpointsEventBuffer,
QueryPersistentVolume: constants.DefaultQueryPersistentVolumeBuffer,
@@ -112,8 +108,6 @@ func NewDefaultCloudCoreConfig() *CloudCoreConfig {
UpdateNodeStatusWorkers: constants.DefaultUpdateNodeStatusWorkers,
QueryConfigMapWorkers: constants.DefaultQueryConfigMapWorkers,
QuerySecretWorkers: constants.DefaultQuerySecretWorkers,
- QueryServiceWorkers: constants.DefaultQueryServiceWorkers,
- QueryEndpointsWorkers: constants.DefaultQueryEndpointsWorkers,
QueryPersistentVolumeWorkers: constants.DefaultQueryPersistentVolumeWorkers,
QueryPersistentVolumeClaimWorkers: constants.DefaultQueryPersistentVolumeClaimWorkers,
QueryVolumeAttachmentWorkers: constants.DefaultQueryVolumeAttachmentWorkers,
diff --git a/pkg/apis/componentconfig/cloudcore/v1alpha1/types.go b/pkg/apis/componentconfig/cloudcore/v1alpha1/types.go
index 71142e678..f2af11424 100644
--- a/pkg/apis/componentconfig/cloudcore/v1alpha1/types.go
+++ b/pkg/apis/componentconfig/cloudcore/v1alpha1/types.go
@@ -220,12 +220,6 @@ type EdgeControllerBuffer struct {
// QuerySecret indicates the buffer of query secret
// default 1024
QuerySecret int32 `json:"querySecret,omitempty"`
- // QueryService indicates the buffer of query service
- // default 1024
- QueryService int32 `json:"queryService,omitempty"`
- // QueryEndpoints indicates the buffer of query endpoint
- // default 1024
- QueryEndpoints int32 `json:"queryEndpoints,omitempty"`
// PodEvent indicates the buffer of pod event
// default 1
PodEvent int32 `json:"podEvent,omitempty"`
@@ -235,12 +229,6 @@ type EdgeControllerBuffer struct {
// SecretEvent indicates the buffer of secret event
// default 1
SecretEvent int32 `json:"secretEvent,omitempty"`
- // ServiceEvent indicates the buffer of service event
- // default 1
- ServiceEvent int32 `json:"serviceEvent,omitempty"`
- // EndpointsEvent indicates the buffer of endpoint event
- // default 1
- EndpointsEvent int32 `json:"endpointsEvent,omitempty"`
// RulesEvent indicates the buffer of rule event
// default 1
RulesEvent int32 `json:"rulesEvent,omitempty"`
@@ -299,12 +287,6 @@ type EdgeControllerLoad struct {
// QuerySecretWorkers indicates the load of query secret workers
// default 4
QuerySecretWorkers int32 `json:"querySecretWorkers,omitempty"`
- // QueryServiceWorkers indicates the load of query service workers
- // default 4
- QueryServiceWorkers int32 `json:"queryServiceWorkers,omitempty"`
- // QueryEndpointsWorkers indicates the load of query endpoint workers
- // default 4
- QueryEndpointsWorkers int32 `json:"queryEndpointsWorkers,omitempty"`
// QueryPersistentVolumeWorkers indicates the load of query persistent volume workers
// default 4
QueryPersistentVolumeWorkers int32 `json:"queryPersistentVolumeWorkers,omitempty"`
generated by cgit v1.2.3 (git 2.52.0) at 2026-01-17 07:52:51 +0000