Functions — github.com/cosmonic-labs/concordance

hub / github.com/cosmonic-labs/concordance / functions

Functions335 in github.com/cosmonic-labs/concordance

⨍ Functions 335◇ Types & classes 145

↓ 63 callersMethodinto

(self)

examples/bankaccount/projector/src/genimpl.rs:78

↓ 35 callersMethodas_ref

(&self)

capability-provider/src/natsclient/mod.rs:102

↓ 32 callersFunctiondeserialize

( buf: &'de [u8], )

examples/bankaccount/model/src/lib.rs:9

↓ 32 callersFunctionserialize

(data: &T)

examples/bankaccount/model/src/lib.rs:15

↓ 18 callersFunctiondeserialize_json

( buf: &'de [u8], )

examples/bankaccount/aggregate/src/genimpl.rs:156

↓ 15 callersMethodack

Acks this message. This should be called when all work related to this message has been completed. If this is called before work is done (e.g. like se

capability-provider/src/natsclient/mod.rs:39

↓ 15 callersFunctionclear_streams

(js: async_nats::jetstream::Context)

capability-provider/src/natsclient/mod.rs:145

↓ 14 callersFunctionget

(ctx: &Context, kv: &KeyValueSender<WasmHost>, key: &str)

examples/bankaccount/projector/src/store.rs:228

↓ 11 callersFunctioncreate_js_context

()

capability-provider/src/natsclient/mod.rs:140

↓ 10 callersMethodnack

(&mut self)

capability-provider/src/natsclient/mod.rs:61

↓ 9 callersMethodensure_streams

(&self)

capability-provider/src/natsclient/natsconn.rs:21

↓ 8 callersFunctiondeserialize_json

( buf: &'de [u8], )

examples/bankaccount/projector/src/genimpl.rs:67

↓ 8 callersFunctioninbound_to_node

(g: &Graph, n: &Node)

crates/concordance-gen/src/model.rs:361

↓ 7 callersFunctionget_nodes_by_prefix

Whether a unique entity appears as an object or a subject, it is unique by its URI So this function gathers all unique entities with a given URI prefi

crates/concordance-gen/src/model.rs:327

↓ 7 callersFunctionset

(ctx: &Context, kv: &KeyValueSender<WasmHost>, key: String, value: String)

examples/bankaccount/projector/src/store.rs:203

↓ 6 callersFunctiondeserialize_json

( buf: &'de [u8], )

examples/bankaccount/process_manager/src/genimpl.rs:60

↓ 6 callersMethodfetch_state

( &self, actor_role: &ActorRole, entity_name: &str, key: &str, )

capability-provider/src/state.rs:45

↓ 6 callersFunctiongenerate_ld

(hm: HashMap<String, String>)

capability-provider/src/config.rs:486

↓ 4 callersFunctiondecode_event

(d: &mut wasmbus_rpc::cbor::Decoder<'_>)

capability-provider/src/eventsourcing.rs:109

↓ 4 callersFunctiondecode_event

(d: &mut wasmbus_rpc::cbor::Decoder<'_>)

examples/bankaccount/projector/src/eventsourcing.rs:109

↓ 4 callersFunctiondecode_event

(d: &mut wasmbus_rpc::cbor::Decoder<'_>)

examples/bankaccount/process_manager/src/eventsourcing.rs:109

↓ 4 callersFunctiondecode_event

(d: &mut wasmbus_rpc::cbor::Decoder<'_>)

examples/bankaccount/aggregate/src/eventsourcing.rs:109

↓ 4 callersFunctionmake_link_definition

(role: &str, entity_name: &str, interest: &str)

capability-provider/src/wcprovider.rs:305

↓ 4 callersFunctionoutbound_from_node

(g: &Graph, n: &Node)

crates/concordance-gen/src/model.rs:368

↓ 4 callersMethodput_link

(&self, ld: &LinkDefinition)

capability-provider/src/wcprovider.rs:180

↓ 4 callersFunctionset_ledger

( ctx: &Context, kv: &KeyValueSender<WasmHost>, key: String, ledger: AccountLedger, )

examples/bankaccount/projector/src/store.rs:219

↓ 4 callersMethodwrite_state

( &self, actor_role: &ActorRole, entity_name: &str, key: &str, state:

capability-provider/src/state.rs:22

↓ 3 callersFunctiongenerate_impl

Generates a single implementation for the given entity. The entity name and entity type must match the name and entity type as declared in the Turtle

crates/concordance-gen/src/lib.rs:19

↓ 3 callersFunctiongenerate_system_traits

Generates the set of traits as described in the model specification Turtle RDF (ttl) file. These traits are for developers to implement, while the cod

crates/concordance-gen/src/lib.rs:32

↓ 3 callersMethodis_interested_in_event

(&self, event: &ConcordanceEvent)

capability-provider/src/config.rs:249

↓ 3 callersMethodok

()

examples/bankaccount/projector/src/genimpl.rs:90

↓ 3 callersFunctionstate_key

(role: &ActorRole, entity_name: &str, key: &str)

capability-provider/src/state.rs:86

↓ 3 callersFunctionwait_for_command

( mut stream: impl Stream<Item = Result<AckableMessage<RawCommand>, async_nats::Error>> + Unpin, )

capability-provider/src/consumers/command_consumer.rs:220

↓ 2 callersMethodconsumer_name

(&self)

capability-provider/src/config.rs:254

↓ 2 callersFunctiondecode_command_list

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

capability-provider/src/eventsourcing.rs:46

↓ 2 callersFunctiondecode_command_list

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/projector/src/eventsourcing.rs:46

↓ 2 callersFunctiondecode_command_list

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/process_manager/src/eventsourcing.rs:46

↓ 2 callersFunctiondecode_command_list

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/aggregate/src/eventsourcing.rs:46

↓ 2 callersFunctiondecode_output_command

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

capability-provider/src/eventsourcing.rs:364

↓ 2 callersFunctiondecode_output_command

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/projector/src/eventsourcing.rs:364

↓ 2 callersFunctiondecode_output_command

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/process_manager/src/eventsourcing.rs:364

↓ 2 callersFunctiondecode_output_command

( d: &mut wasmbus_rpc::cbor::Decoder<'_>, )

examples/bankaccount/aggregate/src/eventsourcing.rs:364

↓ 2 callersFunctionencode_event

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &Event, )

capability-provider/src/eventsourcing.rs:90

↓ 2 callersFunctionencode_event

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &Event, )

examples/bankaccount/projector/src/eventsourcing.rs:90

↓ 2 callersFunctionencode_event

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &Event, )

examples/bankaccount/process_manager/src/eventsourcing.rs:90

↓ 2 callersFunctionencode_event

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &Event, )

examples/bankaccount/aggregate/src/eventsourcing.rs:90

↓ 2 callersMethodextract_key_value_from_payload

(&self, payload: &serde_json::Value)

capability-provider/src/config.rs:107

↓ 2 callersMethodextract_max_messages_per_batch

(&self)

capability-provider/src/config.rs:115

↓ 2 callersFunctionfind_node

(g: &Graph, name: &str, prefix: &str)

crates/concordance-gen/src/model.rs:313

↓ 2 callersFunctionget_aggregates

(g: &Graph)

crates/concordance-gen/src/model.rs:271

↓ 2 callersFunctionget_commands

(g: &Graph)

crates/concordance-gen/src/model.rs:285

↓ 2 callersFunctionget_events

(g: &Graph)

crates/concordance-gen/src/model.rs:278

↓ 2 callersFunctionget_node_name

(n: &Node)

crates/concordance-gen/src/model.rs:384

↓ 2 callersFunctionget_notifiers

(g: &Graph)

crates/concordance-gen/src/model.rs:306

↓ 2 callersFunctionget_process_managers

(g: &Graph)

crates/concordance-gen/src/model.rs:292

↓ 2 callersFunctionget_projectors

(g: &Graph)

crates/concordance-gen/src/model.rs:299

↓ 2 callersFunctionpublish_command

( client: &async_nats::Client, entity_name: &str, cmd: &RawCommand, )

capability-provider/src/natsclient/mod.rs:151

↓ 2 callersFunctionpublish_event

( client: &async_nats::Client, event_type: &str, raw: &str, )

capability-provider/src/natsclient/mod.rs:166

↓ 2 callersMethodremove_state

( &self, msg: &mut AckableMessage<CloudEvent>, key: &str, )

capability-provider/src/workers/aggregate_event.rs:172

↓ 2 callersFunctionwait_for_event

( mut stream: impl Stream<Item = Result<AckableMessage<CloudEvent>, async_nats::Error>> + Unpin, )

capability-provider/src/consumers/event_consumer.rs:192

↓ 1 callersMethodadd_aggregate_cmd_consumer

This is a command consumer that uses an aggregate-specific worker. This worker knows how to supply the aggregate with its internal state when applying

capability-provider/src/wcprovider.rs:118

↓ 1 callersMethodadd_aggregate_event_consumer

This will add an event consumer for aggregates that will pull events, ask the aggregate to apply the event to state, and persist the state. No events

capability-provider/src/wcprovider.rs:144

↓ 1 callersMethodadd_consumer

Adds a consumer and the appropriate worker to the provider's consumer manager, which will in turn create or bind to an existing NATS consumer

capability-provider/src/wcprovider.rs:51

↓ 1 callersMethodadd_general_event_consumer

Adds a consumer to the manager for notifiers. This is currently a generic worker because notifiers have just the simple stateless event handler contra

capability-provider/src/wcprovider.rs:68

↓ 1 callersMethodadd_process_manager_consumer

(&self, decl: &InterestDeclaration)

capability-provider/src/wcprovider.rs:91

↓ 1 callersMethodadjust_state

( &self, msg: &mut AckableMessage<CloudEvent>, state_ack: Result<StateAck, RpcError>,

capability-provider/src/workers/aggregate_event.rs:100

↓ 1 callersMethodapply_event

(&self, ctx: &Context, arg: &EventWithState)

capability-provider/src/eventsourcing.rs:1011

↓ 1 callersMethodapply_stateless_event

(&self, ctx: &Context, arg: &Event)

capability-provider/src/eventsourcing.rs:1218

↓ 1 callersMethodcustom_ack

(&mut self, kind: AckKind)

capability-provider/src/natsclient/mod.rs:68

↓ 1 callersMethoddispatch_commands

( &self, msg: &mut AckableMessage<CloudEvent>, ack: &ProcessManagerAck, )

capability-provider/src/workers/process_manager.rs:124

↓ 1 callersMethoddo_work

(&self, message: AckableMessage<Self::Message>)

capability-provider/src/consumers/manager.rs:262

↓ 1 callersFunctionencode_command_list

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &CommandList, )

capability-provider/src/eventsourcing.rs:30

↓ 1 callersFunctionencode_command_list

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &CommandList, )

examples/bankaccount/projector/src/eventsourcing.rs:30

↓ 1 callersFunctionencode_command_list

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &CommandList, )

examples/bankaccount/process_manager/src/eventsourcing.rs:30

↓ 1 callersFunctionencode_command_list

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &CommandList, )

examples/bankaccount/aggregate/src/eventsourcing.rs:30

↓ 1 callersFunctionencode_output_command

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &OutputCommand, )

capability-provider/src/eventsourcing.rs:343

↓ 1 callersFunctionencode_output_command

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &OutputCommand, )

examples/bankaccount/projector/src/eventsourcing.rs:343

↓ 1 callersFunctionencode_output_command

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &OutputCommand, )

examples/bankaccount/process_manager/src/eventsourcing.rs:343

↓ 1 callersFunctionencode_output_command

( mut e: &mut wasmbus_rpc::cbor::Encoder<W>, val: &OutputCommand, )

examples/bankaccount/aggregate/src/eventsourcing.rs:343

↓ 1 callersMethodevent_starts_new_process

(&self, event_type: &str)

capability-provider/src/config.rs:455

↓ 1 callersFunctiongenerate_doc

Generate markdown documentation based on the model specification Turtle RDF (ttl) file. This function emits a number of markdown files, an index file

crates/concordance-gen/src/lib.rs:53

↓ 1 callersMethodget_nats_connection

(&self)

capability-provider/src/config.rs:57

↓ 1 callersFunctionget_node_description

(g: &Graph, n: &Node)

crates/concordance-gen/src/model.rs:346

↓ 1 callersFunctionget_or_create_bucket

(js: &Context)

capability-provider/src/state.rs:97

↓ 1 callersMethodhandle_command

(&self, ctx: &Context, arg: &StatefulCommand)

capability-provider/src/eventsourcing.rs:991

↓ 1 callersMethodhandle_event

( &self, ctx: &Context, arg: &EventWithState, )

capability-provider/src/eventsourcing.rs:1113

↓ 1 callersMethodhas_consumer

Checks if this manager has a consumer for the given interest declaration. Returns `false` if it doesn't exist or has stopped

capability-provider/src/consumers/manager.rs:72

↓ 1 callersFunctioninitialize_account

Creates a new AccountLedger instance with an initial transaction as a deposit, sets the current balance to the initial amount

examples/bankaccount/projector/src/store.rs:14

↓ 1 callersFunctionis_meta_predicate

(n: &Node)

crates/concordance-gen/src/model.rs:376

↓ 1 callersMethodlink

(&self, name: &str)

crates/concordance-gen/src/model.rs:234

↓ 1 callersFunctionlowercase_ld_keys

(ld: LinkDefinition)

capability-provider/src/config.rs:280

↓ 1 callersFunctionparse_process_manager_interest

(input: &str)

capability-provider/src/config.rs:460

↓ 1 callersMethodprefix

(&self)

crates/concordance-gen/src/model.rs:222

↓ 1 callersFunctionpublish_es_event

( nc: &async_nats::Client, event: ConcordanceEvent, )

capability-provider/src/events.rs:20

↓ 1 callersFunctionpublish_raw_command

( nc: &async_nats::Client, cmd: RawCommand, stream: &str, )

capability-provider/src/events.rs:41

↓ 1 callersFunctionrecord_deposit

Records a deposit by adding a `LedgerLine` to the end of the previously stored ledger and recording the new balance.

examples/bankaccount/projector/src/store.rs:38

↓ 1 callersFunctionrecord_funds_reserved

Records a reservation of funds by adding a funds reserved transaction to the end of the ledger and recording the newly adjusted balance

examples/bankaccount/projector/src/store.rs:119

↓ 1 callersFunctionrecord_withdrawal

Records a withdrawal from an account by adding a withdrawal ledger item to the ledger and recording the new balance

examples/bankaccount/projector/src/store.rs:76

↓ 1 callersFunctionrelease_reserved_funds

Releases previously reserved funds by adding a funds released transaction to the end of the ledger and recording the updated balance

examples/bankaccount/projector/src/store.rs:161

↓ 1 callersMethodremove_state

( &self, actor_role: &ActorRole, entity_name: &str, key: &str, )

capability-provider/src/state.rs:66

next →1–100 of 335, ranked by callers