Skip to content

Commit

Permalink
[ISSUE #2243]🚀ReplicasManager add shutdown method
Browse files Browse the repository at this point in the history
  • Loading branch information
mxsm committed Jan 15, 2025
1 parent c19a3b9 commit bf68676
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion rocketmq-broker/src/controller/replicas_manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
use tracing::warn;

#[derive(Default)]
pub struct ReplicasManager {}

impl ReplicasManager {
pub fn start(&mut self) {}
pub fn start(&mut self) {
warn!("ReplicasManager started not implemented");
}

Check warning on line 25 in rocketmq-broker/src/controller/replicas_manager.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/controller/replicas_manager.rs#L23-L25

Added lines #L23 - L25 were not covered by tests

pub fn shutdown(&mut self) {
warn!("ReplicasManager shutdown not implemented");
}

Check warning on line 29 in rocketmq-broker/src/controller/replicas_manager.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/controller/replicas_manager.rs#L27-L29

Added lines #L27 - L29 were not covered by tests
}

0 comments on commit bf68676

Please # to comment.