Functions — github.com/Actyx/Actyx

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771

↓ 20 callersMethodinto_iter

(self)

rust/actyx/ax-core/src/trees/tags.rs:182

↓ 20 callersFunctionl

(x: &'static str)

rust/actyx/ax-core/src/trees/dnf.rs:84

↓ 20 callersFunctionmk_offset

(o: u32)

rust/actyx/ax-types/src/offset.rs:803

↓ 20 callersFunctionsetup

()

js/sdk/src/internal_common/event-fns-impl.spec.ts:138

↓ 20 callersFunctionsetup_logger

Sets up a logging, defaulting to `warn` level, see [`setup_logger_with_level`].

rust/actyx/ax-core/src/util/mod.rs:62

↓ 20 callersMethodupdate_settings

Tries to replace the settings at given `scope` to `settings`. Unless `force` is set, providing a non-conformant (according to the installed schema) se

rust/actyx/ax-core/src/settings/repository.rs:133

↓ 19 callersMethodbuild

(&self, stream: StreamId)

rust/actyx/ax-core/src/trees/query.rs:48

↓ 19 callersFunctionfetch

(input, init)

js/sdk/src/v2/blobSnapshotStore.ts:87

↓ 19 callersMethodor

* Add an alternative set we may also match. E.g. tag0.or(tag1.and(tag2)).or(tag1.and(tag3)) will match: * Events with tag0; Events with both tag1 a

js/sdk/src/types/tags.ts:63

↓ 19 callersMethodset

( &self, name: ActyxName, cid: Cid, level: PersistenceLevel, public: b

rust/actyx/ax-core/src/api/ans.rs:133

↓ 18 callersMethodadd_route

Add a new route to the routing table. Attempts to add the target stream as well. If a new stream number is allocated returns it. Warning: _Does not c

rust/actyx/ax-core/src/swarm/mod.rs:2050

↓ 18 callersMethodlen

(&self)

rust/actyx/ax-core/src/trees/axtrees.rs:238

↓ 18 callersFunctionload_schema

(path: PathBuf)

rust/actyx/ax-core/tests/integration_test.rs:8

↓ 18 callersMethodmeta

(&self)

rust/actyx/ax-core/src/runtime/value.rs:162

↓ 18 callersMethodpush

(&mut self, key: &treediff::value::Key)

rust/actyx/ax-core/src/settings/json_differ.rs:26

↓ 18 callersMethodquery

Returns a builder to query events. Query order defined in the query itself takes precedence over options. See [`Query::with_order`] for more informat

rust/sdk/src/client.rs:374

↓ 18 callersFunctionrepo

(path: &TempDir)

rust/actyx/ax-core/tests/integration_test.rs:12

↓ 18 callersFunctionstream_id

(stream_nr: u64)

rust/actyx/ax-types/src/offset.rs:799

↓ 18 callersMethodtoString

* Convert to an Actyx Event Service query string.

js/sdk/src/types/tags.ts:77

↓ 17 callersFunctionassert_err_response

(resp: Response<Bytes>, status: http::StatusCode, json: serde_json::Value)

rust/actyx/ax-core/src/api/tests.rs:93

↓ 17 callersFunctionemit

(computed: impl FnOnce() -> T, changed: bool, original: &T)

rust/actyx/ax-aql/src/language/rewrite_impl.rs:265

↓ 17 callersMethodencode

(&self, c: DagCborCodec, w: &mut W)

rust/actyx/ax-types/src/tags.rs:162

↓ 17 callersFunctionsetup

(store: &BanyanStore)

rust/actyx/ax-core/src/api/events/service.rs:699

↓ 17 callersMethodsubscribe

( &self, app_id: AppId, request: SubscribeRequest, )

rust/actyx/ax-core/src/api/events/service.rs:251

↓ 17 callersMethodtake_until_condition

Take from this stream up to and including the element on which the predicate turns true.

rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:113

↓ 16 callersMethodappend

(&mut self, other: Self)

rust/actyx/ax-core/src/util/mod.rs:107

↓ 16 callersMethodapply

* Apply these tags to an event that they may legally be attached to (according to the tag's type `E`).

js/sdk/src/types/tags.ts:119

↓ 16 callersMethodas_bytes

(&self)

rust/actyx/ax-types/src/event/payload.rs:70

↓ 16 callersMethodas_f64

(&self)

rust/actyx/ax-aql/src/language/number_impl.rs:24

↓ 16 callersMethodas_number

(&self)

rust/actyx/ax-core/src/runtime/value.rs:210

↓ 16 callersFunctioneq

(a: Settings, b: Settings)

js/node-manager/src/client/components/SettingsEditor.tsx:12

↓ 16 callersFunctionexpectResultEq

(op: () => void, ...expected: unknown[])

js/sdk/src/internal_common/event-fns-impl.spec.ts:107

↓ 16 callersFunctionget

(json: &Value, ptr: &str)

rust/actyx/ax/tests/smoke.rs:208

↓ 16 callersMethodget_or_create_own_stream

(&mut self, stream_nr: StreamNr)

rust/actyx/ax-core/src/swarm/mod.rs:504

↓ 16 callersFunctiono

(s: &str)

rust/actyx/ax/tests/version_compat.rs:381

↓ 16 callersMethodrewrite

(&self, surfer: &mut impl Galactus)

rust/actyx/ax-aql/src/language/rewrite_impl.rs:37

↓ 16 callersFunctionroot

()

rust/actyx/ax-core/src/settings/scope.rs:238

↓ 16 callersMethodspawn

Bootstraps the application, and returns a handle structure.

rust/actyx/ax-core/src/node/mod.rs:282

↓ 16 callersMethodspawn_task

Spawns a new task that will be shutdown when [`BanyanStore`] is dropped.

rust/actyx/ax-core/src/swarm/mod.rs:665

↓ 16 callersMethodvalidate

(&self, enabled: &[String], endpoint: Endpoint)

rust/actyx/ax-core/src/runtime/features.rs:127

↓ 16 callersFunctionvalidateOrThrow

(decoder: t.Decoder<any, T>)

js/sdk/src/util/io.ts:25

↓ 15 callersMethoddrain

Feed all values into a supermassive black hole and return a Future that completes when done.

rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:171

↓ 15 callersMethodformat

format a nodeid using the crypt alphabet, which is order preserving

rust/actyx/ax-types/src/scalars.rs:126

↓ 15 callersMethodgenerate_key_pair

Generate a new Ed25519 key pair and return its key_id The key pair is stored in this KeyStore. Callers should make sure to persist the store with `du

rust/actyx/ax-core/src/crypto/keystore.rs:104

↓ 15 callersMethodinsert

(&mut self, tag: Tag)

rust/actyx/ax-types/src/tags.rs:282

↓ 15 callersFunctionrender_simple_expr

(w: &mut impl Write, e: &SimpleExpr)

rust/actyx/ax-aql/src/language/render.rs:106

↓ 15 callersFunctionsetup_env

()

rust/actyx/swarm/harness/src/lib.rs:107

↓ 14 callersMethodappend

Append events to a stream, publishing the new data.

rust/actyx/ax-core/src/swarm/mod.rs:1351

↓ 14 callersMethodblob_put

(&self, app_id: AppId, path: String, mime_type: String, data: &[u8])

rust/actyx/ax-core/src/swarm/blob_store.rs:75

↓ 14 callersFunctioncli

()

rust/actyx/ax/tests/cli.rs:26

↓ 14 callersMethodconnect

(&self)

rust/actyx/ax/src/cmd/mod.rs:64

↓ 14 callersFunctionctx

()

rust/actyx/ax-core/src/runtime/eval.rs:673

↓ 14 callersFunctionde

(from: &'de str, expected: T)

rust/actyx/ax-types/src/offset.rs:928

↓ 14 callersFunctionl

(tag: &'static str)

rust/actyx/ax-core/src/trees/query.rs:480

↓ 14 callersMethodpeer_id

(&self)

rust/actyx/swarm/harness/src/lib.rs:79

↓ 14 callersMethodstarts_with

(&self, other: &Scope)

rust/actyx/ax-core/src/settings/scope.rs:175

↓ 14 callersMethodstream_filtered_chunked

( &self, stream_id: StreamId, range: RangeInclusive<u64>, query: Q, )

rust/actyx/ax-core/src/swarm/mod.rs:1478

↓ 14 callersMethodwith

(head: impl Into<String>, tail: &[&dyn ToIndex])

rust/actyx/ax-aql/src/language/mod.rs:575

↓ 13 callersMethodas_bool

(&self)

rust/actyx/ax-core/src/runtime/value.rs:226

↓ 13 callersFunctionbuffer

()

js/sdk/src/internal_common/event-fns-impl.spec.ts:96

↓ 13 callersMethodclose

()

js/sdk/src/internal_common/multiplexedWebSocket.ts:130

↓ 13 callersMethodfrom

(q: ax_aql::Query<'_>, app_id: AppId)

rust/actyx/ax-core/src/runtime/query.rs:34

↓ 13 callersMethodget

Returns the current node version, associated with the `DATABANK_VERSION` constant.

rust/actyx/ax-core/src/util/version.rs:83

↓ 13 callersMethodinto

(self)

rust/release/src/os_arch.rs:153

↓ 13 callersMethodread

(&self)

rust/actyx/ax-core/src/util/variable.rs:32

↓ 13 callersMethodremove

(&mut self, tag: &Tag)

rust/actyx/ax-types/src/tags.rs:288

↓ 13 callersMethodstream

Wrap a response stream with keep-alive functionality. See [`keep_alive`](keep_alive) for more.

rust/actyx/ax-core/src/api/events/http/ndjson.rs:99

↓ 13 callersMethodstring

(&mut self)

rust/actyx/ax-aql/src/language/parser/utils.rs:43

↓ 12 callersMethodax_err

(self, code: ActyxOSCode)

rust/actyx/ax-core/src/util/formats/errors.rs:19

↓ 12 callersMethodeval

(&'c self, expr: &'c SimpleExpr)

rust/actyx/ax-core/src/runtime/eval.rs:210

↓ 12 callersMethodis_empty

(&self)

rust/actyx/ax-core/src/ax_futures_util/stream/merge_unordered.rs:39

↓ 12 callersMethodlog

(self)

rust/actyx/ax-core/src/node_connection.rs:589

↓ 12 callersFunctionnew_test_client

The normal [`Ax::new`] connects to a client, the client returned by this function is a "mock" client instead that allows us to test the builder functi

rust/sdk/src/client.rs:1358

↓ 12 callersMethodquery

( &self, app_id: AppId, request: QueryRequest, )

rust/actyx/ax-core/src/api/events/service.rs:91

↓ 12 callersMethodstream

Creates a [`StreamId`](struct.StreamId.html) belonging to this node ID with the given stream number

rust/actyx/ax-types/src/scalars.rs:111

↓ 12 callersMethodstream_nr

(&self)

rust/actyx/ax-core/src/swarm/streams.rs:116

↓ 12 callersFunctionuseAppState

()

js/node-manager/src/client/app-state/app-state.tsx:263

↓ 12 callersMethodwarn

(message: String)

rust/actyx/ax-types/src/service/events.rs:505

↓ 11 callersMethodadd_stream

Add a new stream to the routing table. Returns the allocated stream number.

rust/actyx/ax-core/src/swarm/mod.rs:2000

↓ 11 callersFunctionauthenticate

( node_info: NodeInfo, token: impl Filter<Extract = (Token,), Error = Rejection> + Clone, )

rust/actyx/ax-core/src/api/filters/authenticate.rs:105

↓ 11 callersFunctioncall_cli_settings_local

calls `ax settings local [..args] --working-dir [working_dir]`

rust/actyx/ax/tests/cli.rs:206

↓ 11 callersMethoddecode

(c: C, r: &mut R)

rust/actyx/ax-core/src/swarm/discovery.rs:125

↓ 11 callersFunctiondecorateEConnRefused

(errMsg: string, triedToContact: string)

js/sdk/src/internal_common/errors.ts:7

↓ 11 callersFunctionfirst

()

rust/actyx/ax-core/src/settings/scope.rs:315

↓ 11 callersMethodio

(self, ctx: impl AsRef<str>)

rust/actyx/ax/src/cmd/events/restore.rs:55

↓ 11 callersMethodis_anti

(&self)

rust/actyx/ax-core/src/runtime/value.rs:166

↓ 11 callersFunctionmkRPC

( ipcCode: string, //requestEncoder: io.Encoder<Req, object>, request: io.Type<Req, object, unknown>,

js/node-manager/src/common/ipc.ts:58

↓ 11 callersFunctionmkRpc

(rpc: RPC<Req, Resp>)

js/node-manager/src/client/util/index.ts:97

↓ 11 callersMethodoffset

(&self)

rust/actyx/ax-core/src/swarm/streams.rs:167

↓ 11 callersMethodproject

Read and project out a value. This can be cheaper than using get_cloned()

rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:198

↓ 11 callersFunctionsetupRpc

( window: BrowserWindow, rpc: RPC<Req, Resp>, action: (req: Req) => Promise<Resp>, )

js/node-manager/src/node/ipc.ts:50

↓ 11 callersMethodstore

(&self)

rust/actyx/ax-core/src/runtime/eval.rs:100

↓ 11 callersFunctionvalidate_signed_manifest

( manifest: &AppManifest, ax_public_key: &PublicKey, licensing: &Licensing, )

rust/actyx/ax-core/src/api/auth/validate_signed_manifest.rs:13

↓ 10 callersFunctionTag

(rawTagString: string, extractId?: (e: E) => string)

js/sdk/src/types/tags.ts:193

↓ 10 callersMethodas_ref

(&self)

rust/actyx/ax-core/src/crypto/public.rs:174

↓ 10 callersFunctioncurrent

()

js/sdk/src/util/runStats.ts:180

↓ 10 callersMethodcurrent

()

rust/release/src/os_arch.rs:121

↓ 10 callersFunctionend

(name: string, from: Timestamp, to: Timestamp)

js/sdk/src/util/runStats.ts:212

↓ 10 callersMethodexec

(&mut self, update: impl FnOnce(&mut Transaction) -> R)

rust/actyx/ax-core/src/settings/database.rs:75

↓ 10 callersMethodexists

(base_dir: impl AsRef<Path>)

rust/actyx/ax-core/src/settings/database.rs:33

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