Functions — github.com/serverlesstechnology/cqrs

hub / github.com/serverlesstechnology/cqrs / functions

Functions363 in github.com/serverlesstechnology/cqrs

⨍ Functions 363◇ Types & classes 122

↓ 1 callersMethodload

(&self, view_id: &str)

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

↓ 1 callersMethodload

(&self, view_id: &str)

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

↓ 1 callersMethodload_mut

(&self, view_id: String)

src/persist/generic_query.rs:90

↓ 1 callersMethodload_with_context

( &self, view_id: &str, )

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

↓ 1 callersMethodload_with_context

( &self, view_id: &str, )

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

↓ 1 callersMethodload_with_context

( &self, view_id: &str, )

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

↓ 1 callersFunctionmysql_cqrs

A convenience method for building a simple connection pool for MySql. A connection pool is needed for both the event and view repositories. ``` use s

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

↓ 1 callersFunctionnew_test_event_store

(pool: Pool<MySql>)

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

↓ 1 callersFunctionnew_test_event_store

( pool: Pool<Postgres>, )

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

↓ 1 callersFunctionnew_test_event_store

( client: Client, )

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

↓ 1 callersFunctionnew_test_event_store

( client: Client, )

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

↓ 1 callersMethodquery_events

( &self, aggregate_type: &str, aggregate_id: &str, )

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

↓ 1 callersMethodquery_events_from

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

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

↓ 1 callersFunctionquery_handler

Serves as our query endpoint to respond with the materialized `BankAccountView` for the requested account.

demo/src/route_handler.rs:11

↓ 1 callersMethodselect_snapshot

(&self)

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

↓ 1 callersMethodselect_snapshot

(&self)

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

↓ 1 callersFunctionserialize_events

( events: &[EventEnvelope<A>], )

src/persist/serialized_event.rs:61

↓ 1 callersFunctionstream_all_events

( query: String, aggregate_type: String, pool: Pool<MySql>, channel_size: usize, )

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

↓ 1 callersFunctionstream_all_events

(base_query: ScanFluentBuilder, channel_size: usize)

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

↓ 1 callersFunctionstream_events

( query: String, aggregate_type: String, aggregate_id: String, pool: Pool<MySql>, channel_

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

↓ 1 callersFunctionstream_events

TODO: combine these two methods

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

↓ 1 callersMethodsupersedes

Identifies if one `SemanticVersion` supersedes another. Used to determine whether an upcaster function should be applied. E.g., - for upcaster v0.2.3

src/persist/upcaster.rs:36

↓ 1 callersMethodupdate

(&mut self, _event: &EventEnvelope<MyAggregate>)

src/persist/doc.rs:15

↓ 1 callersMethodupdate_snapshot

(&self)

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

↓ 1 callersMethodupdate_snapshot

(&self)

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

↓ 1 callersMethodupdate_view

( &self, _view: MyView, _context: ViewContext, )

src/persist/doc.rs:41

↓ 1 callersMethoduse_error_handler

Allows the user to apply a custom error handler to the query replay. _Example: An error handler that panics on any error._ ``` # use cqrs_es::doc::{M

src/persist/replay.rs:75

↓ 1 callersMethodvalidate_check

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

demo/src/domain/aggregate.rs:315

↓ 1 callersFunctionverify_replay_stream

(id: &str, event_repo: MysqlEventRepository)

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

↓ 1 callersFunctionverify_replay_stream

(id: &str, event_repo: PostgresEventRepository)

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

↓ 1 callersFunctionverify_replay_stream

(id: &str, event_repo: DynamoEventRepository)

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

↓ 1 callersMethodwith_streaming_channel_size

Configures a `MysqlEventRepository` to use a streaming queue of the provided size. _Example: configure the repository to stream with a 1000 event buf

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

↓ 1 callersMethodwith_streaming_channel_size

Configures a `PostgresEventRepository` to use a streaming queue of the provided size. _Example: configure the repository to stream with a 1000 event

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

↓ 1 callersMethodwith_streaming_channel_size

Configures a `DynamoEventRepository` to use a streaming queue of the provided size. _Example: configure the repository to stream with a 1000 event bu

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

Methodaggregate

(&mut self)

src/persist/context.rs:28

Methodaggregate_id

(events: &[EventEnvelope<A>])

src/mem_store.rs:73

Methodand

(self, new_events: Vec<A::Event>)

src/test/executor.rs:74

Methodappend_query

Appends an additional query to the framework. ```rust # use cqrs_es::doc::{MyAggregate, MyQuery, MyService}; use cqrs_es::CqrsFramework; use cqrs_es::

src/cqrs.rs:87

Methodapply

(&mut self, _e: Self::Event)

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

Methodapply

(&mut self, _e: Self::Event)

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

Methodapply

(&mut self, _e: Self::Event)

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

Methodapply

(&mut self, event: Self::Event)

demo/src/domain/aggregate.rs:92

Methodatm_withdrawal

(&self, _atm_id: &str, _amount: f64)

demo/src/services.rs:27

Methodbuild_event_put_transactions

( table_name: &str, events: &[SerializedEvent], )

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

Functioncommit

()

src/persist/event_store.rs:616

Functioncommit_and_load_events

()

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

Functioncommit_and_load_events

()

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

Functioncommit_and_load_events

()

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

Functioncommit_and_load_events

()

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

Functioncommit_and_load_events_snapshot_store

()

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

Functioncommit_and_load_events_snapshot_store

()

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

Functioncommit_and_load_events_snapshot_store

()

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

Functioncommit_five

()

src/persist/event_store.rs:929

Functioncommit_no_events

()

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

Functioncommit_one_event

()

src/persist/event_store.rs:776

Functioncommit_one_event_with_previous

()

src/persist/event_store.rs:803

Functioncommit_three_events

()

src/persist/event_store.rs:834

Functioncommit_two_with_existing

()

src/persist/event_store.rs:884

Methodcontext_for

(aggregate_id: &str, _is_event_source: bool)

src/persist/context.rs:17

demo/src/domain/aggregate.rs:292

Methoddeser_event

(row: MySqlRow)

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

Methoddeser_event

(row: &PgRow)

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

Methoddeser_snapshot

(row: &PgRow)

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

Methoddispatch

(&self, view_id: &str, events: &[EventEnvelope<A>])

src/persist/generic_query.rs:125

Methoddispatch

(&self, _aggregate_id: &str, events: &[EventEnvelope<TestAggregate>])

tests/lib.rs:164

Methoddispatch

(&self, aggregate_id: &str, events: &[EventEnvelope<BankAccount>])

demo/src/queries.rs:16

Functiondynamodb_aggregate_cqrs

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

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

Functiondynamodb_snapshot_cqrs

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

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

Functionevent_repositories

()

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

Functionevent_repositories

()

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

Functionevent_repositories

()

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

Functionevent_repositories

()

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

demo/src/domain/events.rs:25

demo/src/domain/events.rs:34

Methodfmt

(&self, f: &mut Formatter<'_>)

src/persist/upcaster.rs:43

Methodfmt

(&self, f: &mut Formatter<'_>)

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

Methodfmt

(&self, f: &mut Formatter<'_>)

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

Methodfmt

(&self, f: &mut Formatter<'_>)

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

Functionframework_test

src/persist/event_store.rs:375

Methodfrom

(_: ParseIntError)

src/persist/upcaster.rs:72

Methodfrom

(err: PersistenceError)

src/persist/error.rs:23

Methodfrom

(err: sqlx::Error)

persistence/mysql-es/src/error.rs:18

Methodfrom

(err: sqlx::Error)

persistence/postgres-es/src/error.rs:18

Methodfrom

(error: DynamoAggregateError)

persistence/dynamo-es/src/error.rs:28

(_: axum::extract::rejection::BytesRejection)

demo/src/command_extractor.rs:52

Methodfrom

(msg: &str)

demo/src/domain/events.rs:44

Methodfrom_request

(req: Request<Body>, state: &S)

demo/src/command_extractor.rs:20

Methodfrom_str

(event_version: &str)

src/persist/upcaster.rs:54

Methodget_events

( &self, _aggregate_id: &str, )

( &self, _aggregate_id: &str, )

src/persist/doc.rs:68

← previous next →101–200 of 363, ranked by callers