Skip to content

Commit 6a1bee2

Browse files
authored
Merge pull request #26 from ilikepi63/chore/refactor-file-naming
chore: Refactor File Naming
2 parents 214e29e + 348cc1c commit 6a1bee2

File tree

9 files changed

+285
-285
lines changed

9 files changed

+285
-285
lines changed
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@
33
44
#![allow(dead_code)]
55

6+
pub mod simple;
7+
68
use std::collections::HashSet;
79
use std::vec::Vec;
810

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
mod index;
2+
3+
use index::Index;
14
use std::{
25
collections::HashSet,
36
fs::{File, OpenOptions},
@@ -10,7 +13,7 @@ use uuid::Uuid;
1013

1114
use crate::{
1215
batch_coordinator::BatchInfo, error::RisklessResult,
13-
messages::commit_batch_request::CommitBatchRequest, simple_batch_coordinator::index::Index,
16+
messages::commit_batch_request::CommitBatchRequest,
1417
};
1518

1619
use crate::batch_coordinator::{
@@ -264,7 +267,7 @@ impl BatchCoordinator for SimpleBatchCoordinator {
264267

265268
/// No-op as this operation is not supported in the SimpleBatchCoordinator.
266269
async fn delete_files(&self, _request: DeleteFilesRequest) {}
267-
270+
268271
/// Always returns false.
269272
async fn is_safe_to_delete_file(&self, _object_key: String) -> bool {
270273
false

src/broker.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use crate::{
1414
produce_request::{ProduceRequest, ProduceRequestCollection},
1515
produce_response::ProduceResponse,
1616
},
17-
segment::SharedLogSegment,
17+
shared_log_segment::SharedLogSegment,
1818
utils::request_response::Request,
1919
};
2020

src/lib.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,7 @@ pub mod batch_coordinator;
66
mod utils;
77
mod broker;
88
pub mod messages;
9-
mod segment;
10-
pub mod simple_batch_coordinator;
9+
mod shared_log_segment;
1110

1211
pub use broker::{Broker, BrokerConfiguration};
1312
pub mod error;

src/segment.rs

Lines changed: 0 additions & 275 deletions
This file was deleted.

0 commit comments

Comments
 (0)