refactor: move sync related methods as private

goto · Dec 5, 2023 · ef0115f · ef0115f
1 parent af6c5ce
commit ef0115f
Show file tree

Hide file tree

Showing 9 changed files with 163 additions and 401 deletions.
diff --git a/core/asset/discovery.go b/core/asset/discovery.go
@@ -12,10 +12,7 @@ type DiscoveryRepository interface {
 	Search(ctx context.Context, cfg SearchConfig) (results []SearchResult, err error)
 	Suggest(ctx context.Context, cfg SearchConfig) (suggestions []string, err error)
 	GroupAssets(ctx context.Context, cfg GroupConfig) (results []GroupResult, err error)
-	Clone(ctx context.Context, indexName, clonedIndexName string) error
-	UpdateAlias(ctx context.Context, indexName, alias string) error
-	DeleteByIndexName(ctx context.Context, indexName string) error
-	UpdateIndexSettings(ctx context.Context, indexName string, body string) error
+	SyncAssets(ctx context.Context, indexName string, assets []Asset) error
 }
 
 // GroupConfig represents a group query along

diff --git a/core/asset/mocks/discovery_repository.go b/core/asset/mocks/discovery_repository.go
diff --git a/internal/server/v1beta1/asset.go b/internal/server/v1beta1/asset.go
@@ -347,7 +347,6 @@ func (server *APIServer) CreateAssetProbe(ctx context.Context, req *compassv1bet
 }
 
 func (server *APIServer) SyncAssets(ctx context.Context, req *compassv1beta1.SyncAssetsRequest) (*compassv1beta1.SyncAssetsResponse, error) {
-
 	server.assetService.SyncAssets(ctx, req.GetServices())
 
 	return nil, nil
-Original file line number
+Diff line change
@@ Expand Up @@
     }
     func (server *APIServer) SyncAssets(ctx context.Context, req *compassv1beta1.SyncAssetsRequest) (*compassv1beta1.SyncAssetsResponse, error) {
     	server.assetService.SyncAssets(ctx, req.GetServices())
     	return nil, nil
@@ Expand Down @@