Struct ProjectionCheckpoint 

pub struct ProjectionCheckpoint<C> { /* private fields */ }

English:
Owned cursor identifying progress in a projection’s input stream.

The cursor type and meaning belong to the application. This container performs no ordering, monotonicity, or validity checks and does not store progress by itself.

Borrow a cursor for inspection, then recover its ownership without cloning.

日本語:
プロジェクションの入力ストリームにおける進捗を示す、所有されたカーソルです。

カーソルの型と意味はアプリケーションが定めます。このコンテナーは順序、単調性、妥当性を 検証せず、単体では進捗を保存しません。

カーソルを借用して確認した後、複製せずに所有権を取り出せます。

Example / 使用例

use ddd_toolkit_core::ProjectionCheckpoint;

let checkpoint = ProjectionCheckpoint::new(String::from("partition-2:17"));
assert_eq!(checkpoint.cursor(), "partition-2:17");
let cursor = checkpoint.into_cursor();
assert_eq!(cursor, "partition-2:17");

Implementations

impl<C> ProjectionCheckpoint<C>

pub fn new(cursor: C) -> ProjectionCheckpoint<C>

English:
Wraps cursor without validating its position or comparing previous progress.

日本語:
位置の検証や以前の進捗との比較をせずに cursor を包みます。

pub fn cursor(&self) -> &C

English:
Borrows the stored cursor without advancing it.

日本語:
進めることなく、保存されたカーソルを借用します。

pub fn into_cursor(self) -> C

English:
Consumes the checkpoint and returns its cursor by value.

日本語:
チェックポイントを消費し、カーソルを値として返します。

Trait Implementations

impl<C> Clone for ProjectionCheckpoint<C>

where C: Clone,

fn clone(&self) -> ProjectionCheckpoint<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Debug for ProjectionCheckpoint<C>

where C: Debug,

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

Formats the value using the given formatter.

impl<C> Eq for ProjectionCheckpoint<C>

where C: Eq,

impl<C> Hash for ProjectionCheckpoint<C>

where C: Hash,

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

where __H: Hasher,

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<C> PartialEq for ProjectionCheckpoint<C>

where C: PartialEq,

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

Equality operator ==.

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

Inequality operator !=.

impl<C> StructuralPartialEq for ProjectionCheckpoint<C>

where C: PartialEq,