Struct ChangeBatch 

#[non_exhaustive]
pub struct ChangeBatch {
    pub changes: Vec<Change>,
    pub next: FeedPosition,
}

A batch of changes plus the cursor to resume from.

use kevy_embedded::{Config, Store};

let store = Store::open(Config::default().with_feed(0))?;
let from = store.changes_tail()?;
store.set(b"k", b"v")?;
let batch = store.changes_since(from, 10, &[])?;
assert_eq!(batch.changes.len(), 1);
assert_eq!(batch.next.offset, from.offset + 1);

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

changes: Vec<Change>

Delivered changes, offset order.

use kevy_embedded::{Config, Store};

let store = Store::open(Config::default().with_feed(0))?;
let from = store.changes_tail()?;
store.set(b"a", b"1")?;
store.del(&[b"a"])?;
let batch = store.changes_since(from, 10, &[])?;
let verbs: Vec<&[u8]> = batch.changes.iter().map(|c| &c.argv[0][..]).collect();
assert_eq!(verbs, [&b"SET"[..], b"DEL"]);

next: FeedPosition

The cursor to pass to the next changes_since.

use kevy_embedded::{Config, Store};

let store = Store::open(Config::default().with_feed(0))?;
let from = store.changes_tail()?;
store.set(b"a", b"1")?;
store.set(b"b", b"2")?;
let first = store.changes_since(from, 1, &[])?;
// resuming at `next` picks up exactly where the first batch stopped
let rest = store.changes_since(first.next, 10, &[])?;
assert_eq!(rest.changes[0].argv[1], b"b");

Implementations

impl ChangeBatch

pub fn new(changes: Vec<Change>, next: FeedPosition) -> Self

A batch of changes resuming at next — the decoded form of a server’s FEED.READ reply.

use kevy_embedded::{ChangeBatch, FeedPosition};
let caught_up = ChangeBatch::new(Vec::new(), FeedPosition::new(1, 42));
assert!(caught_up.changes.is_empty());
assert_eq!(caught_up.next.offset, 42);

Trait Implementations

impl Clone for ChangeBatch

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeBatch

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

Formats the value using the given formatter.

impl Eq for ChangeBatch

impl Hash for ChangeBatch

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ChangeBatch

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ChangeBatch