Functions — github.com/serverlesstechnology/cqrs

hub / github.com/serverlesstechnology/cqrs / functions

Functions363 in github.com/serverlesstechnology/cqrs

⨍ Functions 363◇ Types & classes 122

Methodstream_events

( &self, _aggregate_id: &str, )

src/persist/event_store.rs:502

Methodstream_events

( &self, aggregate_id: &str, )

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

Methodstream_events

( &self, aggregate_id: &str, )

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

Methodstream_events

( &self, aggregate_id: &str, )

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

Functiontest_add_email

()

src/doc.rs:255

Functiontest_add_email_name_populted

()

src/doc.rs:267

Functiontest_add_name

()

src/doc.rs:231

Functiontest_add_name_again

()

src/doc.rs:243

Functiontest_deposit_money

()

demo/src/domain/aggregate.rs:130

Functiontest_deposit_money_with_balance

()

demo/src/domain/aggregate.rs:148

Functiontest_framework_failure_test

()

tests/lib.rs:267

Functiontest_framework_failure_test_b

()

tests/lib.rs:284

Functiontest_framework_test

()

tests/lib.rs:241

Functiontest_mem_store

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

Functiontest_queries

()

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

Functiontest_replay_stream

()

src/persist/event_stream.rs:52

Functiontest_serialized_event

(seq: usize, event: TestEvents)

src/persist/event_store.rs:522

Functiontest_source_of_truth

()

src/persist/event_store.rs:45

Functiontest_valid_cqrs_framework

()

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

Functiontest_valid_cqrs_framework

()

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

Functiontest_valid_cqrs_framework

()

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

Functiontest_valid_view_repository

()

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

Functiontest_valid_view_repository

()

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

Functiontest_valid_view_repository

()

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

Functiontest_withdraw_money

()

demo/src/domain/aggregate.rs:170

Functiontest_withdraw_money_client_error

()

demo/src/domain/aggregate.rs:193

Functiontest_withdraw_money_funds_not_available

()

demo/src/domain/aggregate.rs:213

Functiontest_wrote_check

()

demo/src/domain/aggregate.rs:228

Functiontest_wrote_check_bad_check

()

demo/src/domain/aggregate.rs:253

Functiontest_wrote_check_funds_not_available

()

demo/src/domain/aggregate.rs:273

Methodthen_expect_error

Verifies that the result is the expected error. > Note that the configured Error *must* implement `std::cmp::PartialEq`. ``` # use cqrs_es::doc::{My

src/test/validator.rs:96

Methodtry_from

(event: &EventEnvelope<A>)

src/persist/serialized_event.rs:85

Functionupcasted_event

()

persistence/mysql-es/tests/lib.rs:76

Functionupcasted_event

()

persistence/postgres-es/tests/lib.rs:79

Functionupcasted_event

()

persistence/dynamo-es/tests/lib.rs:107

Functionupcasting_fn

(_payload: Value)

src/persist/replay.rs:206

Methodupdate

( &self, aggregate: Value, aggregate_id: String, current_snapshot: usize,

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

Methodupdate

(&mut self, event: &EventEnvelope<TestAggregate>)

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

Methodupdate

( &self, aggregate: Value, aggregate_id: String, current_snapshot: usize,

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

Methodupdate

(&mut self, event: &EventEnvelope<TestAggregate>)

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

Methodupdate

(&mut self, event: &EventEnvelope<TestAggregate>)

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

Methodupdate

(&mut self, event: &EventEnvelope<BankAccount>)

demo/src/queries.rs:61

Methodupdate_snapshot

( &self, aggregate_payload: Value, aggregate_id: String, current_snapshot: usi

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

Methodupdate_snapshot_with_events

( events: &[<A as Aggregate>::Event], mut context: EventStoreAggregateContext<A>, comm

src/persist/event_store.rs:295

Methoduse_error_handler

Allows the user to apply a custom error handler to the query. Queries are infallible and _should_ never cause errors, but programming errors or other

src/persist/generic_query.rs:65

Methoduse_table_names

(client: Client, event_table: &str, snapshot_table: &str)

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

Methoduse_tables

(pool: Pool<MySql>, events_table: &str, snapshots_table: &str)

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

Methoduse_tables

(pool: Pool<Postgres>, events_table: &str, snapshots_table: &str)

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

Methodvalidate_check

( &self, _account_id: &str, _check_number: &str, )

demo/src/services.rs:31

Functionwhen

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

src/test/executor.rs:87

Methodwhen_async

Consumes a command in an `async` test and provides a validator object to test against. ``` # use cqrs_es::doc::{MyAggregate, MyCommands, MyService};

src/test/executor.rs:51

Methodwith

Create a test framework using the provided service.

src/test/framework.rs:12

Methodwith_commit

( test_function: Box< dyn FnOnce(&[SerializedEvent], Option<(String, Value, usize)

src/persist/event_store.rs:458

Methodwith_events

(result: Result<Vec<SerializedEvent>, PersistenceError>)

src/persist/event_store.rs:428

Methodwith_last_events

( last_events: Result<Vec<SerializedEvent>, PersistenceError>, snapshot: Result<Option

src/persist/event_store.rs:436

Methodwith_snapshot

( result: Result<Option<SerializedSnapshot>, PersistenceError>, )

src/persist/event_store.rs:447

Methodwith_tables

Configures a `MysqlEventRepository` to use the provided table names. _Example: configure the repository to use "my_event_table" and "my_snapshot_tabl

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

Methodwith_tables

Configures a `PostgresEventRepository` to use the provided table names. _Example: configure the repository to use "my_event_table" and "my_snapshot_t

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

Methodwith_tables

Configures a `DynamoEventRepository` to use the provided table names. _Example: configure the repository to use "my_event_table" and "my_snapshot_tab

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

Methodwith_upcasters

Configures the event store to use event upcasters when loading events. The EventUpcasters within the Vec should be placed in the order that they shoul

src/persist/event_store.rs:170

Methodwrap_events

Method to wrap a set of events with the additional metadata needed for persistence and publishing

src/mem_store.rs:148

Methodwrap_events

Method to wrap a set of events with the additional metadata needed for persistence and publishing

src/persist/event_store.rs:312

← previous301–363 of 363, ranked by callers