Skip to content

Commit dddd899

Browse files
committed
make the go compile
1 parent e66d300 commit dddd899

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

go/pkg/sysdb/coordinator/coordinator.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ func (s *Coordinator) GetCollectionWithSegments(ctx context.Context, collectionI
123123
return s.catalog.GetCollectionWithSegments(ctx, collectionID, false)
124124
}
125125

126-
func (s *Coordinator) CheckCollection(ctx context.Context, collectionID types.UniqueID) (bool, error) {
126+
func (s *Coordinator) CheckCollection(ctx context.Context, collectionID types.UniqueID) (bool, int64, error) {
127127
return s.catalog.CheckCollection(ctx, collectionID)
128128
}
129129

go/pkg/sysdb/coordinator/table_catalog.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ func (tc *Catalog) CreateCollection(ctx context.Context, createCollection *model
403403

404404
// Returns true if collection is deleted (either soft-deleted or hard-deleted)
405405
// and false otherwise.
406-
func (tc *Catalog) CheckCollection(ctx context.Context, collectionID types.UniqueID) (bool, error) {
406+
func (tc *Catalog) CheckCollection(ctx context.Context, collectionID types.UniqueID) (bool, int64, error) {
407407
tracer := otel.Tracer
408408
if tracer != nil {
409409
_, span := tracer.Start(ctx, "Catalog.CheckCollection")
@@ -412,7 +412,7 @@ func (tc *Catalog) CheckCollection(ctx context.Context, collectionID types.Uniqu
412412

413413
collectionInfo, err := tc.metaDomain.CollectionDb(ctx).GetCollectionWithoutMetadata(types.FromUniqueID(collectionID), nil, nil)
414414
if err != nil {
415-
return false, err
415+
return false, 0, err
416416
}
417417
// Collection is hard deleted.
418418
if collectionInfo == nil {

go/pkg/sysdb/grpc/collection_service.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ func (s *Server) CheckCollections(ctx context.Context, req *coordinatorpb.CheckC
261261
}
262262

263263
res.Deleted[i] = deleted
264-
res.LogPosition[i] = logPosition,
264+
res.LogPosition[i] = logPosition
265265
}
266266
return res, nil
267267
}

0 commit comments

Comments
 (0)