use std::fmt;
use std::fmt::Debug;
use crate::log_id::RaftLogId;
use crate::LogId;
use crate::Membership;
use crate::MessageSummary;
use crate::RaftTypeConfig;
pub mod payload;
mod traits;
pub use payload::EntryPayload;
pub use traits::FromAppData;
pub use traits::RaftEntry;
pub use traits::RaftPayload;
#[cfg_attr(feature = "serde", derive(serde::Deserialize, serde::Serialize), serde(bound = ""))]
pub struct Entry<C>
where C: RaftTypeConfig
{
pub log_id: LogId<C::NodeId>,
pub payload: EntryPayload<C>,
}
impl<C> Clone for Entry<C>
where
C: RaftTypeConfig,
C::D: Clone,
{
fn clone(&self) -> Self {
Self {
log_id: self.log_id,
payload: self.payload.clone(),
}
}
}
impl<C> Debug for Entry<C>
where C: RaftTypeConfig
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_struct("Entry").field("log_id", &self.log_id).field("payload", &self.payload).finish()
}
}
impl<C> Default for Entry<C>
where C: RaftTypeConfig
{
fn default() -> Self {
Self {
log_id: LogId::default(),
payload: EntryPayload::Blank,
}
}
}
impl<C> PartialEq for Entry<C>
where
C::D: PartialEq,
C: RaftTypeConfig,
{
fn eq(&self, other: &Self) -> bool {
self.log_id == other.log_id && self.payload == other.payload
}
}
impl<C> AsRef<Entry<C>> for Entry<C>
where C: RaftTypeConfig
{
fn as_ref(&self) -> &Entry<C> {
self
}
}
impl<C> fmt::Display for Entry<C>
where C: RaftTypeConfig
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(f, "{}:{}", self.log_id, self.payload.summary())
}
}
impl<C> MessageSummary<Entry<C>> for Entry<C>
where C: RaftTypeConfig
{
fn summary(&self) -> String {
format!("{}:{}", self.log_id, self.payload.summary())
}
}
impl<C> RaftPayload<C::NodeId, C::Node> for Entry<C>
where C: RaftTypeConfig
{
fn is_blank(&self) -> bool {
self.payload.is_blank()
}
fn get_membership(&self) -> Option<&Membership<C::NodeId, C::Node>> {
self.payload.get_membership()
}
}
impl<C> RaftLogId<C::NodeId> for Entry<C>
where C: RaftTypeConfig
{
fn get_log_id(&self) -> &LogId<C::NodeId> {
&self.log_id
}
fn set_log_id(&mut self, log_id: &LogId<C::NodeId>) {
self.log_id = *log_id;
}
}
impl<C> RaftEntry<C::NodeId, C::Node> for Entry<C>
where C: RaftTypeConfig
{
fn new_blank(log_id: LogId<C::NodeId>) -> Self {
Self {
log_id,
payload: EntryPayload::Blank,
}
}
fn new_membership(log_id: LogId<C::NodeId>, m: Membership<C::NodeId, C::Node>) -> Self {
Self {
log_id,
payload: EntryPayload::Membership(m),
}
}
}
impl<C> FromAppData<C::D> for Entry<C>
where C: RaftTypeConfig
{
fn from_app_data(d: C::D) -> Self {
Entry {
log_id: LogId::default(),
payload: EntryPayload::Normal(d),
}
}
}