MCPcopy Create free account

hub / github.com/Migorithm/rustiful-backend / functions

Functions118 in github.com/Migorithm/rustiful-backend

↓ 29 callersMethodget
(executor: Arc<RwLock<Executor>>)
library/src/adapters/outbox.rs:80
↓ 19 callersMethodrepository
(&mut self)
library/src/services/unit_of_work.rs:39
↓ 15 callersFunctionrun_test
(test: T)
tests/helpers.rs:45
↓ 14 callersMethodadd
( connection: Arc<RwLock<Executor>>, outboxes: Vec<Self>, )
library/src/adapters/outbox.rs:56
↓ 12 callersMethodcommit
(&mut self)
library/src/adapters/database.rs:67
↓ 11 callersMethodbegin
(&mut self)
library/src/adapters/database.rs:49
↓ 10 callersFunctionboard_create_helper
(state: BoardState)
tests/helpers.rs:32
↓ 10 callersMethodcommit
(mut self)
library/src/services/unit_of_work.rs:52
↓ 10 callersMethodhandle
(&self, message: C)
library/src/services/messagebus.rs:40
↓ 9 callersFunctionconnection_pool
()
library/src/bootstrap.rs:174
↓ 9 callersMethodexecutor
(&self)
library/src/adapters/database.rs:30
↓ 8 callersFunctionboard_repository_helper
(executor: Arc<RwLock<Executor>>)
tests/helpers.rs:28
↓ 8 callersMethodbuild
(self)
library/src/domain/auth/mod.rs:41
↓ 7 callersMethodupdate
(&self, executor: Arc<RwLock<Executor>>)
library/src/adapters/outbox.rs:93
↓ 5 callersFunctionrun_test
(test: T)
library/src/utils/test_components.rs:17
↓ 5 callersMethodtake_board
(mut self, board: Board)
library/src/domain/board/mod.rs:83
↓ 5 callersMethodtransaction
(&mut self)
library/src/adapters/database.rs:88
↓ 4 callersMethodbegin
(&mut self)
library/src/services/unit_of_work.rs:42
↓ 4 callersMethodconnection
(&self)
library/src/adapters/database.rs:94
↓ 3 callersMethodexecutor
(&self)
library/src/services/unit_of_work.rs:48
↓ 3 callersFunctionoutbox_setup
()
tests/outbox.rs:22
↓ 2 callersMethodconvert_event
(&self)
library/src/adapters/outbox.rs:47
↓ 2 callersFunctioncreate_board
( State(bus): State<Arc<MessageBus>>, Json(cmd): Json<CreateBoard>, )
bin/src/routes.rs:14
↓ 2 callersMethodset_events
(&mut self,events:VecDeque<Box<dyn Message> >)
library/src/adapters/repositories/mod.rs:41
↓ 2 callersMethodtake_comments
(mut self, comments: Vec<Comment>)
library/src/domain/board/mod.rs:87
↓ 2 callersMethodupdate_board
(&mut self, cmd: EditBoard)
library/src/domain/board/mod.rs:35
↓ 1 callersMethod_add
(&mut self, aggregate: &BoardAggregate)
library/src/adapters/repositories/board_repository.rs:29
↓ 1 callersMethod_commit
(&mut self)
library/src/services/unit_of_work.rs:59
↓ 1 callersMethod_commit_hook
commit_hook is invoked right before the calling for commit which sorts out and processes outboxes and internally processable events.
library/src/services/unit_of_work.rs:72
↓ 1 callersMethod_update
(&mut self, aggregate: &BoardAggregate)
library/src/adapters/repositories/board_repository.rs:104
↓ 1 callersFunctionadd_comment
( State(bus): State<Arc<MessageBus>>, Json(cmd): Json<AddComment>, )
bin/src/routes.rs:35
↓ 1 callersMethodas_any
Blanket implementation
library/src/domain/mod.rs:17
↓ 1 callersFunctionboard_routers
()
bin/src/routes.rs:54
↓ 1 callersFunctioncommand_handler
()
library/src/bootstrap.rs:146
↓ 1 callersMethodcreate_board
( cmd: CreateBoard, context: AtomicContextManager, )
library/src/services/handlers.rs:21
↓ 1 callersFunctionedit_board
( State(bus): State<Arc<MessageBus>>, Json(cmd): Json<EditBoard>, )
bin/src/routes.rs:25
↓ 1 callersFunctionevent_handler
()
library/src/bootstrap.rs:160
↓ 1 callersMethodexternally_notifiable
(&self)
library/src/domain/mod.rs:23
↓ 1 callersMethodget_events
(&mut self)
library/src/adapters/repositories/mod.rs:35
↓ 1 callersMethodhandle_event
( &self, msg: Box<dyn Message>, context_manager: AtomicContextManager, )
library/src/services/messagebus.rs:80
↓ 1 callersMethodinternally_notifiable
(&self)
library/src/domain/mod.rs:26
↓ 1 callersMethodoutbox
(&self)
library/src/domain/mod.rs:31
↓ 1 callersMethodrollback
(&mut self)
library/src/adapters/database.rs:77
↓ 1 callersMethodrollback
(self)
library/src/services/unit_of_work.rs:65
↓ 1 callersMethodtake_account
(mut self, account: Account)
library/src/domain/auth/mod.rs:26
↓ 1 callersFunctiontear_down
()
library/src/utils/test_components.rs:9
↓ 1 callersFunctiontear_down
()
tests/helpers.rs:20
Method_add
(&mut self, _aggregate: &AuthAggregate)
library/src/adapters/repositories/auth_repository.rs:12
Method_update
(&mut self, _aggregate: &AuthAggregate)
library/src/adapters/repositories/auth_repository.rs:20
Methodadd
(&mut self, aggregate: &mut BoardAggregate)
library/src/adapters/repositories/board_repository.rs:20
Methodadd_comment
(&mut self, cmd: AddComment)
library/src/domain/board/mod.rs:52
Methodadd_comment
(cmd: AddComment, context: AtomicContextManager)
library/src/services/handlers.rs:55
Methodbuild
(self)
library/src/domain/board/mod.rs:98
Methodbuilder
()
library/src/domain/board/mod.rs:104
Methodbuilder
()
library/src/domain/auth/mod.rs:47
Methodcollect_events
(&mut self)
library/src/domain/mod.rs:81
Methodcreate_board
(&mut self, cmd: CreateBoard)
library/src/domain/board/mod.rs:25
Methodcreate_token
(&mut self)
library/src/domain/auth/entity.rs:59
Methoddefault
()
library/src/domain/board/entity.rs:16
Methoddefault
()
library/src/domain/auth/entity.rs:14
Methoddelete
(&mut self)
library/src/domain/board/mod.rs:63
Functiondependency
()
library/src/bootstrap.rs:193
Methodedit_board
(cmd: EditBoard, context: AtomicContextManager)
library/src/services/handlers.rs:40
Functionedit_comment
( State(bus): State<Arc<MessageBus>>, Json(cmd): Json<EditComment>, )
bin/src/routes.rs:45
Methodedit_comment
(&mut self, cmd: EditComment)
library/src/domain/board/mod.rs:67
Methodedit_comment
( cmd: EditComment, context: AtomicContextManager, )
library/src/services/handlers.rs:69
Methodfmt
(&self, f: &mut std::fmt::Formatter<'_>)
library/src/utils/errors.rs:21
Methodfmt
(&self, f: &mut std::fmt::Formatter<'_>)
library/src/domain/mod.rs:41
Methodfrom
(value: String)
library/src/domain/commands.rs:17
Methodfrom
(value: ApplicationError)
bin/src/error.rs:8
Methodget
(&self, _aggregate_id: &str)
library/src/adapters/repositories/board_repository.rs:46
Methodget
(&self, _aggregate_id: &str)
library/src/adapters/repositories/auth_repository.rs:16
Methodhandle_outbox
(outbox: Outbox, context: AtomicContextManager)
library/src/services/handlers.rs:86
Methodhash_password
(plain_password: String)
library/src/domain/auth/entity.rs:44
Methodinto_response
(self)
bin/src/error.rs:14
Functionmain
()
bin/src/main.rs:20
Methodmessage_bus
()
library/src/bootstrap.rs:23
Methodnew
()
library/src/domain/board/mod.rs:94
Methodnew
( author: Uuid, title: impl Into<String>, content: impl Into<String>, state: B
library/src/domain/board/entity.rs:34
Methodnew
()
library/src/domain/auth/mod.rs:37
Methodnew
(id: String, email: String, password: String, nickname: String)
library/src/domain/auth/entity.rs:33
Methodnew
Creation of context manager returns context manager AND event receiver
library/src/adapters/database.rs:25
Methodnew
(aggregate_id: String, topic: String, state: String)
library/src/adapters/outbox.rs:37
Methodnew
(executor:Arc<RwLock<Executor> >)
library/src/adapters/repositories/mod.rs:38
Methodnew
( command_handler: &'static CommandHandler<AtomicContextManager>, event_handler: &'static Even
library/src/services/messagebus.rs:26
Methodnew
(context: AtomicContextManager)
library/src/services/unit_of_work.rs:28
Methodsome_dependency
(&self)
library/src/bootstrap.rs:33
Methodtag_processed
(&mut self)
library/src/adapters/outbox.rs:52
Methodtake_token_stat
(mut self, token_stat: TokenStat)
library/src/domain/auth/mod.rs:30
Functiontest_add_board
()
tests/repository.rs:19
Functiontest_add_comment
()
tests/service.rs:103
Functiontest_connection
()
tests/database.rs:17
Functiontest_convert_event
()
tests/outbox.rs:73
Functiontest_create_account
()
library/src/domain/auth/mod.rs:53
Functiontest_create_board
()
library/src/domain/board/mod.rs:116
Functiontest_create_board
()
tests/service.rs:22
Functiontest_create_board_leaves_outbox
()
tests/outbox.rs:51
Functiontest_create_comment
()
tests/repository.rs:183
Functiontest_create_hashed_password
()
library/src/domain/auth/entity.rs:65
Functiontest_delete_board
()
tests/repository.rs:92
next →1–100 of 118, ranked by callers