Struct QueueDiff 

pub struct QueueDiff {
    pub hash: HashBytes,
    pub prev_hash: HashBytes,
    pub shard_ident: ShardIdent,
    pub seqno: u32,
    pub processed_to: BTreeMap<ShardIdent, QueueKey>,
    pub min_message: QueueKey,
    pub max_message: QueueKey,
    pub messages: Vec<HashBytes>,
    pub router_partitions_src: RouterPartitions,
    pub router_partitions_dst: RouterPartitions,
}

Representation of an internal messages queue diff.

Fields

hash: HashBytes

Computed hash of this diff.

NOTE: This field is not serialized and can be HashBytes::ZERO for serialization.

prev_hash: HashBytes

Hash of the TL repr of the previous queue diff.

shard_ident: ShardIdent

Shard identifier of the corresponding block

seqno: u32

Seqno of the corresponding block.

processed_to: BTreeMap<ShardIdent, QueueKey>

collator boundaries.

min_message: QueueKey

Min message queue key.

max_message: QueueKey

Max message queue key.

messages: Vec<HashBytes>

List of message hashes (sorted ASC).

router_partitions_src: RouterPartitions

Inbound router partitions.

router_partitions_dst: RouterPartitions

Outbound router partitions.

Implementations

impl QueueDiff

pub const TL_ID: u32 = 1_612_751_794u32

pub fn recompute_hash(&mut self)

Recomputes the hash of the diff.

NOTE: Since the hash is not serialized, it is NOT mandatory to call this method if it will not be used after this.

pub fn compute_hash(data: &[u8]) -> HashBytes

Computes the hash of the serialized diff.

Trait Implementations

impl AsRef<QueueDiff> for QueueDiffStuff

fn as_ref(&self) -> &QueueDiff

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for QueueDiff

fn clone(&self) -> QueueDiff

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueDiff

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

Formats the value using the given formatter.

impl PartialEq for QueueDiff

fn eq(&self, other: &QueueDiff) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<'tl> TlRead<'tl> for QueueDiff

type Repr = Boxed

Serialized object representation.

fn read_from(data: &mut &'tl [u8]) -> TlResult<Self>

Tries to read itself from bytes at the specified offset, incrementing that offset.

impl TlWrite for QueueDiff

type Repr = Boxed

Serialized object representation.

fn max_size_hint(&self) -> usize

Max required number of bytes.

fn write_to<P>(&self, packet: &mut P)

where P: TlPacket,

Writes itself to the specified TlPacket.

impl Eq for QueueDiff

impl StructuralPartialEq for QueueDiff