From 9af6c16ea081f89bf04e565a01279ea104d42966 Mon Sep 17 00:00:00 2001 From: foxspy Date: Wed, 11 Jun 2025 15:26:38 +0800 Subject: [PATCH] fix: add describeIndex timestamp for restful interface (#42104) issue: #41431 Signed-off-by: xianliang.li --- internal/distributed/proxy/httpserver/handler_v2.go | 3 +++ internal/distributed/proxy/httpserver/request_v2.go | 9 ++++++++- 2 files changed, 11 insertions(+), 1 deletion(-) diff --git a/internal/distributed/proxy/httpserver/handler_v2.go b/internal/distributed/proxy/httpserver/handler_v2.go index 2258920db3..4669fe0e63 100644 --- a/internal/distributed/proxy/httpserver/handler_v2.go +++ b/internal/distributed/proxy/httpserver/handler_v2.go @@ -2240,10 +2240,13 @@ func (h *HandlersV2) listIndexes(ctx context.Context, c *gin.Context, anyReq any func (h *HandlersV2) describeIndex(ctx context.Context, c *gin.Context, anyReq any, dbName string) (interface{}, error) { collectionGetter, _ := anyReq.(requestutil.CollectionNameGetter) indexGetter, _ := anyReq.(IndexNameGetter) + timeGetter, _ := anyReq.(TimestampGetter) + req := &milvuspb.DescribeIndexRequest{ DbName: dbName, CollectionName: collectionGetter.GetCollectionName(), IndexName: indexGetter.GetIndexName(), + Timestamp: timeGetter.GetTimestamp(), } c.Set(ContextRequest, req) diff --git a/internal/distributed/proxy/httpserver/request_v2.go b/internal/distributed/proxy/httpserver/request_v2.go index ceb85179ac..3a46f9710f 100644 --- a/internal/distributed/proxy/httpserver/request_v2.go +++ b/internal/distributed/proxy/httpserver/request_v2.go @@ -354,7 +354,9 @@ type OptionsGetter interface { type JobIDGetter interface { GetJobID() string } - +type TimestampGetter interface { + GetTimestamp() uint64 +} type PasswordReq struct { UserName string `json:"userName" binding:"required"` Password string `json:"password" binding:"required"` @@ -424,6 +426,7 @@ type IndexReq struct { DbName string `json:"dbName"` CollectionName string `json:"collectionName" binding:"required"` IndexName string `json:"indexName" binding:"required"` + Timestamp uint64 `json:"timestamp"` } func (req *IndexReq) GetDbName() string { return req.DbName } @@ -435,6 +438,10 @@ func (req *IndexReq) GetIndexName() string { return req.IndexName } +func (req *IndexReq) GetTimestamp() uint64 { + return req.Timestamp +} + type IndexReqWithProperties struct { DbName string `json:"dbName"` CollectionName string `json:"collectionName" binding:"required"`