fix test

Author: AlinsRan

internal/adc/client/client.go

@@ -74,7 +74,7 @@ func (d *Client) Insert(ctx context.Context, args Task) error {
 
 func (d *Client) Remove(ctx context.Context, args Task) error {
 	for _, config := range args.Configs {
-		if err := d.Store.Delete(config.Name, args.ResourceTypes, args.Labels); err != nil {
+		if err := d.Delete(config.Name, args.ResourceTypes, args.Labels); err != nil {
 			log.Errorw("failed to delete resources from store",
 				zap.String("name", config.Name),
 				zap.Error(err),
@@ -102,7 +102,7 @@ func (c *Client) Sync(ctx context.Context, cfg map[string]adctypes.Config) (map[
 	failedMap := map[string]types.ADCExecutionErrors{}
 	var failedConfigs []string
 	for name, config := range cfg {
-		resources, err := c.Store.GetResources(name)
+		resources, err := c.GetResources(name)
 		if err != nil {
 			log.Errorw("failed to get resources from store", zap.String("name", name), zap.Error(err))
 			failedConfigs = append(failedConfigs, name)
@@ -183,7 +183,7 @@ func (c *Client) sync(ctx context.Context, task Task) error {
 				resourceType = "all"
 			}
 
-			err = c.executor.Execute(ctx, "", config, args)
+			err = c.executor.Execute(ctx, c.BackendMode, config, args)
 			duration := time.Since(startTime).Seconds()
 
 			status := "success"
@@ -231,7 +231,7 @@ func (c *Client) sync(ctx context.Context, task Task) error {
 			resourceType = "all"
 		}
 
-		err := c.executor.Execute(ctx, "", config, args)
+		err := c.executor.Execute(ctx, c.BackendMode, config, args)
 		duration := time.Since(startTime).Seconds()
 
 		status := "success"

internal/provider/api7ee/provider.go

@@ -57,7 +57,7 @@ type api7eeProvider struct {
 
 	provider.Options
 
-	configManager common.ConfigManager[adctypes.Config]
+	configManager *common.ConfigManager[adctypes.Config]
 
 	client *adcclient.Client
 }
@@ -75,12 +75,13 @@ func New(updater status.Updater, readier readiness.ReadinessManager, opts ...pro
 	}
 
 	return &api7eeProvider{
-		client:     cli,
-		Options:    o,
-		translator: &translator.Translator{},
-		updater:    updater,
-		readier:    readier,
-		syncCh:     make(chan struct{}, 1),
+		client:        cli,
+		Options:       o,
+		translator:    &translator.Translator{},
+		configManager: common.NewConfigManager[adctypes.Config](),
+		updater:       updater,
+		readier:       readier,
+		syncCh:        make(chan struct{}, 1),
 	}, nil
 }
 

internal/provider/apisix/provider.go

@@ -59,7 +59,7 @@ type apisixProvider struct {
 
 	syncCh chan struct{}
 
-	configManager common.ConfigManager[adctypes.Config]
+	configManager *common.ConfigManager[adctypes.Config]
 
 	client *adcclient.Client
 }
@@ -77,12 +77,13 @@ func New(updater status.Updater, readier readiness.ReadinessManager, opts ...pro
 	}
 
 	return &apisixProvider{
-		client:     cli,
-		Options:    o,
-		translator: &translator.Translator{},
-		updater:    updater,
-		readier:    readier,
-		syncCh:     make(chan struct{}, 1),
+		client:        cli,
+		Options:       o,
+		translator:    &translator.Translator{},
+		updater:       updater,
+		configManager: common.NewConfigManager[adctypes.Config](),
+		readier:       readier,
+		syncCh:        make(chan struct{}, 1),
 	}, nil
 }