MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 589 callersMethodmap
(&self, f: impl FnMut(&T) -> U)
rust/actyx/ax-aql/src/language/non_empty.rs:8
↓ 562 callersMethodinto
(&self)
rust/actyx/ax-aql/src/language/mod.rs:491
↓ 481 callersMethodclone
(&self)
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:86
↓ 234 callersFunctionfrom
(q: Query)
rust/actyx/ax-aql/src/language/parser/mod.rs:698
↓ 213 callersFunctiondefault
()
rust/actyx/ax-core/src/api/licensing.rs:76
↓ 130 callersMethodnext
(mut s: Pin<&mut (dyn Stream<Item = SubscribeResponse> + Send)>)
rust/actyx/ax-core/src/api/events/service.rs:669
↓ 127 callersMethodclone
(&self)
rust/actyx/ax-types/src/types/arcval.rs:76
↓ 106 callersMethodcontext
(self, context: F)
rust/sdk/src/client.rs:1296
↓ 100 callersFunctiono
(s: &str)
rust/actyx/ax/tests/smoke.rs:211
↓ 97 callersMethodas_str
(&self)
rust/actyx/ax-core/src/runtime/value.rs:230
↓ 96 callersMethoditer
(&self)
rust/actyx/ax-core/src/util/mod.rs:136
↓ 92 callersMethodlock
Acquire an async lock to modify this stream
rust/actyx/ax-core/src/swarm/streams.rs:100
↓ 91 callersMethodpush
(&self, remote: &str, branch_name: &str)
rust/release/src/repo.rs:63
↓ 87 callersMethoditer
(&self)
rust/actyx/ax-types/src/tags.rs:298
↓ 86 callersMethodinto_iter
(self)
rust/actyx/ax-core/src/util/mod.rs:187
↓ 80 callersMethodand
* Add more tags to this requirement. E.g `Tag<FooEvent>('foo').and(Tag<BarEvent>('bar'))` will require both 'foo' and 'bar'.
js/sdk/src/types/tags.ts:102
↓ 79 callersMethodpush
Add the given stream to the merge pool.
rust/actyx/ax-core/src/ax_futures_util/stream/merge_unordered.rs:44
↓ 78 callersMethodinsert
(&mut self, tag: ScopedTag)
rust/actyx/ax-core/src/trees/tags.rs:132
↓ 75 callersMethodlog
(&mut self, s: impl AsRef<str>)
rust/actyx/ax/src/cmd/events/dump.rs:71
↓ 71 callersMethodsend
(&mut self, message: NodeEvent)
rust/actyx/ax-core/src/node/node_impl.rs:271
↓ 68 callersMethodpush
(&mut self, op: Operation)
rust/actyx/ax-aql/src/language/mod.rs:468
↓ 67 callersMethodparse
(s: &'a str)
rust/actyx/ax-aql/src/language/query_impl.rs:5
↓ 67 callersMethodparse
(text: &str)
rust/actyx/ax-core/src/trees/tags.rs:68
↓ 62 callersMethodinto_iter
(self)
rust/actyx/ax-types/src/tags.rs:250
↓ 62 callersMethodlen
(&self)
rust/actyx/ax-core/src/trees/tags.rs:136
↓ 62 callersFunctionparse
(s: String)
rust/actyx/ax-core/src/settings/repository.rs:80
↓ 59 callersFunctionempty
()
rust/actyx/ax-core/src/swarm/mod.rs:2104
↓ 59 callersFunctionrequest
(task: &mut Sender<Task>, f: F, extract: F2)
rust/actyx/ax-core/src/node_connection.rs:463
↓ 55 callersMethodsend
Sends a value. The only reason this can fail is if the receiver has been dropped.
rust/actyx/ax-core/src/ax_futures_util/stream/latest_channel.rs:53
↓ 54 callersFunctionchannel
A channel that is bounded to a size of 1, so always just remembers the latest element Sending is always possible, and replaces the most recent value r
rust/actyx/ax-core/src/ax_futures_util/stream/latest_channel.rs:14
↓ 53 callersMethodmk_cbor
(&self, f: impl FnOnce(CborBuilder<WithOutput>) -> CborOwned)
rust/actyx/ax-core/src/runtime/eval.rs:142
↓ 52 callersMethodipfs
Returns the underlying [`Ipfs`].
rust/actyx/ax-core/src/swarm/mod.rs:1198
↓ 51 callersMethodwrite_str
(&mut self, s: &str)
rust/actyx/ax/tests/smoke.rs:63
↓ 50 callersMethodget
(&self, link: &Sha256Digest)
rust/actyx/ax-core/src/swarm/sqlite.rs:40
↓ 49 callersMethodclone
(&self)
rust/actyx/swarm/harness/src/pinned_resource.rs:22
↓ 49 callersFunctionspawn
( working_dir: PathBuf, runtime: Runtime, bind_to: BindTo, log_no_color: bool, log_as_json
rust/actyx/ax-core/src/node/mod.rs:80
↓ 48 callersMethoddiv
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:411
↓ 47 callersMethodtry_into
(self)
rust/actyx/ax-core/src/certs/app_manifest.rs:38
↓ 46 callersMethodas_ref
(&self)
rust/actyx/ax-core/src/trees/tags.rs:154
↓ 46 callersFunctionpublish
(service: &EventService, tags: TagSet, data: u32)
rust/actyx/ax-core/src/api/events/service.rs:720
↓ 45 callersFunctionall
()
js/sdk/src/globals.ts:24
↓ 45 callersMethodfeed
(&mut self, input: Option<Value>, cx: &Context<'_>)
rust/actyx/ax-core/src/runtime/query.rs:172
↓ 44 callersMethodlen
(&self)
rust/actyx/ax-types/src/tags.rs:99
↓ 44 callersFunctionsleep
(ms: number)
js/node-manager/src/common/util.ts:7
↓ 43 callersMethodas_slice
(&self)
rust/actyx/ax-core/src/runtime/value.rs:190
↓ 43 callersMethodis_empty
(&self)
rust/actyx/ax-types/src/tags.rs:306
↓ 43 callersFunctionmap
(x: (T, bool), f: impl FnOnce(T) -> U)
rust/actyx/ax-aql/src/language/rewrite_impl.rs:273
↓ 42 callersMethodsingle
(mut self)
rust/actyx/ax-aql/src/language/parser/utils.rs:31
↓ 41 callersMethodwith_message
(self, message: impl Into<String>)
rust/actyx/ax-core/src/util/formats/errors.rs:58
↓ 40 callersMethodis_empty
(&self)
rust/actyx/ax-core/src/trees/tags.rs:116
↓ 40 callersMethodunion
(&self, rhs: &TagSet)
rust/actyx/ax-types/src/tags.rs:318
↓ 39 callersMethodas_ref
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:26
↓ 39 callersMethodcontains
(&self, tag: &Tag)
rust/actyx/ax-types/src/tags.rs:294
↓ 39 callersMethodlen
(&self)
rust/actyx/ax-core/src/settings/scope.rs:94
↓ 38 callersMethodnext
(&mut self)
rust/actyx/swarm/harness/src/bin/quickcheck_interleaved.rs:136
↓ 37 callersMethodchild
(&self)
rust/actyx/ax-core/src/runtime/eval.rs:44
↓ 36 callersMethodas_ref
(&self)
rust/actyx/ax-types/src/tags.rs:144
↓ 36 callersMethodget
(&self, idx: usize)
rust/actyx/ax-types/src/tags.rs:310
↓ 35 callersMethoderror
(message: String)
rust/actyx/ax-types/src/service/events.rs:512
↓ 35 callersMethodid
* Returns the ID-specific variant of this particular tag, see also `withId`. * * Use this if you want to tag an event belonging to entity A with
js/sdk/src/types/tags.ts:181
↓ 35 callersMethodstream
(&mut self, reply: OneShot<StreamOf<Event<Payload>>>, runtime: &Handle, f: F)
rust/actyx/ax-core/src/swarm/event_store_ref.rs:293
↓ 34 callersMethodbind
(&mut self, name: impl Into<String>, value: Value)
rust/actyx/ax-core/src/runtime/eval.rs:112
↓ 34 callersMethodremove
(&self, name: ActyxName)
rust/actyx/ax-core/src/api/ans.rs:163
↓ 34 callersMethodsubscribe
Returns a builder to subscribe to an event query. [`Subscribe`] implements the [`Future`] trait, thus, it can be `.await`ed. Example: ```no_run use
rust/sdk/src/client.rs:394
↓ 33 callersMethodkeys
(&self)
rust/actyx/ax-core/src/ax_futures_util/future/oneshot_dispatcher.rs:48
↓ 33 callersMethodnext
(&mut self)
rust/actyx/ax-core/src/settings/scope.rs:89
↓ 33 callersMethodoutput
(opts: Self::Opt, json: bool)
rust/actyx/ax/src/cmd/mod.rs:79
↓ 32 callersMethodfind
(&self, tag: &Tag)
rust/actyx/ax-types/src/tags.rs:314
↓ 32 callersMethoditer
(&self)
rust/actyx/ax-core/src/settings/scope.rs:149
↓ 32 callersMethodmin
()
rust/actyx/ax-types/src/scalars.rs:242
↓ 32 callersFunctiontest_routes
()
rust/actyx/ax-core/src/api/tests.rs:40
↓ 31 callersMethodnode_id
(&self)
rust/actyx/ax-core/src/swarm/event_store.rs:44
↓ 31 callersFunctionparse_expires_in_as_duration
This function is much easier to test for correctness
rust/actyx/ax/src/cmd/apps/license.rs:94
↓ 30 callersMethodexecute
(&self, f: F)
rust/actyx/swarm/harness/src/api.rs:104
↓ 29 callersMethodpublish
* Publish a number of events with tags attached. * This function is the same as `emit`, only it directly returns the Promise. * * @param even
js/sdk/src/event-fns.ts:425
↓ 28 callersMethodget_settings
(&self)
rust/actyx/ax-core/src/node/host.rs:67
↓ 28 callersFunctionto_string
()
rust/actyx/ax-core/src/settings/scope.rs:252
↓ 27 callersMethodax_err_ctx
(self, code: ActyxOSCode, ctx: impl Into<String>)
rust/actyx/ax-core/src/util/formats/errors.rs:31
↓ 27 callersMethodnow
()
rust/actyx/ax-types/src/timestamp.rs:39
↓ 25 callersMethoddecode
(c: DagCborCodec, r: &mut R)
rust/actyx/ax-core/src/trees/tags.rs:85
↓ 25 callersFunctionf
(s: &str)
rust/actyx/ax-core/src/runtime/features.rs:269
↓ 25 callersMethodrun
(&self, machine: MachineId, f: F)
rust/actyx/swarm/harness/src/api.rs:50
↓ 24 callersMethoddecode
(c: DagCborCodec, r: &mut R)
rust/actyx/ax-types/src/tags.rs:156
↓ 24 callersMethodkind
(&self)
rust/actyx/ax-core/src/runtime/value.rs:198
↓ 24 callersFunctionnodeAddrValid
(addr: string)
js/node-manager/src/common/util.ts:56
↓ 23 callersMethodadd
Adds a binary blob to the store. Requires aliasing and flushing before dropping the `TempPin`. Blobs are encoded as [unixfs-v1] files. [unixfs-v1]:
rust/actyx/ax-core/src/swarm/mod.rs:1316
↓ 23 callersMethodcode
(&self)
rust/actyx/ax-core/src/util/formats/errors.rs:83
↓ 23 callersMethodencode
(&self, families: &[prometheus::proto::MetricFamily], w: &mut W)
rust/actyx/ax-core/src/swarm/metrics.rs:145
↓ 23 callersMethodpop
(&mut self)
rust/actyx/ax-core/src/settings/json_differ.rs:36
↓ 23 callersFunctionshed
(x: (T, bool), b: &mut bool)
rust/actyx/ax-aql/src/language/rewrite_impl.rs:277
↓ 22 callersMethodget
(&self, name: impl Into<ActyxName>)
rust/actyx/ax-core/src/api/ans.rs:159
↓ 22 callersFunctionrequest_single
(task: &mut Sender<Task>, f: F, extract: F2)
rust/actyx/ax-core/src/node_connection.rs:539
↓ 22 callersFunctionrun
(bin: &str)
rust/actyx/ax/tests/smoke.rs:73
↓ 21 callersMethodincludes
(&self, other: impl IntoIterator<Item = (StreamId, Offset)>)
rust/actyx/ax-types/src/offset.rs:595
↓ 21 callersMethodinner
(self)
rust/actyx/ax-aql/src/language/parser/utils.rs:35
↓ 21 callersMethodlock
(&self)
rust/actyx/ax-core/src/swarm/mod.rs:1180
↓ 21 callersFunctionr_simple_expr
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:501
↓ 21 callersMethodset_schema
(&mut self, scope: String, schema: String)
rust/actyx/ax-core/src/settings/database.rs:85
↓ 21 callersFunctionwait_for
(fut: impl futures::future::Future<Output = T> + Unpin + Send + 'static)
rust/actyx/ax-core/src/ax_futures_util/future/future_helpers.rs:4
↓ 20 callersMethodadd
(&mut self, f: Feature)
rust/actyx/ax-core/src/runtime/features.rs:123
next →1–100 of 3,158, ranked by callers