diff --git a/apis/docs/v1/docs.md b/apis/docs/v1/docs.md
index d307aaca6f..14dab54f00 100644
--- a/apis/docs/v1/docs.md
+++ b/apis/docs/v1/docs.md
@@ -1633,8 +1633,7 @@ Represent the index manager service.
| IndexDetail | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.Detail](#payload-v1-Info-Index-Detail) | Represent the RPC to get the index information for each agents. |
| IndexStatistics | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.Statistics](#payload-v1-Info-Index-Statistics) | Represent the RPC to get the index statistics. |
| IndexStatisticsDetail | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.StatisticsDetail](#payload-v1-Info-Index-StatisticsDetail) | Represent the RPC to get the index statistics for each agents. |
-| IndexProperty | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.Property](#payload-v1-Info-Index-Property) | Represent the RPC to get the index property. |
-| IndexPropertyDetail | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.PropertyDetail](#payload-v1-Info-Index-PropertyDetail) | Represent the RPC to get the index properties for each agents. |
+| IndexProperty | [.payload.v1.Empty](#payload-v1-Empty) | [.payload.v1.Info.Index.PropertyDetail](#payload-v1-Info-Index-PropertyDetail) | Represent the RPC to get the index property. |
diff --git a/apis/grpc/v1/payload/payload.pb.go b/apis/grpc/v1/payload/payload.pb.go
index e13b917b96..35ccf90e38 100644
--- a/apis/grpc/v1/payload/payload.pb.go
+++ b/apis/grpc/v1/payload/payload.pb.go
@@ -6679,7 +6679,6 @@ var (
(*status.Status)(nil), // 99: google.rpc.Status
}
)
-
var file_v1_payload_payload_proto_depIdxs = []int32{
21, // 0: payload.v1.Search.Request.config:type_name -> payload.v1.Search.Config
15, // 1: payload.v1.Search.MultiRequest.requests:type_name -> payload.v1.Search.Request
diff --git a/apis/grpc/v1/rpc/errdetails/error_details.pb.go b/apis/grpc/v1/rpc/errdetails/error_details.pb.go
index ff9e1c42cf..1ca92f9554 100644
--- a/apis/grpc/v1/rpc/errdetails/error_details.pb.go
+++ b/apis/grpc/v1/rpc/errdetails/error_details.pb.go
@@ -1108,7 +1108,6 @@ var (
(*durationpb.Duration)(nil), // 15: google.protobuf.Duration
}
)
-
var file_v1_rpc_errdetails_error_details_proto_depIdxs = []int32{
10, // 0: rpc.v1.ErrorInfo.metadata:type_name -> rpc.v1.ErrorInfo.MetadataEntry
15, // 1: rpc.v1.RetryInfo.retry_delay:type_name -> google.protobuf.Duration
diff --git a/apis/grpc/v1/vald/index.pb.go b/apis/grpc/v1/vald/index.pb.go
index 44a723b75c..58728f3ad6 100644
--- a/apis/grpc/v1/vald/index.pb.go
+++ b/apis/grpc/v1/vald/index.pb.go
@@ -46,7 +46,7 @@ var file_v1_vald_index_proto_rawDesc = []byte{
0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74,
0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x18, 0x76, 0x31,
0x2f, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2f, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
- 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xdc, 0x04, 0x0a, 0x05, 0x49, 0x6e, 0x64, 0x65, 0x78,
+ 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xf1, 0x03, 0x0a, 0x05, 0x49, 0x6e, 0x64, 0x65, 0x78,
0x12, 0x51, 0x0a, 0x09, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x11, 0x2e,
0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
0x1a, 0x1c, 0x2e, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x49, 0x6e,
@@ -71,26 +71,19 @@ var file_v1_vald_index_proto_rawDesc = []byte{
0x64, 0x65, 0x78, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x69, 0x73, 0x74, 0x69, 0x63, 0x73, 0x44, 0x65,
0x74, 0x61, 0x69, 0x6c, 0x22, 0x20, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1a, 0x12, 0x18, 0x2f, 0x69,
0x6e, 0x64, 0x65, 0x78, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x69, 0x73, 0x74, 0x69, 0x63, 0x73, 0x2f,
- 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x5c, 0x0a, 0x0d, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x50,
+ 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x62, 0x0a, 0x0d, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x50,
0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x12, 0x11, 0x2e, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61,
- 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x1f, 0x2e, 0x70, 0x61, 0x79,
+ 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x25, 0x2e, 0x70, 0x61, 0x79,
0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x49, 0x6e, 0x66, 0x6f, 0x2e, 0x49, 0x6e, 0x64,
- 0x65, 0x78, 0x2e, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x22, 0x17, 0x82, 0xd3, 0xe4,
- 0x93, 0x02, 0x11, 0x12, 0x0f, 0x2f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x2f, 0x70, 0x72, 0x6f, 0x70,
- 0x65, 0x72, 0x74, 0x79, 0x12, 0x6f, 0x0a, 0x13, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x50, 0x72, 0x6f,
- 0x70, 0x65, 0x72, 0x74, 0x79, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x11, 0x2e, 0x70, 0x61,
- 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x25,
- 0x2e, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x49, 0x6e, 0x66, 0x6f,
- 0x2e, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x2e, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x44,
- 0x65, 0x74, 0x61, 0x69, 0x6c, 0x22, 0x1e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x18, 0x12, 0x16, 0x2f,
- 0x69, 0x6e, 0x64, 0x65, 0x78, 0x2f, 0x70, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x2f, 0x64,
- 0x65, 0x74, 0x61, 0x69, 0x6c, 0x42, 0x52, 0x0a, 0x1a, 0x6f, 0x72, 0x67, 0x2e, 0x76, 0x64, 0x61,
- 0x61, 0x73, 0x2e, 0x76, 0x61, 0x6c, 0x64, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x31, 0x2e, 0x76,
- 0x61, 0x6c, 0x64, 0x42, 0x09, 0x56, 0x61, 0x6c, 0x64, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x50, 0x01,
- 0x5a, 0x27, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x76, 0x64, 0x61,
- 0x61, 0x73, 0x2f, 0x76, 0x61, 0x6c, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x67, 0x72, 0x70,
- 0x63, 0x2f, 0x76, 0x31, 0x2f, 0x76, 0x61, 0x6c, 0x64, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
- 0x33,
+ 0x65, 0x78, 0x2e, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x44, 0x65, 0x74, 0x61, 0x69,
+ 0x6c, 0x22, 0x17, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x11, 0x12, 0x0f, 0x2f, 0x69, 0x6e, 0x64, 0x65,
+ 0x78, 0x2f, 0x70, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x42, 0x52, 0x0a, 0x1a, 0x6f, 0x72,
+ 0x67, 0x2e, 0x76, 0x64, 0x61, 0x61, 0x73, 0x2e, 0x76, 0x61, 0x6c, 0x64, 0x2e, 0x61, 0x70, 0x69,
+ 0x2e, 0x76, 0x31, 0x2e, 0x76, 0x61, 0x6c, 0x64, 0x42, 0x09, 0x56, 0x61, 0x6c, 0x64, 0x49, 0x6e,
+ 0x64, 0x65, 0x78, 0x50, 0x01, 0x5a, 0x27, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f,
+ 0x6d, 0x2f, 0x76, 0x64, 0x61, 0x61, 0x73, 0x2f, 0x76, 0x61, 0x6c, 0x64, 0x2f, 0x61, 0x70, 0x69,
+ 0x73, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x76, 0x31, 0x2f, 0x76, 0x61, 0x6c, 0x64, 0x62, 0x06,
+ 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var file_v1_vald_index_proto_goTypes = []any{
@@ -99,8 +92,7 @@ var file_v1_vald_index_proto_goTypes = []any{
(*payload.Info_Index_Detail)(nil), // 2: payload.v1.Info.Index.Detail
(*payload.Info_Index_Statistics)(nil), // 3: payload.v1.Info.Index.Statistics
(*payload.Info_Index_StatisticsDetail)(nil), // 4: payload.v1.Info.Index.StatisticsDetail
- (*payload.Info_Index_Property)(nil), // 5: payload.v1.Info.Index.Property
- (*payload.Info_Index_PropertyDetail)(nil), // 6: payload.v1.Info.Index.PropertyDetail
+ (*payload.Info_Index_PropertyDetail)(nil), // 5: payload.v1.Info.Index.PropertyDetail
}
var file_v1_vald_index_proto_depIdxs = []int32{
@@ -109,15 +101,13 @@ var file_v1_vald_index_proto_depIdxs = []int32{
0, // 2: vald.v1.Index.IndexStatistics:input_type -> payload.v1.Empty
0, // 3: vald.v1.Index.IndexStatisticsDetail:input_type -> payload.v1.Empty
0, // 4: vald.v1.Index.IndexProperty:input_type -> payload.v1.Empty
- 0, // 5: vald.v1.Index.IndexPropertyDetail:input_type -> payload.v1.Empty
- 1, // 6: vald.v1.Index.IndexInfo:output_type -> payload.v1.Info.Index.Count
- 2, // 7: vald.v1.Index.IndexDetail:output_type -> payload.v1.Info.Index.Detail
- 3, // 8: vald.v1.Index.IndexStatistics:output_type -> payload.v1.Info.Index.Statistics
- 4, // 9: vald.v1.Index.IndexStatisticsDetail:output_type -> payload.v1.Info.Index.StatisticsDetail
- 5, // 10: vald.v1.Index.IndexProperty:output_type -> payload.v1.Info.Index.Property
- 6, // 11: vald.v1.Index.IndexPropertyDetail:output_type -> payload.v1.Info.Index.PropertyDetail
- 6, // [6:12] is the sub-list for method output_type
- 0, // [0:6] is the sub-list for method input_type
+ 1, // 5: vald.v1.Index.IndexInfo:output_type -> payload.v1.Info.Index.Count
+ 2, // 6: vald.v1.Index.IndexDetail:output_type -> payload.v1.Info.Index.Detail
+ 3, // 7: vald.v1.Index.IndexStatistics:output_type -> payload.v1.Info.Index.Statistics
+ 4, // 8: vald.v1.Index.IndexStatisticsDetail:output_type -> payload.v1.Info.Index.StatisticsDetail
+ 5, // 9: vald.v1.Index.IndexProperty:output_type -> payload.v1.Info.Index.PropertyDetail
+ 5, // [5:10] is the sub-list for method output_type
+ 0, // [0:5] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
diff --git a/apis/grpc/v1/vald/index_vtproto.pb.go b/apis/grpc/v1/vald/index_vtproto.pb.go
index 572af108a9..e0d8f29f68 100644
--- a/apis/grpc/v1/vald/index_vtproto.pb.go
+++ b/apis/grpc/v1/vald/index_vtproto.pb.go
@@ -51,9 +51,7 @@ type IndexClient interface {
// Represent the RPC to get the index statistics for each agents.
IndexStatisticsDetail(ctx context.Context, in *payload.Empty, opts ...grpc.CallOption) (*payload.Info_Index_StatisticsDetail, error)
// Represent the RPC to get the index property.
- IndexProperty(ctx context.Context, in *payload.Empty, opts ...grpc.CallOption) (*payload.Info_Index_Property, error)
- // Represent the RPC to get the index properties for each agents.
- IndexPropertyDetail(ctx context.Context, in *payload.Empty, opts ...grpc.CallOption) (*payload.Info_Index_PropertyDetail, error)
+ IndexProperty(ctx context.Context, in *payload.Empty, opts ...grpc.CallOption) (*payload.Info_Index_PropertyDetail, error)
}
type indexClient struct {
@@ -110,20 +108,9 @@ func (c *indexClient) IndexStatisticsDetail(
func (c *indexClient) IndexProperty(
ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
-) (*payload.Info_Index_Property, error) {
- out := new(payload.Info_Index_Property)
- err := c.cc.Invoke(ctx, "/vald.v1.Index/IndexProperty", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *indexClient) IndexPropertyDetail(
- ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
) (*payload.Info_Index_PropertyDetail, error) {
out := new(payload.Info_Index_PropertyDetail)
- err := c.cc.Invoke(ctx, "/vald.v1.Index/IndexPropertyDetail", in, out, opts...)
+ err := c.cc.Invoke(ctx, "/vald.v1.Index/IndexProperty", in, out, opts...)
if err != nil {
return nil, err
}
@@ -143,9 +130,7 @@ type IndexServer interface {
// Represent the RPC to get the index statistics for each agents.
IndexStatisticsDetail(context.Context, *payload.Empty) (*payload.Info_Index_StatisticsDetail, error)
// Represent the RPC to get the index property.
- IndexProperty(context.Context, *payload.Empty) (*payload.Info_Index_Property, error)
- // Represent the RPC to get the index properties for each agents.
- IndexPropertyDetail(context.Context, *payload.Empty) (*payload.Info_Index_PropertyDetail, error)
+ IndexProperty(context.Context, *payload.Empty) (*payload.Info_Index_PropertyDetail, error)
mustEmbedUnimplementedIndexServer()
}
@@ -178,14 +163,8 @@ func (UnimplementedIndexServer) IndexStatisticsDetail(
func (UnimplementedIndexServer) IndexProperty(
context.Context, *payload.Empty,
-) (*payload.Info_Index_Property, error) {
- return nil, status.Errorf(codes.Unimplemented, "method IndexProperty not implemented")
-}
-
-func (UnimplementedIndexServer) IndexPropertyDetail(
- context.Context, *payload.Empty,
) (*payload.Info_Index_PropertyDetail, error) {
- return nil, status.Errorf(codes.Unimplemented, "method IndexPropertyDetail not implemented")
+ return nil, status.Errorf(codes.Unimplemented, "method IndexProperty not implemented")
}
func (UnimplementedIndexServer) mustEmbedUnimplementedIndexServer() {}
@@ -300,26 +279,6 @@ func _Index_IndexProperty_Handler(
return interceptor(ctx, in, info, handler)
}
-func _Index_IndexPropertyDetail_Handler(
- srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
-) (any, error) {
- in := new(payload.Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(IndexServer).IndexPropertyDetail(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/vald.v1.Index/IndexPropertyDetail",
- }
- handler := func(ctx context.Context, req any) (any, error) {
- return srv.(IndexServer).IndexPropertyDetail(ctx, req.(*payload.Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
// Index_ServiceDesc is the grpc.ServiceDesc for Index service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
@@ -347,10 +306,6 @@ var Index_ServiceDesc = grpc.ServiceDesc{
MethodName: "IndexProperty",
Handler: _Index_IndexProperty_Handler,
},
- {
- MethodName: "IndexPropertyDetail",
- Handler: _Index_IndexPropertyDetail_Handler,
- },
},
Streams: []grpc.StreamDesc{},
Metadata: "v1/vald/index.proto",
diff --git a/apis/grpc/v1/vald/vald.go b/apis/grpc/v1/vald/vald.go
index 0463c83b25..3ff180c0e8 100644
--- a/apis/grpc/v1/vald/vald.go
+++ b/apis/grpc/v1/vald/vald.go
@@ -140,7 +140,6 @@ const (
IndexStatisticsRPCName = "IndexStatistics"
IndexStatisticsDetailRPCName = "IndexStatisticsDetail"
IndexPropertyRPCName = "IndexProperty"
- IndexPropertyDetailRPCName = "IndexPropertyDetail"
)
type client struct {
diff --git a/apis/proto/v1/vald/index.proto b/apis/proto/v1/vald/index.proto
index 72ba71fd4b..4360dc9bbb 100644
--- a/apis/proto/v1/vald/index.proto
+++ b/apis/proto/v1/vald/index.proto
@@ -47,12 +47,7 @@ service Index {
}
// Represent the RPC to get the index property.
- rpc IndexProperty(payload.v1.Empty) returns (payload.v1.Info.Index.Property) {
+ rpc IndexProperty(payload.v1.Empty) returns (payload.v1.Info.Index.PropertyDetail) {
option (google.api.http).get = "/index/property";
}
-
- // Represent the RPC to get the index properties for each agents.
- rpc IndexPropertyDetail(payload.v1.Empty) returns (payload.v1.Info.Index.PropertyDetail) {
- option (google.api.http).get = "/index/property/detail";
- }
}
diff --git a/apis/swagger/v1/vald/index.swagger.json b/apis/swagger/v1/vald/index.swagger.json
index 4fe1e9ec63..b8032366d5 100644
--- a/apis/swagger/v1/vald/index.swagger.json
+++ b/apis/swagger/v1/vald/index.swagger.json
@@ -58,27 +58,6 @@
"get": {
"summary": "Represent the RPC to get the index property.",
"operationId": "Index_IndexProperty",
- "responses": {
- "200": {
- "description": "A successful response.",
- "schema": {
- "$ref": "#/definitions/IndexProperty"
- }
- },
- "default": {
- "description": "An unexpected error response.",
- "schema": {
- "$ref": "#/definitions/rpcStatus"
- }
- }
- },
- "tags": ["Index"]
- }
- },
- "/index/property/detail": {
- "get": {
- "summary": "Represent the RPC to get the index properties for each agents.",
- "operationId": "Index_IndexPropertyDetail",
"responses": {
"200": {
"description": "A successful response.",
diff --git a/internal/client/v1/client/vald/vald.go b/internal/client/v1/client/vald/vald.go
index 8f8ad0c5ef..8b0578ce8b 100644
--- a/internal/client/v1/client/vald/vald.go
+++ b/internal/client/v1/client/vald/vald.go
@@ -830,7 +830,7 @@ func (c *client) IndexStatisticsDetail(
func (c *client) IndexProperty(
ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
-) (res *payload.Info_Index_Property, err error) {
+) (res *payload.Info_Index_PropertyDetail, err error) {
ctx, span := trace.StartSpan(grpc.WrapGRPCMethod(ctx, "internal/client/"+vald.IndexPropertyRPCName), apiName+"/"+vald.IndexPropertyRPCName)
defer func() {
if span != nil {
@@ -850,28 +850,6 @@ func (c *client) IndexProperty(
return res, nil
}
-func (c *client) IndexPropertyDetail(
- ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
-) (res *payload.Info_Index_PropertyDetail, err error) {
- ctx, span := trace.StartSpan(grpc.WrapGRPCMethod(ctx, "internal/client/"+vald.IndexPropertyDetailRPCName), apiName+"/"+vald.IndexPropertyDetailRPCName)
- defer func() {
- if span != nil {
- span.End()
- }
- }()
- _, err = c.c.RoundRobin(ctx, func(ctx context.Context,
- conn *grpc.ClientConn,
- copts ...grpc.CallOption,
- ) (any, error) {
- res, err = vald.NewValdClient(conn).IndexPropertyDetail(ctx, in, append(copts, opts...)...)
- return nil, err
- })
- if err != nil {
- return nil, err
- }
- return res, nil
-}
-
func (c *client) GetTimestamp(
ctx context.Context, in *payload.Object_TimestampRequest, opts ...grpc.CallOption,
) (res *payload.Object_Timestamp, err error) {
@@ -1316,7 +1294,7 @@ func (c *singleClient) IndexStatisticsDetail(
func (c *singleClient) IndexProperty(
ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
-) (res *payload.Info_Index_Property, err error) {
+) (res *payload.Info_Index_PropertyDetail, err error) {
ctx, span := trace.StartSpan(grpc.WrapGRPCMethod(ctx, "internal/singleClient/"+vald.IndexPropertyRPCName), apiName+"/"+vald.IndexPropertyRPCName)
defer func() {
if span != nil {
@@ -1326,18 +1304,6 @@ func (c *singleClient) IndexProperty(
return c.vc.IndexProperty(ctx, in, opts...)
}
-func (c *singleClient) IndexPropertyDetail(
- ctx context.Context, in *payload.Empty, opts ...grpc.CallOption,
-) (res *payload.Info_Index_PropertyDetail, err error) {
- ctx, span := trace.StartSpan(grpc.WrapGRPCMethod(ctx, "internal/client/"+vald.IndexPropertyDetailRPCName), apiName+"/"+vald.IndexPropertyDetailRPCName)
- defer func() {
- if span != nil {
- span.End()
- }
- }()
- return c.vc.IndexPropertyDetail(ctx, in, opts...)
-}
-
func (c *singleClient) GetTimestamp(
ctx context.Context, in *payload.Object_TimestampRequest, opts ...grpc.CallOption,
) (res *payload.Object_Timestamp, err error) {
diff --git a/rust/libs/proto/src/vald.v1.tonic.rs b/rust/libs/proto/src/vald.v1.tonic.rs
index 563b4e793a..9c856bfd0d 100644
--- a/rust/libs/proto/src/vald.v1.tonic.rs
+++ b/rust/libs/proto/src/vald.v1.tonic.rs
@@ -1838,33 +1838,6 @@ pub mod index_client {
pub async fn index_property(
&mut self,
request: impl tonic::IntoRequest,
- ) -> std::result::Result<
- tonic::Response,
- tonic::Status,
- > {
- self.inner
- .ready()
- .await
- .map_err(|e| {
- tonic::Status::new(
- tonic::Code::Unknown,
- format!("Service was not ready: {}", e.into()),
- )
- })?;
- let codec = tonic::codec::ProstCodec::default();
- let path = http::uri::PathAndQuery::from_static(
- "/vald.v1.Index/IndexProperty",
- );
- let mut req = request.into_request();
- req.extensions_mut()
- .insert(GrpcMethod::new("vald.v1.Index", "IndexProperty"));
- self.inner.unary(req, path, codec).await
- }
- /** Represent the RPC to get the index properties for each agents.
-*/
- pub async fn index_property_detail(
- &mut self,
- request: impl tonic::IntoRequest,
) -> std::result::Result<
tonic::Response<
super::super::super::payload::v1::info::index::PropertyDetail,
@@ -1882,11 +1855,11 @@ pub mod index_client {
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
- "/vald.v1.Index/IndexPropertyDetail",
+ "/vald.v1.Index/IndexProperty",
);
let mut req = request.into_request();
req.extensions_mut()
- .insert(GrpcMethod::new("vald.v1.Index", "IndexPropertyDetail"));
+ .insert(GrpcMethod::new("vald.v1.Index", "IndexProperty"));
self.inner.unary(req, path, codec).await
}
}
@@ -1937,15 +1910,6 @@ pub mod index_server {
async fn index_property(
&self,
request: tonic::Request,
- ) -> std::result::Result<
- tonic::Response,
- tonic::Status,
- >;
- /** Represent the RPC to get the index properties for each agents.
-*/
- async fn index_property_detail(
- &self,
- request: tonic::Request,
) -> std::result::Result<
tonic::Response<
super::super::super::payload::v1::info::index::PropertyDetail,
@@ -2236,7 +2200,7 @@ pub mod index_server {
> tonic::server::UnaryService<
super::super::super::payload::v1::Empty,
> for IndexPropertySvc {
- type Response = super::super::super::payload::v1::info::index::Property;
+ type Response = super::super::super::payload::v1::info::index::PropertyDetail;
type Future = BoxFuture<
tonic::Response,
tonic::Status,
@@ -2277,55 +2241,6 @@ pub mod index_server {
};
Box::pin(fut)
}
- "/vald.v1.Index/IndexPropertyDetail" => {
- #[allow(non_camel_case_types)]
- struct IndexPropertyDetailSvc(pub Arc);
- impl<
- T: Index,
- > tonic::server::UnaryService<
- super::super::super::payload::v1::Empty,
- > for IndexPropertyDetailSvc {
- type Response = super::super::super::payload::v1::info::index::PropertyDetail;
- type Future = BoxFuture<
- tonic::Response,
- tonic::Status,
- >;
- fn call(
- &mut self,
- request: tonic::Request<
- super::super::super::payload::v1::Empty,
- >,
- ) -> Self::Future {
- let inner = Arc::clone(&self.0);
- let fut = async move {
- ::index_property_detail(&inner, request).await
- };
- Box::pin(fut)
- }
- }
- let accept_compression_encodings = self.accept_compression_encodings;
- let send_compression_encodings = self.send_compression_encodings;
- let max_decoding_message_size = self.max_decoding_message_size;
- let max_encoding_message_size = self.max_encoding_message_size;
- let inner = self.inner.clone();
- let fut = async move {
- let inner = inner.0;
- let method = IndexPropertyDetailSvc(inner);
- let codec = tonic::codec::ProstCodec::default();
- let mut grpc = tonic::server::Grpc::new(codec)
- .apply_compression_config(
- accept_compression_encodings,
- send_compression_encodings,
- )
- .apply_max_message_size_config(
- max_decoding_message_size,
- max_encoding_message_size,
- );
- let res = grpc.unary(method, req).await;
- Ok(res)
- };
- Box::pin(fut)
- }
_ => {
Box::pin(async move {
Ok(