From 0b9622c418d89d76e9b82ac1fa4969d2b2087a79 Mon Sep 17 00:00:00 2001
From: Evgenii Stratonikov <e.stratonikov@yadro.com>
Date: Fri, 7 Apr 2023 14:21:05 +0300
Subject: [PATCH] [#191] control: Add Doctor RPC

Doctor RPC performs complex operations on the storage engine.
Currently only duplicate removal is supported.

Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
---
 pkg/services/control/convert.go            |  18 ++++++++++
 pkg/services/control/rpc.go                |  14 ++++++++
 pkg/services/control/server/doctor.go      |  37 +++++++++++++++++++++
 pkg/services/control/service.pb.go         | Bin 111752 -> 121755 bytes
 pkg/services/control/service.proto         |  28 ++++++++++++++++
 pkg/services/control/service_frostfs.pb.go | Bin 52798 -> 57948 bytes
 pkg/services/control/service_grpc.pb.go    | Bin 18217 -> 20760 bytes
 7 files changed, 97 insertions(+)
 create mode 100644 pkg/services/control/server/doctor.go

diff --git a/pkg/services/control/convert.go b/pkg/services/control/convert.go
index 833288bb..f7582dd6 100644
--- a/pkg/services/control/convert.go
+++ b/pkg/services/control/convert.go
@@ -200,3 +200,21 @@ func (w *flushCacheResponseWrapper) FromGRPCMessage(m grpc.Message) error {
 	w.FlushCacheResponse = r
 	return nil
 }
+
+type doctorResponseWrapper struct {
+	*DoctorResponse
+}
+
+func (w *doctorResponseWrapper) ToGRPCMessage() grpc.Message {
+	return w.DoctorResponse
+}
+
+func (w *doctorResponseWrapper) FromGRPCMessage(m grpc.Message) error {
+	r, ok := m.(*DoctorResponse)
+	if !ok {
+		return message.NewUnexpectedMessageType(m, (*DoctorResponse)(nil))
+	}
+
+	w.DoctorResponse = r
+	return nil
+}
diff --git a/pkg/services/control/rpc.go b/pkg/services/control/rpc.go
index 0779e177..2676ea7a 100644
--- a/pkg/services/control/rpc.go
+++ b/pkg/services/control/rpc.go
@@ -18,6 +18,7 @@ const (
 	rpcSynchronizeTree = "SynchronizeTree"
 	rpcEvacuateShard   = "EvacuateShard"
 	rpcFlushCache      = "FlushCache"
+	rpcDoctor          = "Doctor"
 )
 
 // HealthCheck executes ControlService.HealthCheck RPC.
@@ -191,3 +192,16 @@ func FlushCache(cli *client.Client, req *FlushCacheRequest, opts ...client.CallO
 
 	return wResp.FlushCacheResponse, nil
 }
+
+// Doctor executes ControlService.Doctor RPC.
+func Doctor(cli *client.Client, req *DoctorRequest, opts ...client.CallOption) (*DoctorResponse, error) {
+	wResp := &doctorResponseWrapper{new(DoctorResponse)}
+	wReq := &requestWrapper{m: req}
+
+	err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceName, rpcDoctor), wReq, wResp, opts...)
+	if err != nil {
+		return nil, err
+	}
+
+	return wResp.DoctorResponse, nil
+}
diff --git a/pkg/services/control/server/doctor.go b/pkg/services/control/server/doctor.go
new file mode 100644
index 00000000..2c91d4c2
--- /dev/null
+++ b/pkg/services/control/server/doctor.go
@@ -0,0 +1,37 @@
+package control
+
+import (
+	"context"
+
+	"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/engine"
+	"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/services/control"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func (s *Server) Doctor(ctx context.Context, req *control.DoctorRequest) (*control.DoctorResponse, error) {
+	err := s.isValidRequest(req)
+	if err != nil {
+		return nil, status.Error(codes.PermissionDenied, err.Error())
+	}
+
+	if !req.Body.RemoveDuplicates {
+		return nil, status.Error(codes.InvalidArgument, "operation not specified")
+	}
+
+	var prm engine.RemoveDuplicatesPrm
+	prm.Concurrency = int(req.Body.Concurrency)
+
+	err = s.s.RemoveDuplicates(ctx, prm)
+	if err != nil {
+		return nil, status.Error(codes.Internal, err.Error())
+	}
+
+	resp := &control.DoctorResponse{Body: &control.DoctorResponse_Body{}}
+
+	err = SignMessage(s.key, resp)
+	if err != nil {
+		return nil, status.Error(codes.Internal, err.Error())
+	}
+	return resp, nil
+}
diff --git a/pkg/services/control/service.pb.go b/pkg/services/control/service.pb.go
index 78e7b0598d93a7a763bfc152815feab18749387b..ca3e2770e1425432e663a12d4763d7420d57f637 100644
GIT binary patch
delta 6014
zcma(#X;@TOmftC;DypbrQ3Mfz0$kXw<xvF~1*5hLvWUAzk>w#MR6$h{MNlA<m`pk@
z<f^A*I)El=lSzxDs}sM^Xj~?fWYQDG#F_5QM8!mG)7>hjC!P6BC(OC;)k9q7`-UHn
zbI(2dc5mJ1zR|pVOxtJN9y7;P>2<kHZn3dR^msG%-sT3;BqLdG{y(tZx?qieIpD5i
z)9aTj%R8&16%gzdOl+%GmX_ItYDp|xub!+R?-bXti|yBy<(F&C3V3j1eWcaAO}|aA
zuWoWynv%DeQvE6|5fKVi`Q`-*cspm^#1Xqa4KAlgyx;JHK~Il1yj)kzGClF5jW17%
z@tattuVl^7jMzSFL6Lvs?MYMpP~-So_U9cVrr()qQ7kDjIwP%?N18r7CDPAs5f>`-
zeYP^6ar-J@Q+A20TRVpJYt?LL?_AavY-I64YH2;Q9ofO%gY1$<-hcK)itlbmdjPx0
zMBkNXjKE6w@m(Y9dn%aCJe$Jqb{Ku}&uKMm%1a{4WZ~@ePCbd8&&=aPBsg!kmJJ_|
zVrx5NUpzn>Z>?r~4_s%bqGeLjz=r*B=IhnIg3f<bv9VoTRvf!^cs9!zAH_=cYT50s
ziL5?692>g8z_!0p&YtNWBq@ATEm<-w!CKaKw#xU@{$v$<?vTieCK*{<oEp2kLBn?S
z&S8Iish9ottAoru#mH7q)U#(#q_X-chI>TQUKf3iUw#R!;V@?(%l0Iy*`BWNXdTFe
zg<ttL^~9=JSg*+1Qp4HsK`q<eJDYuDHei_u!L01neY6?Kb{xIR)}(U+weR+89V({z
zE$1+>fnOQPuRE;eok1cn`1;?>3uH;ht6!WE!rG4*NZPmTh4-$r_3wsY-fN)uwe{@?
zVE=K72qIYibT#|S;knG@2w{Ei8hKD&d}k|r{LFRV`gcDFU_<{RvY98NSkLjB1P8L}
zkFNUMC&U2u!SDD+Fe{p`VMV93Qe<~62$$far}wg)PX~R;XFm>L?_Cht6UAeh>7UiC
z>-b!Ddl{wi!$Zve`5?<%Ea81+ACtt_e$NR**!d;Fl1aChMd0}wit??lSoZ$EwXno5
zIEPF?mEv1}ZcPAlT@rn!&mw_cyFAD~T^ot{Z-JVUkm4)5I5&XVz80D3vvAf|rtz8n
zpaS;RHBKfWnCTC4qRTESYo2V;cm6+nRP4YFk;QF_VDST5@_sh^q(+7dFC)|ZX^`z1
z3}x*#YT8$`vX4`I!2`(wtof$Mb~(q%cHcZahqyvn&sS1h*|ck|?8dD@-=0BTfJ!j4
z#=}*<;Tsy@FwDHhoUI0CxWOwZg&Btoc)Nl;3HwINS}%&e!+*X&gci=khHn^H-!=^!
zy7@gv$-HA|DZ67FdX}XgOYnE>(Dk2Z7d6#ah;Eas+T^Wqi{(`wlh<Wx@`$Et8kgQ0
z(d23n-R0g|mornZo9%K|Ho4uRv$C1xel;~|WR>3Fc6nX4MAJr(%bA;4If}0BgUH1s
z(j%6;D{D-mb3?6D7GBlVP*+=7?j;o!8^ubm$5igDGS!LYPZGvi*GwPLROxDHCdH*<
zz3WMFj>6$#!!IPwb4$pw5jmc8u6>4#zDN6jZ4Ys=#$QbE2c&anoHD{phc>7LE03vy
z>F8aofV)3SRlxZ7>OtUhOhL4qu=}MsFS@g==5*5|XMU-C5|usfs%lO#%@e(&WBdH|
z<OL(K)$6wDb#Bqy<aV0Ok2pOZlJr2ZSllO*!ydqSSm$r-ip8CuFa>OX#pE|W{Fxf^
z%d$*Vwyqp5RltF+bU#(Y8%~vAW0r-3euU+$L)kj(QCTg%7lwr8X;v#mVM}EW|C%k*
zw_N&G@vk88uf1CO?k|NX95g@-Udn_>m9?7P`TG*wI}c`<Mw8h%u|vV=b+oYJRRd&V
zNC;%8^g6r{0Ml8+Pm?$tJ`tv4j}|6jTN3CoXAI<EekjCYUpOS;o}YnQm6e5O9*4|O
zDPdd8<>_3exq>bJE^>-p)|Msdlw5I0U%P~{i<03s7W!j6W~M+eRAGh{qS?CdbZ!4X
zR!OiF9g9^`Y^~rZvVy)ADPZ?$l)@$l%wd<bOO|BGA(W!xkT4MrUVmHcmC{$zV7FoX
zV-Tfs*f1YpGVY!Zx&n(t_DCI4Y)2`Pvn7jvr1ZrOh)j1#A(Qj&khIIrm_^CIhf^-5
zK`8boLUN#)D6l6DvR?c?MrEnQ^?{VU{u0n=N0$iETQEPIGi8Gr`(r_UELsZ!;4M3(
zCfVeQb8x@SlJz6{2_x9Jj)Pj5f<g0O9DD!HxN#JDzLPC+DCx)6`7oJ1_SXd5MRZsn
zNCnnD9}=)`9wf4tzc-?3KA5n-2qv+vZ=<lJkPf9)-&<MHUt{sWB1pmCE`jm*yJFB`
z`$Ev*`wQS_n6Q*2&;=)vwf`7{p(>)tTL1=LjZrNB?`k&mg9cCPK`TrD%Tgl9D1_wu
z$Tj<3B>{fQ1Pq-+(n|!;1&?w8jRh3Da|INol?96Z6iO|+G?0$-3m^<H6+p)Q4q(9|
z^65kYNWIg!h(x@#g4*Wyi(mrY3WG!(QwTAv{f9}oeklav=V8>X4TaQB14c69sE%kU
zED`(71We;z^Y-0e1QDp2K-^ahFc$mgLrSPnAytDvHI;a#n08_!s5?I`qKJL<803=A
zV=yj)jCaNI){UW(m14f57{>5~WMSU|2<9XSyw&p~Xnw@5f(&;0ZyKCi0^>L~FAl62
zw;Z&P!{F{@*84w^yriaLUlL5@@`CWoQi#Ru#pHQ=Ao)YPI?h>MLV-G!L<wt9!5EHd
zC?aF3(;x)b$B_4Cs#KN5ih1*47G|WA+0Ha_S=kHWEC)+z77hJqz=5R@s<KpJ`xNNp
zA+V}>eO6=HQYh2;d*4z`CR)%uhO+kjG}6_!6f|5)(K2%OR3^mjH-dp9G8V!@PEx@|
zMc_aZrL#>%%1<sM*A_YC1l|dyJ@S33>{#py*|Av;Sc2_wRCY9I!|}hClb`v85Q%Xs
z$hGC!Q23zKLn}zef|at=utJEX5=h3&D~bGezHHHj6%@aQl@LQFhT+LV(k%7NKt2^&
zXuj;nz-;n^N;T3dHRgS@fH&r-!A{YUhmzc#7P}G}oiq`GXd-ZWyK-uzY2}gWAiA-<
zXHpEx89}0CGHKFKdZ=BBU}B&^eUHVfU>1*P=PHOL5Bg|nk_?e2yd*=Ahp04-?VKrm
zHO!hIsh4#~v{q>b^TEjSzMUr}KMc~3U0n@Nt5iY?hOC8*V|&-afZBhWV#zwnasOHf
zOf&JnY12$rb1q$coL;x9E>r#i=s)B2x@7-PMl4=WL*Y~{d2ziGLKRsxl_03Bxmdo5
z`s{Qiq=F4i>!`4Us=%TWa&c%Y#N%qd$dVQlSbww@d#h-Kw$M)syz2xb{;dk^;J_g#
zwRC|9X2`}_F6xtCa5#s<kvLRFs?7~FN<ypXF4}Y?63<mZu$s)bnK67T>CdT#G?mT5
z7vovCPlHcagN6Dq-%b5hzkz!0i)u(F3kgB@VmE1?w1G?(aKJ;(oo)p+ws}YcVZ->{
zA8%LtHDqy;c#PvhqG}+VHCznl`hzrFzdaYvcxkqet08F)%&&n`a^Z9Zoyl}9$GQ#F
zq{nMWbq+_yV=PAm*TPh~ZevF+dDp#}`eJ!4q|harW0arwc%}-X%}SmG>;I9bOn$2y
zm8^~pFg`}&;^`G^53=FDTFBw)xlm6XbFG%l&ce`*@Hp79l>c+!zKxJaPW<~uSV1Ao
z*aRzrsOm_XMauR>)HOmHn(IMB+fvHk<Y6vu=4o07MxEa#LBPy9D5fB9uY)rBce#$D
zlZBRgDECWrjH(Q}-KJ@&O-WHUFNi1%bV4q%<vF1Uuec~Xd!4Y95Z^eVgbd7e!E#!4
zx}b={JK%zqik(@b3g?LiNYmM<Nw@=cULkSV+W=V#twTnUPpLsR>Nrk@3F|3=ypC2k
zf<vLqxmR8(n;|`j8k2~vX1U5@o}?qo<c9HDIapSN4G_8CO+h*00jpe$QtfGR*dx;h
z^HL1qk#Um`0%mw%wO^Z6sylya{@MfS6u2)u@PxAMkjwH3FL@^i&6+LMB8?O;Wb-I_
zVF_h(MiW%fs;3E-2GNa!EVfzi73hQ~NBpzd?xDHDAiBeGYC*2tpFEV~pW3N?GQ1Gv
zH^Y`CZ?55H2y&2Z_L0KYVDo0Mk@h2-p)f$Oq+@0+HFxwDn647iv89%-#HpJhHJVRG
z(j`1Jjj(YuBxc+<nMSHhX0bd};m`=yXu5Yv5+CXtJm`i=8Pa1~spx;|l6#1s4%~=`
zdnSRr&<Qkj`L-a}{J(C2>>xSvLY9o0(hS);KNSrIX#nnM21^j#4LPS{R9VtIQ{zB0
zq-f=&2)yRvFmo#nsgGKyJX*HG3^cV;(3fqe1McgsQ~+MSw6)O2IS&22h2ofH!;&_d
zK(|_?NcXowG)`{?YSpbIWp^v&Q)d&ljB3HW4c1^Im;U-T5On+p2-%gD!}pb^M?AU>
zqN47LxL!wn!71&S&`QidY=gZ0?XqR_Ncwq>JhmP3RCME)3?R#babg=-Rd#`!w??*x
z?9$_TLdzyabMuUt+zwe}95JTgv+dN_l7(Ni!yIaBNt~kt>_Jw!IUU>v|5GE*>VWaF
zimh@o^*X!k)*8Dx*I~i8JLpWp4hS*G^}I&N$+ep~I&~CA$l;hs{E<G7M(Z)}DHul<
zak^uho&xW9<tXfa4$k4pm!UvGSoXnr{Npd70IwW?D>$x;E>8r}o81lrp6`K=aCSGL
z%DU({p@&5*d<8znx*i#I4fh`;XlFNZzJExDj5v)BLH=fUEdEs(12}LHE@R_Mv`dhI
zt+NFqZG42&e?>}7J7Fw4dPI#k-ype_hlz?%{Ao?n{vkg922mY3Oz(QPjt67+5n_Dj
zO`;;yWgPe?f{u2Q2zo5Tt|KJE_-jH9zX?}y`VoRs--55Px|g84j69%MEqcV#aK}Ex
z&Z8u{uNRbODUB@tcpp&{`YH_r({6&lJPMciiI=b&7Vw1u!`_A-9NIxOBUm|lq5SI}
dXT1WS(=Y$gs53oq2>afKn;;zP`VIUE{ujNd+SdR8

delta 3502
zcmYjUd05nS8h_rIodafuVE{!CX*5??B$yL~<j~f2%L9wjU9`Y-5HXHIU9nVrJWvif
zUh<7YW>B|X6%}@BdD2XD^Gw3*FrO4@+i}yj#PZq4){1?<zu$=b1HbR*y*}^t{r#r7
zOSA2!y2G#@U)6?r8@JB@RF}EXtqH-48WmRGoq_JkL%3k053i|ZEbE&|Sb+xbhUyX}
zp4cLk4RpO5^jKVX7e|x}O#{Bypu<J?CwVI{OpSdNE-WyO#Nb8^nwx&aIaNM99$~_=
zU=?F36fOsc&Khra%eM;rzE&8Susc$RJ?@`zX}!;Txb3zATN_<Cu+M<OfBqRGntf=Q
zVDJvUS*5_)ZkLw@fag5|4aM4VDw?f^7%Z3&Qom1wt@oFD+uE}MTlczfLyQUC2UQr|
zGy}U2wWHxpA5MK+?|r_bQh}BGgn}N^>}nkFYOvS+1S{#OcMInk?-_%A-ctN|zt21M
z?ODIV!GpQ=DM1*2Opi5ppFneBX#EilRt`pC*^yF~s<8O*m)`3~Tb20lzp-i<ra!LY
zq<)Wcj_A;mrk2iep0POa&cpLBKQ6}kZ{5J_M}sh<TPi1--whhlZ@HiAZ9J(|;<k5O
zSbZ*Bifz20!^h6)Irtc?IlUVHcf^OD9<JcYK=0t0c}iS=+=a)UG@<!|oR#rHJO0q^
z^Ll#DDzW913kyGulsw&jE(qP92v1R%b7?KA&iK5?KVGNAj1PoTkoWLq1>n&OK1_Q$
z2zxVi-osZmD>3gQ7yh!;gr2K%F<M`gpM{&^MI$k&PmkS$S$O5r4cy=pvOw>l>xD|3
zdRZ8TWA#5Z=>F<Hc7E>jZt&$P(SFT^!MBY#a8veJBt4t3b}$@g-yH3o+s9L@y<_yw
z`(~jMqrP%^gKvidHvP-z)!qqE;*GC!amQLc_T3fs-{HbrH?Z(Ey|?JU8x^?!J0T3A
z{!c-Tg+JcGaRWjcg0=TlJir}Y_tX$OUu(C;nk{RlETNy4LIh=I!bD1O!3afQ09n>T
z7%g*wQN<dT7YTA<CY@v<^_k!q>NkLqzRraZnw1MN!XP~#9;E>j#89^$^kmKjwSe0K
z7-pS7>K+A?C~g@9r~?DoWiIuH!XvaV7^Vun#$~J*91XvrgLxczFcenMk~|nq!4sKP
zP6?=Y7P8wbAuwNf3KBNck|2@_ToB;r_`!1KShZZ{7)KYE%W5_G;H2oWOu@1S%)_}x
z2^|S(6YN=MJUy}uj3$Ru6vnbRR-(E%)=bt3kV-RGFroE%Oj0)<l7y$RYrszTRzNH@
z`~iXmoF?3a(781bMV^-+0L*mYC3u`}#6gt8YNOPA_%-E3Ks2qJ3@?*$6=>+a0tlkk
zIB<yMwUlpRL1`i9p)CTt&MI}un#5$NQwLM1b`7XWR|I3J+R8zDGr=HI8&3sA9IYso
zBR^0{p|~Y15JV`V7!oAT<2mOCOt@pCXlxRMQ+yPtD7_dg<XOcIFHUAA^NL{15W6@s
zr!dwuo!NONFa>VrD9SBip82yNTDWd5VFJy|m>IWHLS86g4=kQeM`O7E!K*mP@;o--
zzD84SHuG<Ng{xXT3lap6Wct1YCJJAjb2!z^mE3(PqcSm_$5yh@iUMxsH9Jfe-eT!?
zA(L;P%N4B2WIn7iUUqaZA42KYDhLza23NtOI_{~zn2YHn6Ig{HXEk>|djYpB?N6Lj
z%W5_sT*)rEt5a$DYI%mtS@1_Kn>%cx3pdxmG&)-fBLiJxP7<WnJXH$QIQ!~S7$Z%%
zEtgECyjH9?p2FjKUw$eDqX?;A%jUPVOtvEmMs~fr7B(xu^7nNRq$b+L)AjN?F51;i
zV5PO2Ku5ExxE~!&{AAe-v0$T&^)OnzW@z1Ju<`&N-VDzu9Le<24j4z5H-ix^?RrYz
z0!E(vd0SvE*VerSW<#R*H<J2m*`aYOOk!Vm>L3EM6IHZeD_9h^Bx<XJQG7G2DXpGI
z^Uzk_=%lS2`#?RI=q@WUt+smZU<a~%S~&wYI#JHqSQ>akXO=@S9=@!nUp7IYDn8z9
zw+m?o54UL>JWbsjnd6+DY+AVuVwl)sVghA(DjF2v7XnNapqcv1dEDZ*!$hThN;0Lt
z!DCgrT?|npUmVX?FkK7hT+P=-Qw3XD=~M+wXENGK9=GHQ=6tJ}|KwD%&_R`zus~sn
zrGj<rN7KMFXRd-s9{0zqV6Mg*Yi6!CnpVZF=UQ{-Rp8WEB-lO-)>gx04R0iCJ03P7
zs~VF0%Fc)Ak!pz5*d^Tr(WG%?+yO}(^2r^L$&_~OfCXAPM3U6KD9W#e$y&aB*uB*v
zdKXPcYWbSW+5(XZhlSiVFprBiPy_S*mR7rHs^2nEwsZ{jStHCH9P)N8%%$&YxS})a
z;8_Nm>L5e(`<psg^uX1y?ibYaZl%`oO1SH}d+eYd=5UQua453PJ~Rk6e@Sfgayd8W
z-Fl|n+rT@?Ghtxk)CQ()r<w*>#Har>z|)+5>g$lhC->`+Njn<&ePOrIiH+Qy(K{j8
zPswhTq4hg?@)PL5&LOfqS3{%o7_l^wvIt&yVCVGD5b^8DK85se!2AGzHxs2{8cpXK
zAtunCB$doRVI#=1hf{v1md9h@4QV`djga9V4~N)H-r6Qe9U6i3DjCsJL^Ig5@*Fva
z?Py6eSheyHIHXod`=_IxW|*XPNWmQrv31cD)dDu&*v>tCZRE8;io%f~AG%v$hQg63
z4v{o=7r!zcQ)J2PHlFZJyLcBINiy=`E=Z?0TOe}hZoVgf>*jsWDuWOu-+TnSxH+%2
zLOO4W6y>v4_#M5qi@heed3PK#TJHvjk~5*_TUno(=xMqK><Xu!POS%KDx7{gKX@Qj
z;e1FZMd5tN#6Tx^bA2|{fkC=cuC_6!jy+sm*v&7+)gF$_d<?W?H#mop3Kn)#$krw^
z3lj2hY9_vR=I(*O2Si`l0|^GFye<o!&g29q_3!0`NAHCZdOz%NCOiG`GkYOy80_%F
z-FqQ$)XLIgS9amz0#{&wc>DAIEo94KDvyA(i=9`DqV~UtY$|kg>=QUmsqeuo0fp8F
zsVMb4oS_$vGjj2-AbuLCspx%%wspf(0+K%bWv$K=tW|c3T^aZ4WUcEbS&N~5GQ7`E
z`%gn3C7hC<<gau}JI^7rPqS%n2Z)bzKa27+G9-P3ivVY-^DJA=`v9)d7w6<B9Ukb>
zb+Ir6$lb$X9=pJT?6)BdJ3iwJUyy&UhoOUA%+zyLN5K~v+VG(ag;Uab=%M|+e9X86
zU()4^@{<ug1!~N><9DID#PElo^3=p1<=1`McHStdRPi4(NfxxzKR$<V!P3=v1#ZFr
E0keSKw*UYD

diff --git a/pkg/services/control/service.proto b/pkg/services/control/service.proto
index 5a09a74a..7c661e66 100644
--- a/pkg/services/control/service.proto
+++ b/pkg/services/control/service.proto
@@ -37,6 +37,9 @@ service ControlService {
 
     // FlushCache moves all data from one shard to the others.
     rpc FlushCache (FlushCacheRequest) returns (FlushCacheResponse);
+
+    // Doctor performs storage restructuring operations on engine.
+    rpc Doctor (DoctorRequest) returns (DoctorResponse);
 }
 
 // Health check request.
@@ -345,3 +348,28 @@ message FlushCacheResponse {
     Body body = 1;
     Signature signature = 2;
 }
+
+
+// Doctor request.
+message DoctorRequest {
+    // Request body structure.
+    message Body {
+        // Number of threads to use for the operation.
+        uint32 concurrency = 1;
+        // Flag to search engine for duplicate objects and leave only one copy.
+        bool remove_duplicates = 2;
+    }
+
+    Body body = 1;
+    Signature signature = 2;
+}
+
+// Doctor response.
+message DoctorResponse {
+    // Response body structure.
+    message Body {
+    }
+
+    Body body = 1;
+    Signature signature = 2;
+}
diff --git a/pkg/services/control/service_frostfs.pb.go b/pkg/services/control/service_frostfs.pb.go
index 5bb119090d82b4052d96ca47ada2250c22ff8da9..0f50d58933d2e7b995ee9b8322a6ccf5f04c8e31 100644
GIT binary patch
delta 264
zcmdlthxyJC<_&h|CSNG*V$Dx3$uF9GP+Vm4`lZT~w`>sN%u6mUDoV{uuAKaFsk}f?
zYHog6s!M4>PG)jqNow)tjmlFP*<4`S)=!q&tjqz^GCA;|$mD=}p2@o<gfVnZo|p`j
zJl+b`yjh_^j0wi(pFRb~p6n-g7iNBeTON%0Fy<Ic@rT*F;V$?vTXb@R*;a@*Hrty^
bFhQA#meZij$&5Dlq25gF&xaZ^>6{$^!su&c

delta 9
Qcmca}gn8c_<_&h|02tr|y#N3J

diff --git a/pkg/services/control/service_grpc.pb.go b/pkg/services/control/service_grpc.pb.go
index 2cfddd7f57c2371a832755a5ac9f25f7e74d1eaf..4a4fbeac1f727cc433a38e8d9ebaf1a9c4a87956 100644
GIT binary patch
delta 1551
zcmZ44$2emV<AgXy<BjpB899^l^NLFpG`Kh?zgL$QaVyQq@l7qs$WQT0%uQ7Q0o%zF
zd88)Ca`P|&)ih|y3!te1$!me+G<EUlf6EKjU*{qvil!f739nCPaY=ASVo^%5641Px
zE;7QHYC+b?PR<tK0$F*-L{bb>3Ea^QW?)r`=C}-!ntWe~7i7>|SFHY$o~$pz50YPK
zBP)bq5hP?PMEO7}?CkOQ%*HLJv^c{#F*zeuiHp-YKd+=HKPNb~s4O!%HQpsZxg@_R
z9>aKWz(B*F6QW3oOLOu;N8!omxY;&4GS#q8c3@?3hDa$Cq!y*+7v&Z!6a!65OixuP
zN-ZuaDorjaEy~PGSI7s-CzfOaV_P9VPa!ogJu@#=j|*z<WJMM!Hi$WsFLJ0rnVZ*e
z&R_&33qDl0P2Ml&H@SgdY4T0(ouCwfU0Qy!2JaeBqQE7c#<yZJFg;+GJ`ak1>{9ZR
z9|<f0MLjNQF`*5UfpLyqT48dO@NQ6iW0#hnyjo-nD7tY;e->Q<ifbIwut3Bbo|7GU
z<lzdql~ssI2b=ecrLs{ingeBo#Uarglv-E{OdpyG8d?y6&BC&roRj;NHDNBqqjqwm
zqBl$#qoU|$8MPE<Z0Y2KL-}SIEk-76i3BJ&`GB_Q=1V#+7_p@iklrx;PmI`-2uSY-
z1A)z-4WBV$OD7=tdSju@9VYh~u_Y9cynq@1W&!i3jM!2NNPf13(B>tU9~rSF6_C7z
zwdiIqn|F-Z(h5lauC4Iqmv)aCu_cxd4wom}8;Qb#Fu`a#jG1U#17n`o_9H5VOa|H}
u0f|G6<dO;<V7@QZgT?A(d2^f1haCl2Cr@w|hM6qrqRa{|b0!~lO9KFbbtxnO

delta 453
zcmbQSh;d~f<AgXyqmA*W8JYC;C*NZe-^|BW#lBgKubpx7A!f<RHB3B{4Fq#1y9?|A
z@@07aQcH3Z3xZ1$OG=BCHX8^^LX_z-LzLYYS^?6=?UPwt5}c7(lv1n&)-EHm0Vu8p
zWamvz5nT*Y!{t(%TL4xAQ8HT$q(pLZ2MaG)%Oi1+jZ*xTdC3_?`FWXDsUbzFsSvdm
zl3OM#v8sdBwMap%bjv9%&Tvjl&H$_N+k9F^oNaT8@(+&9(z+?kV532vS!i3nS>BM5
z2`C^l*~M32@)FyU%}0#?BK)z?wqkOosletUvxi_o6wd&)PyTH#u$js78AwtMWZvXH
zE1}J^t?z?XBYA7{LfdSRJrF;EEMDut3=+Wf6i70}87K+z70AdxF2b96+#W+5fb2D}
ReI7BJ6TJmkCm#w30{~nCq(cAz