@@ -135,7 +135,11 @@ public function remove(?\Manticoresearch\Buddy\Base\Plugin\Sharding\Queue $queue
135
135
* @param string|null $operationGroup
136
136
* @return static
137
137
*/
138
- public function addNodeIds (\Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue , array $ nodeIds , ?string $ operationGroup = null ): static {
138
+ public function addNodeIds (
139
+ \Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue ,
140
+ array $ nodeIds ,
141
+ ?string $ operationGroup = null
142
+ ): static {
139
143
$ this ->cluster ?->addNodeIds($ queue , $ nodeIds , $ operationGroup );
140
144
return $ this ;
141
145
}
@@ -147,7 +151,11 @@ public function addNodeIds(\Manticoresearch\Buddy\Base\Plugin\Sharding\Queue $qu
147
151
* @param string|null $operationGroup
148
152
* @return int
149
153
*/
150
- public function addTables (\Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue , array $ tables , ?string $ operationGroup = null ): int {
154
+ public function addTables (
155
+ \Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue ,
156
+ array $ tables ,
157
+ ?string $ operationGroup = null
158
+ ): int {
151
159
return $ this ->cluster ?->addTables($ queue , $ tables , $ operationGroup ) ?? 0 ;
152
160
}
153
161
@@ -158,7 +166,11 @@ public function addTables(\Manticoresearch\Buddy\Base\Plugin\Sharding\Queue $que
158
166
* @param string|null $operationGroup
159
167
* @return int
160
168
*/
161
- public function removeTables (\Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue , array $ tables , ?string $ operationGroup = null ): int {
169
+ public function removeTables (
170
+ \Manticoresearch \Buddy \Base \Plugin \Sharding \Queue $ queue ,
171
+ array $ tables ,
172
+ ?string $ operationGroup = null
173
+ ): int {
162
174
return $ this ->cluster ?->removeTables($ queue , $ tables , $ operationGroup ) ?? 0 ;
163
175
}
164
176
0 commit comments