Struct EventStoreForBigtable 

pub struct EventStoreForBigtable<AID, A, E>
where
    AID: AggregateId,
    A: Aggregate<ID = AID>,
    E: Event<AggregateID = AID>,
{ /* private fields */ }

Implementations

impl<AID, A, E> EventStoreForBigtable<AID, A, E>

where AID: AggregateId, A: Aggregate<ID = AID>, E: Event<AggregateID = AID>,

pub fn new( client: BigtableClient<Channel>, project_id: String, instance_id: String, journal_table_name: String, snapshot_table_name: String, shard_count: u64, ) -> Self

pub fn with_key_resolver( self, key_resolver: Arc<dyn KeyResolver<ID = AID>>, ) -> Self

pub fn with_event_serializer( self, serializer: Arc<dyn EventSerializer<E>>, ) -> Self

pub fn with_snapshot_serializer( self, serializer: Arc<dyn SnapshotSerializer<A>>, ) -> Self

pub fn with_keep_snapshot_count( self, keep_snapshot_count: Option<usize>, ) -> Self

pub fn maintenance(&self) -> &SnapshotMaintenance

Trait Implementations

impl<AID, A, E> Clone for EventStoreForBigtable<AID, A, E>

where AID: AggregateId + Clone, A: Aggregate<ID = AID> + Clone, E: Event<AggregateID = AID> + Clone,

fn clone(&self) -> EventStoreForBigtable<AID, A, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<AID, A, E> Debug for EventStoreForBigtable<AID, A, E>

where AID: AggregateId + Debug, A: Aggregate<ID = AID> + Debug, E: Event<AggregateID = AID> + Debug,

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

Formats the value using the given formatter.

impl<AID, A, E> EventStore for EventStoreForBigtable<AID, A, E>

where AID: AggregateId, A: Aggregate<ID = AID>, E: Event<AggregateID = AID>,

type AG = A

集約の型。

type AID = AID

集約のIDの型。

type EV = E

イベントの型。

fn persist_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: &'life1 Self::EV, version: usize, ) -> Pin<Box<dyn Future<Output = Result<(), EventStoreWriteError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

イベントを保存します。

fn persist_event_and_snapshot<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, event: &'life1 Self::EV, aggregate: &'life2 Self::AG, ) -> Pin<Box<dyn Future<Output = Result<(), EventStoreWriteError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves an event and a snapshot.
イベント及びスナップショットを保存します。

fn get_latest_snapshot_by_id<'life0, 'life1, 'async_trait>( &'life0 self, aid: &'life1 Self::AID, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::AG>, EventStoreReadError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

最新のスナップショットを取得する。

fn get_events_by_id_since_seq_nr<'life0, 'life1, 'async_trait>( &'life0 self, aid: &'life1 Self::AID, seq_nr: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Self::EV>, EventStoreReadError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

指定したIDとシーケンス番号以降のイベントを取得する。

impl<AID, A, E> Send for EventStoreForBigtable<AID, A, E>

where AID: AggregateId, A: Aggregate<ID = AID>, E: Event<AggregateID = AID>,

impl<AID, A, E> Sync for EventStoreForBigtable<AID, A, E>

where AID: AggregateId, A: Aggregate<ID = AID>, E: Event<AggregateID = AID>,