MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 3 callersMethodfiles_get
TODO: #558
rust/sdk/src/client.rs:279
↓ 3 callersFunctionfold
( port: impl FnOnce(u16) -> anyhow::Result<SocketAddrHelper>, input: Vec<PortOrHostPort<N>>, )
rust/actyx/ax/src/cmd/run.rs:133
↓ 3 callersFunctionformat_micros
(n: u32)
rust/actyx/ax/src/cmd/nodes/inspect.rs:204
↓ 3 callersFunctionfrom_fn
(protocol_names: P, fun: F)
rust/actyx/ax-core/src/libp2p_streaming_response/upgrade.rs:7
↓ 3 callersFunctionfully_meshed
(sim: &mut Netsim<Command, E>, timeout: Duration)
rust/actyx/swarm/harness/src/lib.rs:302
↓ 3 callersMethodgenerate_json
( &self, mut tag_generator: impl FnMut(usize) -> TagSet + 'static, mut payload_generat
rust/actyx/ax-core/src/trees/tests.rs:63
↓ 3 callersFunctiongenerate_key
NOTE: I'm not sure where to put this Generate a Swarm Key
rust/actyx/ax-core/src/private_key.rs:22
↓ 3 callersMethodgetHit
(doc, formattedTitle, formattedContent)
web/developer.actyx.com/src/theme/SearchBar/lunar-search.js:23
↓ 3 callersFunctionget_az_storage_shared_access_signature
()
rust/release/src/util.rs:10
↓ 3 callersFunctionget_callback
Get the function pointer to the Callback, if initialized.
rust/actyx/node-ffi/src/lib.rs:83
↓ 3 callersMethodget_observed_streams
(&mut self)
rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:130
↓ 3 callersMethodget_settings
Returns settings for a given scope. If the `no_defaults` flag is set, settings will be unconditionally returned, even if they might be non-conformant
rust/actyx/ax-core/src/settings/repository.rs:230
↓ 3 callersMethodhead_hash
(&self)
rust/release/src/repo.rs:25
↓ 3 callersFunctionhorizonFilter
(horizon: EventKey)
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:73
↓ 3 callersMethodincrease_lamport
Increase the lamport by `increment` and return the *initial* value
rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:98
↓ 3 callersMethodincrement
(&mut self)
rust/actyx/ax-core/src/libp2p_streaming_response/mod.rs:102
↓ 3 callersFunctioninitialize
()
rust/actyx/ax-core/src/api/tests.rs:29
↓ 3 callersFunctioninitialize_repository
(base_path: &Path)
rust/actyx/ax-core/src/node/host.rs:85
↓ 3 callersMethodinternal
(self)
rust/actyx/ax-core/src/node/node_impl.rs:81
↓ 3 callersFunctioninternal_app_id
()
rust/actyx/ax-core/src/swarm/mod.rs:157
↓ 3 callersMethodinto_response
(self)
rust/actyx/ax-core/src/api/events/http/ndjson.rs:40
↓ 3 callersFunctionis_app_id
(s: &str)
rust/actyx/ax-types/src/scalar.rs:6
↓ 3 callersMethodis_authorized
Checks whether `peer` is authorized to use this API. If there are no authorized keys, any connected peer is authorized.
rust/actyx/ax-core/src/node/node_api/mod.rs:186
↓ 3 callersMethodis_empty
(&self)
rust/actyx/ax-core/src/trees/query.rs:44
↓ 3 callersMethodis_subset
(&self, that: &Self)
rust/actyx/ax-core/src/trees/tags.rs:120
↓ 3 callersFunctionkeep_alive
()
rust/actyx/ax-core/src/api/events/http/ndjson.rs:136
↓ 3 callersMethodlamport
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:172
↓ 3 callersMethodleft
(&self)
rust/actyx/ax-types/src/service/events.rs:185
↓ 3 callersFunctionlock_and_load_repo
(working_dir: &Path)
rust/actyx/ax/src/cmd/settings/local/mod.rs:39
↓ 3 callersFunctionlock_working_dir
(working_dir: impl AsRef<std::path::Path>)
rust/actyx/ax/src/cmd/users/addkey.rs:9
↓ 3 callersFunctionmake_events
(n: usize)
rust/actyx/swarm/harness/src/bin/quickcheck_ephemeral.rs:95
↓ 3 callersFunctionmassageError
(err: any)
js/sdk/src/util/error.ts:2
↓ 3 callersFunctionmergeSortedInto
( l: ReadonlyArray<K>, // original events r: ReadonlyArray<K>, // new events out: K[], // original event
js/sdk/src/util/mergeSortedInto.ts:19
↓ 3 callersMethodmessage
Obtain a reference to the message octets that have been signed
rust/actyx/ax-core/src/crypto/signature.rs:38
↓ 3 callersFunctionmkOffset
(n: number)
js/sdk/src/types/various.ts:105
↓ 3 callersFunctionmkTimeline
(...events: MkEvent[])
js/sdk/src/internal_common/testHelper.ts:96
↓ 3 callersFunctionmk_event
(stream_nr: u64, offset: u32)
rust/actyx/ax-types/src/offset.rs:811
↓ 3 callersFunctionmk_path
Makes sure `scope` exists within this value by creating empty objects or arrays at every level and a `null` value at the leaf if no value already exis
rust/actyx/ax-core/src/settings/json_value.rs:42
↓ 3 callersFunctionmonotonicFrom
( fishId: SessionId, subscriptions: Where<unknown>, present: OffsetMap, fixedStart: FixedStart
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:174
↓ 3 callersMethodmul
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:408
↓ 3 callersMethodnew_projection
a stream of a projection
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:211
↓ 3 callersFunctiononChange
(val: string)
js/node-manager/src/client/components/JsonEditor.tsx:43
↓ 3 callersMethodpoll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
rust/actyx/ax-core/src/ax_futures_util/stream/drain.rs:26
↓ 3 callersMethodpred
Return the predecessor to this offset
rust/actyx/ax-types/src/offset.rs:142
↓ 3 callersMethodpublished_tree
Get the last PublishedTree for a stream_id, only if it already exists
rust/actyx/ax-core/src/swarm/mod.rs:598
↓ 3 callersFunctionquery_token
Tries to extract the value given to the `access_token` query parameter.
rust/actyx/ax-core/src/api/filters/authenticate.rs:9
↓ 3 callersFunctionr_array
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:406
↓ 3 callersFunctionr_tag_expr
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:202
↓ 3 callersMethodregister
registers a sender with the dispatcher for a key `K`
rust/actyx/ax-core/src/ax_futures_util/future/oneshot_dispatcher.rs:22
↓ 3 callersFunctionregulateRemovals
(data: Internals, onChange: () => unknown)
js/node-manager/src/client/agents/node-manager.tsx:247
↓ 3 callersMethodremove
(&mut self, name: &str)
rust/actyx/ax-core/src/runtime/eval.rs:136
↓ 3 callersFunctionrender_string
(w: &mut impl Write, e: &str)
rust/actyx/ax-aql/src/language/render.rs:90
↓ 3 callersFunctionrequest_banyan
(task: &mut Sender<Task>, peer_id: PeerId, req: BanyanRequest)
rust/actyx/ax-core/src/node_connection.rs:554
↓ 3 callersMethodrewrite_spread
(&self, surfer: &mut impl Galactus)
rust/actyx/ax-aql/src/language/rewrite_impl.rs:147
↓ 3 callersMethodright
(&self)
rust/actyx/ax-types/src/service/events.rs:194
↓ 3 callersFunctionroute
( node_info: NodeInfo, store: BanyanStore, swarm_state: Reader<SwarmState>, )
rust/actyx/ax-core/src/api/node.rs:40
↓ 3 callersFunctionselect
()
rust/actyx/ax-core/src/runtime/operation/mod.rs:239
↓ 3 callersFunctionselectSnapshotKey
(r: SnapshotRow)
js/sdk/src/snapshotStore/inMemSnapshotStore.ts:37
↓ 3 callersFunctionsetup
()
rust/actyx/ax/tests/version_compat.rs:83
↓ 3 callersFunctionsetup
()
rust/actyx/ax-core/src/certs/app_manifest.rs:161
↓ 3 callersFunctionsign
(store: KeyStoreRef, n: usize)
rust/actyx/ax-core/benches/signing.rs:6
↓ 3 callersMethodsign
Sign a message with a selection of keys and return it in a SignedMessage envelope The message must not be larger than u32::MAX bytes and at least one
rust/actyx/ax-core/src/crypto/keystore.rs:132
↓ 3 callersFunctionspawn_machine
( sim: &mut Netsim<Command, Event>, net: NetworkId, path: &Path, i: u64,
rust/actyx/swarm/harness/src/bin/read_only.rs:20
↓ 3 callersFunctionspawn_with_name
(name: N, f: F)
rust/actyx/ax-core/src/node/util.rs:32
↓ 3 callersMethodsplit_last
(&self)
rust/actyx/ax-core/src/settings/scope.rs:223
↓ 3 callersMethodstop
(&mut self)
rust/actyx/ax-core/src/node/components/mod.rs:291
↓ 3 callersMethodstream_nr
(&self)
rust/actyx/ax-types/src/scalars.rs:253
↓ 3 callersMethodstreams
An iterator over all streams that contribute events to this OffsetMap
rust/actyx/ax-types/src/offset.rs:573
↓ 3 callersFunctionstringifyError
(err: any)
js/sdk/src/util/error.ts:23
↓ 3 callersMethodsucc
Return the successor to this offset, where ZERO succeeds MIN
rust/actyx/ax-types/src/offset.rs:134
↓ 3 callersFunctiontags_too_large
(tags: &[ScopedTag])
rust/actyx/ax-core/src/trees/axtrees.rs:266
↓ 3 callersMethodtest
(node_name: &str)
rust/actyx/ax-core/src/swarm/mod.rs:296
↓ 3 callersFunctiontoStr
(json: object | null | undefined, format?: boolean)
js/node-manager/src/client/components/JsonEditor.tsx:16
↓ 3 callersFunctionto_diagnostic
(err: anyhow::Error)
rust/actyx/ax-core/src/api/events/service.rs:548
↓ 3 callersFunctionto_lines
(stream: impl Stream<Item = Result<Bytes, reqwest::Error>>)
rust/sdk/src/client.rs:428
↓ 3 callersMethodto_multiaddrs
(&self)
rust/actyx/ax-core/src/util/mod.rs:111
↓ 3 callersFunctiontriggerFatalError
(browserWindow: BrowserWindow, error: FatalError)
js/node-manager/src/node/ipc.ts:40
↓ 3 callersFunctiontrigger_shutdown
(success: bool)
rust/actyx/ax-core/src/node/util.rs:110
↓ 3 callersFunctionunsupported_proto
( infos: Option<&(Option<PublicKey>, BTreeSet<String>, Option<NodeVersion>)>, choices: &[&str], tx
rust/actyx/ax-core/src/node_connection.rs:439
↓ 3 callersMethodupdate
Update entry for source if the given offset is larger than the stored one and return the previous offset for this source
rust/actyx/ax-types/src/offset.rs:584
↓ 3 callersMethodupdate_at
(&self, scope: &Scope, value: Self)
rust/actyx/ax-core/src/settings/json_value.rs:140
↓ 3 callersMethodupdate_highest_seen
Updates the highest seen for a given stream, if it is higher
rust/actyx/ax-core/src/swarm/mod.rs:1765
↓ 3 callersMethodv
(self, msg: &str)
rust/actyx/ax/tests/smoke.rs:24
↓ 3 callersFunctionvalidate
(j?: string | null)
js/node-manager/src/client/screens/Settings.tsx:80
↓ 3 callersFunctionvalidate
(manifest: &AppManifest, ax_public_key: &PublicKey)
rust/actyx/ax-core/src/certs/app_manifest.rs:117
↓ 3 callersMethodvalidate
(&self, ax_public_key: &PublicKey)
rust/actyx/ax-core/src/certs/developer_certificate.rs:50
↓ 3 callersMethodvalidate
(&self, ax_public_key: &PublicKey)
rust/actyx/ax-core/src/certs/app_license.rs:70
↓ 3 callersFunctionwait_for_listen_addr
(machine: &mut Machine<Command, Event>)
rust/actyx/swarm/harness/src/bin/health.rs:89
↓ 3 callersMethodwith_order
Set the query's event order. By default, this value is set to [`Order::Asc`], however, order set in the query takes precedence over the order defined
rust/sdk/src/client.rs:883
↓ 3 callersMethodwith_spread
(self, spread: bool)
rust/actyx/ax-aql/src/language/mod.rs:300
↓ 3 callersMethodworkdir
(&self)
rust/release/src/repo.rs:17
↓ 3 callersMethodwrite_request
( &mut self, _protocol: &Self::Protocol, io: &mut T, req: Self::Request, )
rust/actyx/ax-core/src/util/formats/banyan_protocol.rs:121
↓ 2 callersFunctionDisconnected
()
js/node-manager/src/client/screens/Diagnostics.tsx:35
↓ 2 callersFunctionHslPercentageSpectrum
(hueAt0: number, hueAt1: number, saturation?: number, luminosity?: number)
js/node-manager/src/client/util/color.ts:2
↓ 2 callersFunctionadd
(n: string[])
js/node-manager/src/client/screens/NodesOverview.tsx:289
↓ 2 callersFunctionaddDurationStats
(stats: DurationStats0, duration: Duration)
js/sdk/src/util/runStats.ts:87
↓ 2 callersMethodadd_new_version
(&mut self, version: VersionLine)
rust/release/src/versions_file.rs:143
↓ 2 callersMethodadd_stream
(&mut self, stream: StreamId)
rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:110
↓ 2 callersFunctionaggregate
(expr: &SimpleExpr)
rust/actyx/ax-core/src/runtime/operation/aggregate.rs:342
↓ 2 callersFunctionapp_id
()
rust/actyx/ax-core/tests/multi_node.rs:23
← previousnext →501–600 of 3,158, ranked by callers