Skip to content

Commit

Permalink
M examples/raft-kv-memstore-grpc/src/pb_impl/impl_entry.rs
Browse files Browse the repository at this point in the history
  • Loading branch information
drmingdrmer committed Jan 26, 2025
1 parent 7f0ded0 commit 1b66a64
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 19 deletions.
4 changes: 0 additions & 4 deletions examples/raft-kv-memstore-grpc/src/pb_impl/impl_entry.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,6 @@ impl fmt::Display for pb::Entry {
}

impl RaftPayload<TypeConfig> for pb::Entry {
fn app_data(&self) -> Option<&pb::SetRequest> {
self.app_data.as_ref()
}

fn get_membership(&self) -> Option<Membership<TypeConfig>> {
self.membership.clone().map(Into::into)
}
Expand Down
4 changes: 0 additions & 4 deletions openraft/src/entry/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -89,10 +89,6 @@ where C: RaftTypeConfig
impl<C> RaftPayload<C> for Entry<C>
where C: RaftTypeConfig
{
fn app_data(&self) -> Option<&C::D> {
self.payload.app_data()
}

fn get_membership(&self) -> Option<Membership<C>> {
self.payload.get_membership()
}
Expand Down
8 changes: 0 additions & 8 deletions openraft/src/entry/payload.rs
Original file line number Diff line number Diff line change
Expand Up @@ -63,14 +63,6 @@ where C: RaftTypeConfig
}

impl<C: RaftTypeConfig> RaftPayload<C> for EntryPayload<C> {
fn app_data(&self) -> Option<&C::D> {
if let EntryPayload::Normal(data) = self {
Some(data)
} else {
None
}
}

fn get_membership(&self) -> Option<Membership<C>> {
if let EntryPayload::Membership(m) = self {
Some(m.clone())
Expand Down
3 changes: 0 additions & 3 deletions openraft/src/entry/traits.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,6 @@ use crate::RaftTypeConfig;
pub trait RaftPayload<C>
where C: RaftTypeConfig
{
/// Return the reference to the application data.
fn app_data(&self) -> Option<&C::D>;

/// Return `Some(Membership)` if the entry payload contains a membership payload.
fn get_membership(&self) -> Option<Membership<C>>;
}
Expand Down

0 comments on commit 1b66a64

Please sign in to comment.