Functions — github.com/Actyx/Actyx

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771

↓ 5 callersFunctionwrap

(e: Event)

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

↓ 4 callersFunctionLogger

jvm/os-android/app/src/main/java/com/actyx/android/util/Logging.kt:6

↓ 4 callersFunctionapp_id

()

rust/actyx/ax-core/src/swarm/prune.rs:488

↓ 4 callersMethodappend0

( &self, stream_nr: StreamNr, app_id: AppId, timestamp: Timestamp, eve

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

↓ 4 callersFunctionassertEntry

(expected: string = 'hello log', output: string[] = outputCapture)

js/sdk/src/util/logging.spec.ts:45

↓ 4 callersMethodbounded_backward

( &self, tag_expr: &TagExpr, from_offsets_excluding: OffsetMap, to_offsets_inc

rust/actyx/ax-core/src/swarm/event_store.rs:166

↓ 4 callersFunctioncb

(boxedChunk: EventChunk)

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

↓ 4 callersFunctioncleanUpIpcHandlers

()

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

↓ 4 callersFunctioncnt_per_tag

(cmds: &[TestCommand])

rust/actyx/swarm/harness/src/bin/quickcheck_interleaved.rs:54

↓ 4 callersFunctioncommit

(message)

rust/release/integration/test.js:37

↓ 4 callersMethoddedup

Deduplicate consecutive runs of the same value.

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

↓ 4 callersFunctiondelta_decode

(data: &mut [u64])

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

↓ 4 callersFunctiondelta_encode

(data: &mut [u64])

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

↓ 4 callersMethodderef

(&self)

rust/actyx/ax-types/src/types/arcval.rs:70

↓ 4 callersMethoddump

Write the state of this store into the given writer

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

↓ 4 callersFunctionerr

(from: &'de str, msg: &str)

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

↓ 4 callersMethodeval_from

(&'b self, expr: &'c TagExpr)

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

↓ 4 callersFunctionexpectNoResult

(op: () => void)

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

↓ 4 callersFunctionexpectResultMatches

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

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

↓ 4 callersFunctionfilter_tree_streamed

Filter a stream of trees by a query

rust/actyx/ax-core/src/trees/tests.rs:196

↓ 4 callersFunctiongetHeadHash

()

rust/release/integration/test.js:35

↓ 4 callersMethodget_cloned

(&self)

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

↓ 4 callersFunctionget_keypair

()

rust/actyx/ax-core/src/swarm/tests.rs:484

↓ 4 callersMethodget_or_create_node_id

Returns this node's NodeId

rust/actyx/ax-core/src/node/host.rs:49

↓ 4 callersMethodget_or_create_replicated_stream

(&mut self, stream_id: StreamId)

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

↓ 4 callersFunctionheader_token

()

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

↓ 4 callersMethodinfos

Infos about the latest published tree

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

↓ 4 callersFunctionisNumber

(x: any)

js/sdk/src/types/functions.ts:51

↓ 4 callersMethodjson_string

Printable representation of this stored object as JSON — the stored Payload bytes are encoded in the CBOR binary format.

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

↓ 4 callersFunctionlast_item

(drainer: &mut Drainer<T>)

rust/actyx/ax-core/src/swarm/tests.rs:92

↓ 4 callersFunctionlater

(block)

js/sdk/src/snapshotStore/inMemSnapshotStore.ts:17

↓ 4 callersFunctionlookup

(offsets: OffsetMap, source: string)

js/sdk/src/internal_common/testEventStore.ts:69

↓ 4 callersFunctionmerge

(l: number[], r: number[])

js/sdk/src/util/mergeSortedInto.spec.ts:11

↓ 4 callersFunctionmkO

(offset: number)

js/sdk/src/internal_common/types.spec.ts:25

↓ 4 callersFunctionmkO

(psn: number)

js/sdk/src/v1/types.spec.ts:24

↓ 4 callersFunctionmkTestLogger

(dump: string[])

js/sdk/src/util/logging.ts:49

↓ 4 callersFunctionnewestVersion

(versions: Version[])

web/developer.actyx.com/src/components/page-templates/releases/util.ts:18

↓ 4 callersMethodoffsets

(&self)

rust/actyx/ax-core/src/swarm/event_store.rs:121

↓ 4 callersMethodpayload

(&self)

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

↓ 4 callersFunctionpresent

()

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

↓ 4 callersMethodprint

(&self)

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

↓ 4 callersFunctionprune_stream

The timestamp parameter is used has an hack around having to use a fake system clock to make testing this function deterministic

rust/actyx/ax-core/src/swarm/prune.rs:399

↓ 4 callersMethodput

(&mut self, data: Vec<u8>)

rust/actyx/ax-core/src/swarm/sqlite.rs:61

↓ 4 callersFunctionr_string

(p: P)

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

↓ 4 callersFunctionr_tag_from_to

(p: P, f: FromTo, ctx: Context)

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

↓ 4 callersFunctionr_timestamp

(p: P)

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

↓ 4 callersFunctionr_var

(p: P, ctx: Context)

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

↓ 4 callersMethodreader

(&self)

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

↓ 4 callersMethodreceived_lamport

we received a lamport from an external source

rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:87

↓ 4 callersFunctionreply

(event_stream: S)

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

↓ 4 callersFunctionrequest_events

( task: &mut Sender<Task>, peer_id: PeerId, req: EventsRequest, )

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

↓ 4 callersFunctionrun

(bin: &str)

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

↓ 4 callersMethodset_settings

(&mut self, settings: String)

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

↓ 4 callersFunctionset_state

(swarm_state: &mut SwarmState, node_id: NodeId, status: PeerStatus)

rust/actyx/ax-core/src/node/components/swarm_observer.rs:155

↓ 4 callersFunctionsetup

()

rust/actyx/ax-core/src/certs/app_license.rs:107

↓ 4 callersMethodsize

Counts the number of offsets spanned by this OffsetMap.

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

↓ 4 callersMethodspan

(&self)

rust/actyx/ax-macros/src/lib.rs:24

↓ 4 callersMethodstream_iter

An iterator over all streams that contribute events to this OffsetMap including their offset

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

↓ 4 callersMethodsubscribe_monotonic

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

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

↓ 4 callersMethodsubscribe_monotonic

Returns a builder to subscribe to an event query. [`SubscribeMonotonic`] implements the [`Future`] trait, thus, it can be `.await`ed. Example: ```no

rust/sdk/src/client.rs:414

↓ 4 callersFunctiontestChunking

(chunkSize: number, order: EventsSortOrder)

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

↓ 4 callersFunctiontime_to_cbor

(t: Timestamp)

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

↓ 4 callersFunctiontoEventPredicate

(where: Where<unknown>)

js/sdk/src/types/functions.ts:26

↓ 4 callersMethodto_file

Write the private key encoded with a trailing newline into `path`, and the public key into `path`.pub. Files will be created, if they don't exist. If

rust/actyx/ax-core/src/private_key.rs:71

↓ 4 callersMethodtransform_stream

( &self, stream: &mut OwnStreamGuard, f: impl FnOnce(&mut Transaction, &mut AxStreamBu

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

↓ 4 callersFunctionunreachable

()

js/sdk/src/util/typescript.ts:45

↓ 4 callersMethodupdate_present

(&self, stream_id: StreamId, offset: Offset)

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

↓ 3 callersFunctionConnected

()

js/node-manager/src/client/screens/Diagnostics.tsx:34

↓ 3 callersFunction_offsetMapLookup

(m: OffsetMap, s: string)

js/sdk/src/types/offsetMap.ts:37

↓ 3 callersFunctionaccept

(mime_types: &'static [&'static str])

rust/actyx/ax-core/src/api/filters/accept.rs:6

↓ 3 callersFunctionaccept_json

()

rust/actyx/ax-core/src/api/filters/accept.rs:33

↓ 3 callersFunctionaccept_ndjson

()

rust/actyx/ax-core/src/api/filters/accept.rs:38

↓ 3 callersMethodanti

(&mut self)

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

↓ 3 callersMethodappend

(&self, other: &Self)

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

↓ 3 callersFunctionappendLineToVersionsFile

(line)

rust/release/integration/test.js:31

↓ 3 callersMethodappend_stream_mapping_event

(&self, name: String, number: StreamNr)

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

↓ 3 callersMethodas_array

(&self)

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

↓ 3 callersFunctionassert_complete

(ws: &mut test::WsClient, id: u32)

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

↓ 3 callersFunctionassert_listen

(e: ListenerEvent)

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

↓ 3 callersFunctionassert_node_shutdown

(node_tx: Sender<ExternalEvent>)

rust/actyx/ax-core/src/node/node_impl.rs:698

↓ 3 callersFunctionassert_stream

( node_id: NodeId, stream: impl Stream<Item = Event<Payload>> + 'static, selection: Ev

rust/actyx/ax-core/src/swarm/event_store.rs:323

↓ 3 callersFunctionautoExtract

(event: unknown)

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

↓ 3 callersMethodax_invalid_input

(self)

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

↓ 3 callersMethodbackward_stream

(&self, selection: StreamEventSelection)

rust/actyx/ax-core/src/swarm/event_store.rs:66

↓ 3 callersMethodblob_get

(&self, app_id: AppId, path: String)

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

↓ 3 callersMethodborrow

(&self)

rust/actyx/swarm/cli/src/lib.rs:354

↓ 3 callersMethodbounded_streams

( &self, tag_expr: &TagExpr, from_offsets_excluding: OffsetMap, to_offsets_inc

rust/actyx/ax-core/src/swarm/event_store.rs:84

↓ 3 callersFunctioncallbackWhenReplaced

( query: Where<E>, startingOffsets: OffsetMap, initial: ActyxEvent<E> | undefined, onEvent: (e

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

↓ 3 callersFunctionconn_errors

( connects: &mut HashMap<Multiaddr, Vec<Sender<Result<PeerId, ActyxOSError>>>>, addr: &Multiaddr,

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

↓ 3 callersFunctioncreateUserKeyPair

( req: CreateUserKeyPairRequest, )

js/node-manager/src/node/tasks.ts:77

↓ 3 callersFunctionctx

()

rust/actyx/ax-core/src/runtime/operation/aggregate.rs:458

↓ 3 callersMethodcurrent_stream_ids

(&self)

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

↓ 3 callersMethoddiff

Removes a common prefix from self.

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

↓ 3 callersMethoddisplay_name

(&self)

rust/actyx/ax-types/src/app_manifest.rs:65

↓ 3 callersFunctiondownload

(package: &str, bin: &str, version: Version, dst_dir: &Path, may_skip: &mut bool)

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

↓ 3 callersMethoddump_if_cb_installed

(&mut self)

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

↓ 3 callersFunctionempty_store

()

rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:193

↓ 3 callersMethodenabled_features

(&self, pragmas: &Pragmas)

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

↓ 3 callersFunctionentriesOf

( obj: PartialRecord<K, V>, )

js/sdk/src/util/typescript.ts:84

↓ 3 callersFunctionexpectedChunks

( eventsAscending: Events, chunkSize: number, opts: { initialLowerBound?: Record<string, number>

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

← previous next →401–500 of 3,158, ranked by callers