Struct fluvio_sc_schema::message::Message

pub struct Message<C> where
    C: Encoder + Decoder + Debug,  {
    pub header: MsgType,
    pub content: C,
}

Fields

header: MsgType

content: C

Implementations

impl<C> Message<C> where
    C: Encoder + Decoder + Debug, 

pub fn new(typ: MsgType, content: C) -> Message<C>

pub fn delete(content: C) -> Message<C>

pub fn update(content: C) -> Message<C>

impl Message<Replica>

pub fn create_delete_msg(name: ReplicaKey, leader: i32) -> Message<Replica>

Trait Implementations

impl<C> Clone for Message<C> where
    C: Clone + Encoder + Decoder + Debug, 

pub fn clone(&self) -> Message<C>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C> Debug for Message<C> where
    C: Debug + Encoder + Decoder, 

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<C> Decoder for Message<C> where
    C: Encoder + Decoder + Debug, 

pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf, 

pub fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
    Self: Default,
    T: Buf, 

decode Kafka compliant protocol values from buf

impl<C> Default for Message<C> where
    C: Default + Encoder + Decoder + Debug, 

pub fn default() -> Message<C>

Returns the “default value” for a type.

impl<C> Display for Message<C> where
    C: Encoder + Decoder + Debug + Display, 

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<C> Encoder for Message<C> where
    C: Encoder + Decoder + Debug, 

pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

pub fn write_size(&self, version: i16) -> usize

size of this object in bytes

pub fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl<S, C, D> From<LSChange<S, C>> for Message<D> where
    C: MetadataItem,
    S: Spec,
    D: Encoder + Decoder + Debug + From<MetadataStoreObject<S, C>>,
    <S as Spec>::Status: PartialEq<<S as Spec>::Status>, 

pub fn from(change: LSChange<S, C>) -> Message<D>

Performs the conversion.

impl<C> PartialEq<Message<C>> for Message<C> where
    C: PartialEq<C> + Encoder + Decoder + Debug, 

pub fn eq(&self, other: &Message<C>) -> bool

This method tests for self and other values to be equal, and is used by ==.

pub fn ne(&self, other: &Message<C>) -> bool

This method tests for !=.

impl<C> StructuralPartialEq for Message<C> where
    C: Encoder + Decoder + Debug,