Fix format

apis/grpc/v1/agent/core/agent_vtproto.pb.go

@@ -135,10 +135,7 @@ func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer) {
 }
 
 func _Agent_CreateIndex_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Control_CreateIndexRequest)
 	if err := dec(in); err != nil {
@@ -158,10 +155,7 @@ func _Agent_CreateIndex_Handler(
 }
 
 func _Agent_SaveIndex_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Empty)
 	if err := dec(in); err != nil {
@@ -181,10 +175,7 @@ func _Agent_SaveIndex_Handler(
 }
 
 func _Agent_CreateAndSaveIndex_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Control_CreateIndexRequest)
 	if err := dec(in); err != nil {

apis/grpc/v1/discoverer/discoverer_vtproto.pb.go

@@ -137,10 +137,7 @@ func RegisterDiscovererServer(s grpc.ServiceRegistrar, srv DiscovererServer) {
 }
 
 func _Discoverer_Pods_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Discoverer_Request)
 	if err := dec(in); err != nil {
@@ -160,10 +157,7 @@ func _Discoverer_Pods_Handler(
 }
 
 func _Discoverer_Nodes_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Discoverer_Request)
 	if err := dec(in); err != nil {
@@ -183,10 +177,7 @@ func _Discoverer_Nodes_Handler(
 }
 
 func _Discoverer_Services_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Discoverer_Request)
 	if err := dec(in); err != nil {

apis/grpc/v1/filter/egress/egress_filter_vtproto.pb.go

@@ -117,10 +117,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) {
 }
 
 func _Filter_FilterDistance_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_Distance)
 	if err := dec(in); err != nil {
@@ -140,10 +137,7 @@ func _Filter_FilterDistance_Handler(
 }
 
 func _Filter_FilterVector_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_Vector)
 	if err := dec(in); err != nil {

apis/grpc/v1/filter/ingress/ingress_filter_vtproto.pb.go

@@ -117,10 +117,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) {
 }
 
 func _Filter_GenVector_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_Blob)
 	if err := dec(in); err != nil {
@@ -140,10 +137,7 @@ func _Filter_GenVector_Handler(
 }
 
 func _Filter_FilterVector_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_Vector)
 	if err := dec(in); err != nil {

apis/grpc/v1/mirror/mirror_vtproto.pb.go

@@ -97,10 +97,7 @@ func RegisterMirrorServer(s grpc.ServiceRegistrar, srv MirrorServer) {
 }
 
 func _Mirror_Register_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Mirror_Targets)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/filter_vtproto.pb.go

@@ -397,10 +397,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) {
 }
 
 func _Filter_SearchObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Search_ObjectRequest)
 	if err := dec(in); err != nil {
@@ -420,10 +417,7 @@ func _Filter_SearchObject_Handler(
 }
 
 func _Filter_MultiSearchObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Search_MultiObjectRequest)
 	if err := dec(in); err != nil {
@@ -469,10 +463,7 @@ func (x *filterStreamSearchObjectServer) Recv() (*payload.Search_ObjectRequest,
 }
 
 func _Filter_InsertObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Insert_ObjectRequest)
 	if err := dec(in); err != nil {
@@ -518,10 +509,7 @@ func (x *filterStreamInsertObjectServer) Recv() (*payload.Insert_ObjectRequest,
 }
 
 func _Filter_MultiInsertObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Insert_MultiObjectRequest)
 	if err := dec(in); err != nil {
@@ -541,10 +529,7 @@ func _Filter_MultiInsertObject_Handler(
 }
 
 func _Filter_UpdateObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Update_ObjectRequest)
 	if err := dec(in); err != nil {
@@ -590,10 +575,7 @@ func (x *filterStreamUpdateObjectServer) Recv() (*payload.Update_ObjectRequest,
 }
 
 func _Filter_MultiUpdateObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Update_MultiObjectRequest)
 	if err := dec(in); err != nil {
@@ -613,10 +595,7 @@ func _Filter_MultiUpdateObject_Handler(
 }
 
 func _Filter_UpsertObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Upsert_ObjectRequest)
 	if err := dec(in); err != nil {
@@ -662,10 +641,7 @@ func (x *filterStreamUpsertObjectServer) Recv() (*payload.Upsert_ObjectRequest,
 }
 
 func _Filter_MultiUpsertObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Upsert_MultiObjectRequest)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/flush_vtproto.pb.go

@@ -97,10 +97,7 @@ func RegisterFlushServer(s grpc.ServiceRegistrar, srv FlushServer) {
 }
 
 func _Flush_Flush_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Flush_Request)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/index_vtproto.pb.go

@@ -117,10 +117,7 @@ func RegisterIndexServer(s grpc.ServiceRegistrar, srv IndexServer) {
 }
 
 func _Index_IndexInfo_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Empty)
 	if err := dec(in); err != nil {
@@ -140,10 +137,7 @@ func _Index_IndexInfo_Handler(
 }
 
 func _Index_IndexDetail_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Empty)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/insert_vtproto.pb.go

@@ -157,10 +157,7 @@ func RegisterInsertServer(s grpc.ServiceRegistrar, srv InsertServer) {
 }
 
 func _Insert_Insert_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Insert_Request)
 	if err := dec(in); err != nil {
@@ -206,10 +203,7 @@ func (x *insertStreamInsertServer) Recv() (*payload.Insert_Request, error) {
 }
 
 func _Insert_MultiInsert_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Insert_MultiRequest)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/object_vtproto.pb.go

@@ -220,10 +220,7 @@ func RegisterObjectServer(s grpc.ServiceRegistrar, srv ObjectServer) {
 }
 
 func _Object_Exists_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_ID)
 	if err := dec(in); err != nil {
@@ -243,10 +240,7 @@ func _Object_Exists_Handler(
 }
 
 func _Object_GetObject_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_VectorRequest)
 	if err := dec(in); err != nil {
@@ -313,10 +307,7 @@ func (x *objectStreamListObjectServer) Send(m *payload.Object_List_Response) err
 }
 
 func _Object_GetTimestamp_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Object_TimestampRequest)
 	if err := dec(in); err != nil {

apis/grpc/v1/vald/remove_vtproto.pb.go

@@ -177,10 +177,7 @@ func RegisterRemoveServer(s grpc.ServiceRegistrar, srv RemoveServer) {
 }
 
 func _Remove_Remove_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Remove_Request)
 	if err := dec(in); err != nil {
@@ -200,10 +197,7 @@ func _Remove_Remove_Handler(
 }
 
 func _Remove_RemoveByTimestamp_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Remove_TimestampRequest)
 	if err := dec(in); err != nil {
@@ -249,10 +243,7 @@ func (x *removeStreamRemoveServer) Recv() (*payload.Remove_Request, error) {
 }
 
 func _Remove_MultiRemove_Handler(
-	srv any,
-	ctx context.Context,
-	dec func(any) error,
-	interceptor grpc.UnaryServerInterceptor,
+	srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor,
 ) (any, error) {
 	in := new(payload.Remove_MultiRequest)
 	if err := dec(in); err != nil {