Reduce egress gateway agent event

Signed-off-by: lou-lan <[email protected]>

Author: lou-lan

pkg/agent/agent.go

@@ -28,7 +28,7 @@ type Agent struct {
 }
 
 func New(cfg *config.Config) (types.Service, error) {
-	syncPeriod := time.Second * 15
+	syncPeriod := time.Second * time.Duration(cfg.FileConfig.CacheSyncSyncPeriodSecond)
 	log := logger.NewLogger(cfg.EnvConfig.Logger)
 	t := time.Duration(0)
 	mgrOpts := manager.Options{

pkg/agent/vxlan.go

@@ -81,12 +81,6 @@ func (r *vxlanReconciler) Reconcile(ctx context.Context, req reconcile.Request)
 		return r.reconcileEgressTunnel(ctx, newReq, log)
 	case "EgressGateway":
 		return r.reconcileEgressGateway(ctx, newReq, log)
-	case "EgressEndpointSlice":
-		// return r.reconcileEgressEndpointSlice(ctx, newReq, log)
-		return reconcile.Result{}, nil
-	case "EgressClusterEndpointSlice":
-		// return r.reconcileEgressClusterEndpointSlice(ctx, newReq, log)
-		return reconcile.Result{}, nil
 	default:
 		return reconcile.Result{}, nil
 	}
@@ -638,27 +632,12 @@ func newEgressTunnelController(mgr manager.Manager, cfg *config.Config, log logr
 
 	sourceEgressGateway := utils.SourceKind(mgr.GetCache(),
 		&egressv1.EgressGateway{},
-		handler.EnqueueRequestsFromMapFunc(utils.KindToMapFlat("EgressGateway")))
+		handler.EnqueueRequestsFromMapFunc(utils.KindToMapFlat("EgressGateway")),
+	)
 	if err := c.Watch(sourceEgressGateway); err != nil {
 		return fmt.Errorf("failed to watch EgressGateway: %w", err)
 	}
 
-	sourceEgressEndpointSlice := utils.SourceKind(mgr.GetCache(),
-		&egressv1.EgressEndpointSlice{},
-		handler.EnqueueRequestsFromMapFunc(utils.KindToMapFlat("EgressEndpointSlice")),
-		epSlicePredicate{})
-	if err := c.Watch(sourceEgressEndpointSlice); err != nil {
-		return fmt.Errorf("failed to watch EgressEndpointSlice: %w", err)
-	}
-
-	sourceEgressClusterEndpointSlice := utils.SourceKind(mgr.GetCache(),
-		&egressv1.EgressClusterEndpointSlice{},
-		handler.EnqueueRequestsFromMapFunc(utils.KindToMapFlat("EgressClusterEndpointSlice")),
-		epSlicePredicate{})
-	if err := c.Watch(sourceEgressClusterEndpointSlice); err != nil {
-		return fmt.Errorf("failed to watch EgressClusterEndpointSlice: %w", err)
-	}
-
 	go r.keepVXLAN()
 
 	return nil

pkg/config/config.go

@@ -84,6 +84,7 @@ type FileConfig struct {
 	GatewayReplyRouteTable       int             `yaml:"gatewayReplyRouteTable"`
 	GatewayReplyRouteMark        int             `yaml:"gatewayReplyRouteMark"`
 	GatewayFailover              GatewayFailover `yaml:"gatewayFailover"`
+	CacheSyncSyncPeriodSecond    int             `json:"cacheSyncSyncPeriodSecond "`
 }
 
 type GatewayFailover struct {
@@ -163,6 +164,7 @@ func LoadConfig(isAgent bool) (*Config, error) {
 				TunnelUpdatePeriod:  5,
 				EipEvictionTimeout:  15,
 			},
+			CacheSyncSyncPeriodSecond: 1800,
 		},
 	}
 

pkg/controller/endpoint/endpoint_slice.go

@@ -6,7 +6,6 @@ package endpoint
 import (
 	"context"
 	"fmt"
-	"github.com/spidernet-io/egressgateway/pkg/utils"
 	"net"
 	"reflect"
 	"sort"
@@ -32,6 +31,7 @@ import (
 	"github.com/spidernet-io/egressgateway/pkg/coalescing"
 	"github.com/spidernet-io/egressgateway/pkg/config"
 	"github.com/spidernet-io/egressgateway/pkg/k8s/apis/v1beta1"
+	"github.com/spidernet-io/egressgateway/pkg/utils"
 )
 
 type endpointReconciler struct {