Struct Publisher 

pub struct Publisher { /* private fields */ }

What one route last published, so only what changed is sent again.

Implementations

impl Publisher

pub fn reset(&mut self)

Forget what was sent: the next publication sends the whole set.

pub fn wants(&self, state: IndexState) -> bool

Whether the source moved since the last publication.

pub fn publish( &mut self, state: IndexState, entries: Vec<IndexEntry>, ) -> Vec<IndexDelta>

The deltas, each within MAX_DELTA_BYTES, that bring the index from what this publisher sent to entries at state. What they carry counts as sent.

pub fn publish_moved( &mut self, state: IndexState, upsert: Vec<IndexEntry>, remove: Vec<String>, ) -> Option<Vec<IndexDelta>>

The deltas that send upsert entries, new or changed, and drop remove keys, from what this publisher sent: what a source that knows what moved publishes instead of reading its whole set again. None when what this publisher sent does not cover the change (the first publication on a route, or a source that never sent the whole set): the caller publishes the whole set again instead.

Trait Implementations

impl Debug for Publisher

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

Formats the value using the given formatter.

impl Default for Publisher

fn default() -> Publisher

Returns the “default value” for a type.