Functions — github.com/Actyx/Actyx

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771

↓ 6 callersFunctionapp_id

()

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

↓ 6 callersMethodas_i64

(self)

rust/actyx/ax-types/src/timestamp.rs:43

↓ 6 callersMethodas_json_ptr

(&self)

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

↓ 6 callersFunctionassert_dnf

(expr: TagExpr, dnf: &'static [&'static [&'static str]])

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

↓ 6 callersFunctionassert_match

(index: &TagIndex, expr: &TagExpr, expected: Vec<bool>)

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

↓ 6 callersMethodblob_del

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

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

↓ 6 callersMethodcommit

(&self, treeish: git2::Oid, message: &str)

rust/release/src/repo.rs:55

↓ 6 callersFunctiondecimal

(f: f64)

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

↓ 6 callersFunctiondeserialize

(d: D)

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

↓ 6 callersMethoddiff

(&self, right: &Self)

rust/actyx/ax-core/src/settings/json_value.rs:109

↓ 6 callersFunctiondnf

(s: &str)

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

↓ 6 callersFunctionfeatures_simple

(feat: &mut Features, expr: &SimpleExpr)

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

↓ 6 callersMethodflush

(&self)

rust/actyx/ax-core/src/node/log_tracer.rs:51

↓ 6 callersFunctionisFavorite

(store: StoreState, addr: string)

js/node-manager/src/client/screens/NodesOverview.tsx:67

↓ 6 callersMethodis_done

(&self)

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

↓ 6 callersFunctionload_identity

(identity: &Option<String>)

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

↓ 6 callersMethodlock

(&self)

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

↓ 6 callersMethodmake_feeder

(&self)

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

↓ 6 callersMethodmax_key

(&self)

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

↓ 6 callersMethodmerge_unordered

## Merge a stream of streams into a single stream This is the equivalent of RxJS `mergeMap`. The resulting stream only completes once the input strea

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

↓ 6 callersFunctionmeta

(publ: PublishResponseKey, t: &str)

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

↓ 6 callersMethodmin_key

(&self)

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

↓ 6 callersFunctionmkL

(lamport: number)

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

↓ 6 callersFunctionmkL

(lamport: number)

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

↓ 6 callersMethodoffsets

(&self)

rust/actyx/swarm/harness/src/api.rs:100

↓ 6 callersFunctionok

(path: PathBuf)

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

↓ 6 callersFunctionrange

(r: Result<i64, E>)

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

↓ 6 callersMethodrequest

(&mut self, peer_id: PeerId, request: T::Request, channel: mpsc::Sender<Response<T::Response>>)

rust/actyx/ax-core/src/libp2p_streaming_response/mod.rs:202

↓ 6 callersFunctionrespond

( node_tx: Sender<ExternalEvent>, mut channel: mpsc::Sender<ActyxOSResult<AdminRespons

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

↓ 6 callersFunctionsetup

(validity: Option<u32>)

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

↓ 6 callersFunctionsetup

()

rust/actyx/ax-core/src/certs/signature.rs:88

↓ 6 callersMethodsign

(&self, message: &[u8])

rust/actyx/ax-core/src/crypto/pair.rs:64

↓ 6 callersMethodspawn_mut

Access the protected value and possibly mutate it. Returns a `Future` that carries the result of the spawned computation.

rust/actyx/swarm/harness/src/pinned_resource.rs:65

↓ 6 callersFunctionstorePath

(app: App)

js/node-manager/src/node/store.ts:16

↓ 6 callersFunctionsystem_scope

()

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

↓ 6 callersFunctiontakeWhileInclusive

(predicate: (value: T, index: number) => boolean)

js/sdk/src/util/observable.ts:17

↓ 6 callersFunctiontoOffsets

(eventsAscending: Events)

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

↓ 6 callersMethodtransaction

(&mut self)

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

↓ 6 callersMethodtrigger

(name: string, e: any)

js/sdk/src/v2/multiplexedWebsocket.spec.ts:353

↓ 6 callersMethodverify

(&self, input: &T, key: &PublicKey)

rust/actyx/ax-core/src/certs/signature.rs:58

↓ 6 callersFunctionwithPeer

( addr: string, fn: Fn, )

js/node-manager/src/client/agents/node-manager.tsx:425

↓ 6 callersMethodwrite_cbor

(&self, w: W)

rust/actyx/ax-core/src/swarm/gossip_protocol.rs:22

↓ 5 callersFunctiona

(s: &str)

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

↓ 5 callersMethodas_ref

(&self)

rust/actyx/ax-types/src/event/opaque.rs:40

↓ 5 callersFunctionassertPayloadsEqual

(actual: ActyxEvent[], expected: Events)

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

↓ 5 callersFunctionauthorize

(node_info: NodeInfo)

rust/actyx/ax-core/src/api/files/mod.rs:419

↓ 5 callersFunctionauthorize

(node_info: NodeInfo)

rust/actyx/ax-core/src/api/events/http/filters.rs:15

↓ 5 callersFunctionax_err

(code: ActyxOSCode, message: String)

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

↓ 5 callersFunctionbounded_channel

()

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

↓ 5 callersMethodcalculate_version

( &self, product: &Product, ignore: &VersionsIgnoreFile, )

rust/release/src/versions_file.rs:147

↓ 5 callersFunctioncheck

(array: ReadonlyArray<number>)

js/sdk/src/util/binarySearch.spec.ts:16

↓ 5 callersFunctioncreate_mutlipart

(files: BTreeMap<&str, Vec<u8>>)

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

↓ 5 callersFunctiondeserialize

(deserializer: D)

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

↓ 5 callersFunctionevents

()

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

↓ 5 callersMethodevents_url

(&self, path: &str)

rust/sdk/src/client.rs:160

↓ 5 callersFunctionfake_setup

(bytes: &[u8], f: F)

rust/actyx/ax-core/src/libp2p_streaming_response/tests/mod.rs:176

↓ 5 callersFunctionfilter_tree

Filter a single tree by a query

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

↓ 5 callersMethodflush

(&mut self)

rust/actyx/ax/src/cmd/events/dump.rs:323

↓ 5 callersFunctionget

(store: BanyanStore, node_info: NodeInfo)

rust/actyx/ax-core/src/api/files/mod.rs:222

↓ 5 callersMethodget

Retrieves the offset stored for the given source

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

↓ 5 callersMethodget

(&self, link: &Sha256Digest)

rust/actyx/ax/src/cmd/internal/trees/mod.rs:44

↓ 5 callersMethodget_pair

(&self, public: PublicKey)

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

↓ 5 callersMethodhead

(&self)

rust/release/src/repo.rs:29

↓ 5 callersFunctionheader_or_query_token

()

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

↓ 5 callersFunctioninterval

Create a stream of ticks starting immediately and with the given cadence.

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

↓ 5 callersMethodio

(self, ctx: impl AsRef<str>)

rust/actyx/ax/src/cmd/events/dump.rs:117

↓ 5 callersFunctionisString

(x: any)

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

↓ 5 callersMethodis_all

(&self)

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

↓ 5 callersFunctionlookup

(m: { [k: string]: V }, k: string)

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

↓ 5 callersFunctionmetadata

()

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

↓ 5 callersFunctionmkMilliseconds

(time: number)

js/sdk/src/types/various.ts:150

↓ 5 callersFunctionmkS

(stream: string)

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

↓ 5 callersFunctionmkS

(sourceId: string)

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

↓ 5 callersFunctionmk_swarm

(key: AxPrivateKey)

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

↓ 5 callersMethodmy_err

(self)

rust/actyx/ax-core/src/swarm/event_store_ref.rs:186

↓ 5 callersFunctionnodeDisplayName

(node: UiNode)

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

↓ 5 callersMethodoffset

(&self)

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

↓ 5 callersFunctionoffsetToString

(offset: Offset)

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

↓ 5 callersFunctionoffset_map

(map: &BTreeMap<StreamId, u32>)

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

↓ 5 callersMethodopen

()

js/sdk/src/v2/multiplexedWebsocket.spec.ts:339

↓ 5 callersMethodpresent

Currently validated OffsetMap

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

↓ 5 callersMethodproject

(&self, f: impl Fn(&T) -> U)

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

↓ 5 callersMethodread_request

( &mut self, _protocol: &Self::Protocol, io: &mut T, )

rust/actyx/ax-core/src/util/formats/banyan_protocol.rs:67

↓ 5 callersMethodregister

rust/actyx/ax-core/src/ax_futures_util/stream/stream_dispatcher.rs:24

↓ 5 callersFunctionreq

(onlyLocalEvents: boolean, rawTags: TagInternal[])

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

↓ 5 callersFunctionselect_single

(machine: &mut Machine<Command, Event>, timeout: Duration, f: F)

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

↓ 5 callersMethodsize_hint

(&self)

rust/actyx/ax-core/src/ax_futures_util/stream/take_until_condition.rs:95

↓ 5 callersMethodspawn

Spawn the component into its own thread, where `Component::loop_on_rx` is executed. Returns a `std::thread::JoinHandle` to the spawned thread.

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

↓ 5 callersMethodstream_known_streams

Returns a [`Stream`] of known [`StreamId`].

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

↓ 5 callersFunctionstringify

(value: &serde_json::Value)

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

↓ 5 callersFunctiontest_swarm

()

rust/actyx/ax-core/src/libp2p_streaming_response/tests/mod.rs:24

↓ 5 callersMethodto_bytes

Convert this keypair to bytes. # Returns An array of bytes, `[u8; KEYPAIR_LENGTH]`. The first `SECRET_KEY_LENGTH` of bytes is the `SecretKey`, and

rust/actyx/ax-core/src/crypto/pair.rs:82

↓ 5 callersMethodto_ed25519

Gets the underlying ed25519 public key for interop with rust crypto libs

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

↓ 5 callersMethodunion_with

Merge the other OffsetMap into this one, taking the union of their event sets.

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

↓ 5 callersMethodupdate

(&self, app_id: AppId, query: Query<'static>)

rust/actyx/ax-core/src/api/files/pinner.rs:164

↓ 5 callersFunctionuseStore

()

js/node-manager/src/client/store/index.tsx:57

↓ 5 callersMethodvalidate_app_id

(&self, app_id: &AppId)

rust/actyx/ax-core/src/certs/developer_certificate.rs:54

↓ 5 callersMethodversion

(&self)

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

↓ 5 callersFunctionwith_service

( event_service: EventService, )

rust/actyx/ax-core/src/api/events/http/filters.rs:9

↓ 5 callersMethodwith_upper_bound

Add an (inclusive) upper bound to the query. For more information on offsets, as well as lower and upper bounds refer to the [offsets and partitions]

rust/sdk/src/client.rs:795

← previous next →301–400 of 3,158, ranked by callers