refactor: move sync related methods as private

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

Hide file tree

Showing 8 changed files with 162 additions and 399 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