Functions — github.com/serverlesstechnology/cqrs

hub / github.com/serverlesstechnology/cqrs / functions

Functions363 in github.com/serverlesstechnology/cqrs

⨍ Functions 363◇ Types & classes 122

Methodget_events

( &self, _aggregate_id: &str, )

src/persist/event_store.rs:473

Methodget_events

( &self, aggregate_id: &str, )

persistence/mysql-es/src/event_repository.rs:28

Methodget_events

( &self, aggregate_id: &str, )

persistence/postgres-es/src/event_repository.rs:26

Methodget_events

( &self, aggregate_id: &str, )

persistence/dynamo-es/src/event_repository.rs:273

Methodget_last_events

( &self, _aggregate_id: &str, _number_events: usize, )

src/doc.rs:187

Methodget_last_events

( &self, _aggregate_id: &str, _number_events: usize, )

src/persist/doc.rs:75

Methodget_last_events

( &self, _aggregate_id: &str, _number_events: usize, )

src/persist/event_store.rs:479

Methodget_last_events

( &self, aggregate_id: &str, last_sequence: usize, )

persistence/mysql-es/src/event_repository.rs:36

Methodget_last_events

(&self, last_sequence: usize)

persistence/mysql-es/src/sql_query.rs:59

Methodget_last_events

( &self, aggregate_id: &str, last_sequence: usize, )

persistence/postgres-es/src/event_repository.rs:34

Methodget_last_events

(&self, last_sequence: usize)

persistence/postgres-es/src/sql_query.rs:59

Methodget_last_events

( &self, aggregate_id: &str, number_events: usize, )

persistence/dynamo-es/src/event_repository.rs:280

Methodget_snapshot

( &self, _aggregate_id: &str, )

src/doc.rs:195

Methodget_snapshot

( &self, _aggregate_id: &str, )

src/persist/doc.rs:83

Methodget_snapshot

( &self, _aggregate_id: &str, )

src/persist/event_store.rs:486

Methodget_snapshot

( &self, aggregate_id: &str, )

persistence/mysql-es/src/event_repository.rs:45

Methodget_snapshot

( &self, aggregate_id: &str, )

persistence/postgres-es/src/event_repository.rs:43

Methodget_snapshot

( &self, aggregate_id: &str, )

persistence/dynamo-es/src/event_repository.rs:290

Methodhandle

( &mut self, _command: Self::Command, _services: &Self::Services,

persistence/mysql-es/src/testing.rs:25

Methodhandle

( &mut self, _command: Self::Command, _services: &Self::Services,

persistence/postgres-es/src/testing.rs:25

Methodhandle

( &mut self, _command: Self::Command, _services: &Self::Services,

persistence/dynamo-es/src/testing.rs:32

Methodhandle

( &mut self, command: Self::Command, _service: &Self::Services, sink: &EventSi

tests/lib.rs:39

Methodhandle

The aggregate logic goes here. Note that this will be the _bulk_ of a CQRS system so expect to use helper functions elsewhere to keep the code clean.

demo/src/domain/aggregate.rs:24

Methodinsert_events

( &self, events: &[SerializedEvent], )

persistence/mysql-es/src/event_repository.rs:231

Methodinsert_events

( &self, events: &[SerializedEvent], )

persistence/postgres-es/src/event_repository.rs:213

Methodinspect_result

Returns the internal error payload for validation by the user. ``` # use cqrs_es::doc::{MyAggregate, MyCommands, MyEvents, MyService, MyUserError}; u

src/test/validator.rs:68

Functionlambda_command_handler

( Path(account_id): Path<String>, State(state): State<ApplicationState>, CommandExtractor(metadata

demo/src/lambda_main.rs:28

Functionlambda_query_handler

( Path(account_id): Path<String>, State(state): State<ApplicationState>, )

demo/src/lambda_main.rs:22

Functionload

()

src/persist/event_store.rs:550

Methodload

(&self, _view_id: &str)

src/persist/doc.rs:30

Functionload_aggregate_after_deserialize_error

()

src/persist/event_store.rs:745

Functionload_aggregate_error

()

src/persist/event_store.rs:605

Functionload_aggregate_existing

()

src/persist/event_store.rs:586

Functionload_aggregate_new

()

src/persist/event_store.rs:575

Functionload_error

()

src/persist/event_store.rs:564

demo/src/lambda_main.rs:12

Functionmysql_aggregate_cqrs

A convenience function for creating a CqrsFramework using an aggregate store.

persistence/mysql-es/src/cqrs.rs:58

Functionmysql_snapshot_cqrs

A convenience function for creating a CqrsFramework using a snapshot store.

persistence/mysql-es/src/cqrs.rs:43

Methodnew

Creates new framework for dispatching commands using the provided elements. Takes an implementation of an `EventStore`, a vector of queries and a set

src/cqrs.rs:63

Methodnew

(result: Result<Vec<A::Event>, A::Error>)

src/test/validator.rs:72

Methodnew

(events: Vec<A::Event>, service: A::Services)

src/test/executor.rs:81

Methodnew

Create a new [`SerializedEvent`] with the given values.

src/persist/serialized_event.rs:30

Methodnew

Create a new replay utility using the provided event repository as the source and the query as the target.

src/persist/replay.rs:40

Methodnew

(_db: MyDatabaseConnection)

src/persist/doc.rs:24

Methodnew

Creates a new `ReplayStream` that will buffer events up to the `queue_size`.

src/persist/event_stream.rs:14

Methodnew

Convenience function to create a new [`QueryContext`].

src/persist/view_repository.rs:44

Methodnew

Creates a `SemanticVersionEventUpcaster`

src/persist/upcaster.rs:140

Methodnew

Creates a new `GenericQuery` using the provided `ViewRepository`. ``` # use std::sync::Arc; # use cqrs_es::doc::MyAggregate; # use cqrs_es::persist::

src/persist/generic_query.rs:40

Methodnew

Creates a new `MysqlEventRepository` from the provided database connection used for backing a `MysqlSnapshotStore`. This uses the default tables 'even

persistence/mysql-es/src/event_repository.rs:183

Methodnew

(event_table: &str, snapshot_table: &str)

persistence/mysql-es/src/sql_query.rs:12

Methodnew

Creates a new `MysqlViewRepository` that will store serialized views in a MySql table named identically to the `view_name` value provided. This table

persistence/mysql-es/src/view_repository.rs:38

Methodnew

Creates a new `PostgresEventRepository` from the provided database connection. This uses the default tables 'events' and 'snapshots'. ``` use sqlx::{

persistence/postgres-es/src/event_repository.rs:164

Methodnew

(event_table: &str, snapshot_table: &str)

persistence/postgres-es/src/sql_query.rs:12

Methodnew

Creates a new `PostgresViewRepository` that will store serialized views in a Postgres table named identically to the `view_name` value provided. This

persistence/postgres-es/src/view_repository.rs:38

Methodnew

Creates a new `DynamoEventRepository` from the provided dynamo client using default table names. ``` use aws_sdk_dynamodb::Client; use dynamo_es::Dyn

persistence/dynamo-es/src/event_repository.rs:43

Methodnew

Creates a new `DynamoViewRepository` that will store serialized views in a DynamoDb table named identically to the `view_name` value provided. This ta

persistence/dynamo-es/src/view_repository.rs:37

Methodnew

(events: Arc<RwLock<Vec<EventEnvelope<TestAggregate>>>>)

tests/lib.rs:158

Methodnew

(services: Box<dyn BankAccountApi>)

demo/src/services.rs:8

Methodnew

(description: String, amount: f64)

demo/src/queries.rs:49

Methodnew_aggregate_store

Creates a new `PersistedEventStore` from the provided event repository, using the serialized aggregate as the source of truth. As with other `EventSto

src/persist/event_store.rs:133

Methodnew_event_store

Creates a new `PersistedEventStore` from the provided event repository, using events as the single source of truth. ``` # use cqrs_es::doc::{MyAggreg

src/persist/event_store.rs:108

Methodnew_snapshot_store

Creates a new `PersistedEventStore` from the provided event repository, using events and aggregate snapshots as the source of truth. ``` # use cqrs_e

src/persist/event_store.rs:156

Methodnext

(&mut self)

src/persist/doc.rs:54

Functionparse_version

()

src/persist/upcaster.rs:202

Functionparse_version_invalid

()

src/persist/upcaster.rs:222

Methodpersist

( &self, _events: &[SerializedEvent], _snapshot_update: Option<(String, Value, usize)>

src/doc.rs:202

Methodpersist

( &self, _events: &[SerializedEvent], _snapshot_update: Option<(String, Value, usize)>

src/persist/doc.rs:90

Methodpersist

( &self, events: &[SerializedEvent], snapshot_update: Option<(String, Valu

src/persist/event_store.rs:492

Methodpersist

( &self, events: &[SerializedEvent], snapshot_update: Option<(String, Value, usize)>,

persistence/mysql-es/src/event_repository.rs:61

Methodpersist

( &self, events: &[SerializedEvent], snapshot_update: Option<(String, Value, usize)>,

persistence/postgres-es/src/event_repository.rs:59

Methodpersist

( &self, events: &[SerializedEvent], snapshot_update: Option<(String, Value, usize)>,

persistence/dynamo-es/src/event_repository.rs:316

Methodpersist_events

( &self, tx: &mut Transaction<'_, MySql>, events: &[SerializedEvent], )

persistence/mysql-es/src/event_repository.rs:326

Methodpersist_events

( &self, inser_event_query: &str, tx: &mut Transaction<'_, Postgres>, events:

persistence/postgres-es/src/event_repository.rs:313

Functionpostgres_aggregate_cqrs

A convenience function for creating a CqrsFramework using an aggregate store.

persistence/postgres-es/src/cqrs.rs:59

Functionpostgres_snapshot_cqrs

A convenience function for creating a CqrsFramework using a snapshot store.

persistence/postgres-es/src/cqrs.rs:44

Functionquery_replay

()

src/persist/replay.rs:155

Functionquery_replay_with_upcasting

()

src/persist/replay.rs:185

Methodselect_events

(&self)

persistence/mysql-es/src/sql_query.rs:41

Methodselect_events

(&self)

persistence/postgres-es/src/sql_query.rs:41

Functionsemantic_version

(major_version: u32, minor_version: u32, patch: u32)

src/persist/upcaster.rs:193

Functionsemantic_version_upcaster_can_upcast

()

src/persist/upcaster.rs:246

Functionsemantic_version_upcaster_invalid_version

()

src/persist/upcaster.rs:252

Functionsemantic_version_upcaster_upcast

()

src/persist/upcaster.rs:257

Functionsemantic_version_upcaster_upcast_for_documentation

()

src/persist/upcaster.rs:283

Functionsimple_upcaster_can_upcast

()

src/persist/upcaster.rs:233

Functionsnapshot_context

( aggregate_id: String, current_sequence: usize, current_snapshot: usize, aggr

persistence/mysql-es/src/testing.rs:122

Functionsnapshot_context

( aggregate_id: String, current_sequence: usize, current_snapshot: usize, aggr

persistence/postgres-es/src/testing.rs:123

Functionsnapshot_context

( aggregate_id: String, current_sequence: usize, current_snapshot: usize, aggr

persistence/dynamo-es/src/testing.rs:152

Functionsnapshot_repositories

()

persistence/mysql-es/src/event_repository.rs:439

Functionsnapshot_repositories

()

persistence/postgres-es/src/event_repository.rs:429

Functionsnapshot_repositories

()

persistence/dynamo-es/src/event_repository.rs:524

Methodstream_all_events

(&self)

src/doc.rs:217

Methodstream_all_events

(&self)

src/persist/doc.rs:105

Methodstream_all_events

(&self)

src/persist/event_store.rs:509

Methodstream_all_events

(&self)

persistence/mysql-es/src/event_repository.rs:96

Methodstream_all_events

TODO: aggregate id is unused here, `stream_events` function needs to be broken up

persistence/postgres-es/src/event_repository.rs:95

Methodstream_all_events

(&self)

persistence/dynamo-es/src/event_repository.rs:343

Methodstream_events

( &self, _aggregate_id: &str, )

src/doc.rs:210

Methodstream_events

( &self, _aggregate_id: &str, )

src/persist/doc.rs:98

← previous next →201–300 of 363, ranked by callers