Skip to content

Commit 28f7212

Browse files
committed
[ReplicatedLoglet] Remote append
Summary: Implements a remote loglet append calls to leader sequencer
1 parent e072b0a commit 28f7212

File tree

5 files changed

+648
-8
lines changed

5 files changed

+648
-8
lines changed

crates/bifrost/src/loglet/mod.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,10 @@ impl LogletCommitResolver {
168168
pub fn offset(self, offset: LogletOffset) {
169169
let _ = self.tx.send(Ok(offset));
170170
}
171+
172+
pub fn error(self, err: AppendError) {
173+
let _ = self.tx.send(Err(err));
174+
}
171175
}
172176

173177
pub struct LogletCommit {

crates/bifrost/src/providers/replicated_loglet/loglet.rs

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,22 @@ impl<T: TransportConnect> ReplicatedLoglet<T> {
109109
log_server_manager,
110110
})
111111
}
112+
113+
pub fn networking(&self) -> &Networking<T> {
114+
&self.networking
115+
}
116+
117+
pub fn params(&self) -> &ReplicatedLogletParams {
118+
&self.my_params
119+
}
120+
121+
pub fn log_id(&self) -> LogId {
122+
self.log_id
123+
}
124+
125+
pub fn segment_index(&self) -> SegmentIndex {
126+
self.segment_index
127+
}
112128
}
113129

114130
#[derive(derive_more::Debug, derive_more::IsVariant)]

0 commit comments

Comments
 (0)