MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 1 callersFunctioninject_admin_event
(state: &mut State, event: RequestReceived<AdminProtocol>)
rust/actyx/ax-core/src/node/node_api/mod.rs:312
↓ 1 callersFunctioninject_banyan_event
( state: &mut State, swarm: &mut ApiBehaviour, event: RequestResponseEvent<BanyanRequest, BanyanRe
rust/actyx/ax-core/src/node/node_api/mod.rs:768
↓ 1 callersFunctioninject_events_event
(state: &mut State, event: RequestReceived<EventsProtocol>)
rust/actyx/ax-core/src/node/node_api/mod.rs:668
↓ 1 callersFunctioninject_identify_event
(state: &mut State, event: identify::Event)
rust/actyx/ax-core/src/node/node_api/mod.rs:1074
↓ 1 callersMethodinternal_tags
(&'a self, prefix: &'a str)
rust/actyx/ax-core/src/trees/axtrees.rs:98
↓ 1 callersMethodinto_app
(self)
rust/actyx/ax-core/src/trees/tags.rs:57
↓ 1 callersMethodinto_app_tags
(self)
rust/actyx/ax-core/src/trees/axtrees.rs:109
↓ 1 callersMethodinto_msg
(self)
rust/actyx/ax-core/src/libp2p_streaming_response/handler.rs:42
↓ 1 callersMethodinto_ref
(self)
rust/actyx/ax-core/src/crypto/keystore.rs:96
↓ 1 callersMethodinto_tags
(self)
rust/actyx/ax-core/src/trees/axtrees.rs:94
↓ 1 callersMethodinto_written
(self)
rust/actyx/ax-core/src/swarm/sqlite.rs:55
↓ 1 callersMethodinvoke
jvm/os-android/app/src/main/java/com/actyx/android/node/AxNode.kt:25
↓ 1 callersFunctionisConnectedTo
(from: ReachableNodeT, to: UiNode)
js/node-manager/src/client/screens/Diagnostics.tsx:14
↓ 1 callersFunctionisDefined
(v: T)
js/sdk/src/util/typescript.ts:77
↓ 1 callersFunctionisDiagnostics
(event: EventDiagnostic)
js/node-manager/src/client/screens/Query.tsx:275
↓ 1 callersFunctionisInDisconnectionPeriod
(data: Internals, addr: string, now = new Date())
js/node-manager/src/client/agents/node-manager.tsx:293
↓ 1 callersFunctionisPadding
(e: MkEvent)
js/sdk/src/internal_common/testHelper.ts:77
↓ 1 callersMethodisSet
jvm/os-android/app/src/main/java/com/actyx/android/node/RustError.kt:16
↓ 1 callersMethodis_app_id_allowed
(&self, app_id: &AppId)
rust/actyx/ax-core/src/certs/app_domain.rs:17
↓ 1 callersMethodis_expired
(&self)
rust/actyx/ax-core/src/api/bearer_token.rs:26
↓ 1 callersFunctionis_ident
(s: &str)
rust/actyx/ax-aql/src/language/parser/mod.rs:677
↓ 1 callersMethodis_node_licensed
(&self, ax_public_key: &PublicKey)
rust/actyx/ax-core/src/api/licensing.rs:23
↓ 1 callersFunctionis_prefix
(left: &Multiaddr, right: &Multiaddr)
rust/actyx/ax-core/src/node_connection.rs:402
↓ 1 callersMethodis_signed
(&self)
rust/actyx/ax-types/src/app_manifest.rs:77
↓ 1 callersFunctionknown_peers
(ipfs: &Ipfs)
rust/actyx/ax-core/src/node/components/store.rs:108
↓ 1 callersMethodlamport
(&self)
rust/actyx/ax-core/src/trees/axtrees.rs:90
↓ 1 callersMethodle
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:432
↓ 1 callersMethodlen
(&self)
rust/actyx/ax-types/src/event/opaque.rs:29
↓ 1 callersMethodlen
(&self)
rust/actyx/ax-macros/src/lib.rs:18
↓ 1 callersFunctionlist_existing_topics
(store_dir: &PathBuf)
rust/actyx/ax-core/src/node/node_api/mod.rs:575
↓ 1 callersFunctionlist_file_or_dir
(client: &Ax, name_or_cid: String, level: usize)
rust/sdk/examples/files.rs:90
↓ 1 callersFunctionliveStream
(from, subs)
js/sdk/src/internal_common/testEventStore.ts:249
↓ 1 callersFunctionloadAlgolia
()
web/developer.actyx.com/src/theme/SearchBar/index.js:48
↓ 1 callersFunctionload_dev_cert
(path: Option<PathBuf>)
rust/actyx/ax-core/src/private_key.rs:168
↓ 1 callersMethodload_known_streams
(&mut self)
rust/actyx/ax-core/src/swarm/mod.rs:715
↓ 1 callersFunctionload_yml
(input: String)
rust/actyx/ax/src/cmd/settings/set.rs:58
↓ 1 callersMethodlocal_stream_nrs
(&self)
rust/actyx/ax-core/src/swarm/mod.rs:500
↓ 1 callersFunctionlock_working_dir
(working_dir: impl AsRef<std::path::Path>)
rust/actyx/ax-core/src/node/host.rs:19
↓ 1 callersMethodlookup
(&self, name: &str)
rust/actyx/ax-core/src/runtime/eval.rs:126
↓ 1 callersMethodloop_on_rx
Convenience implementation managing the lifecycle of a `Component` as driven by `ComponentRequest`s: New settings are converted to component specific
rust/actyx/ax-core/src/node/components/mod.rs:129
↓ 1 callersFunctionls_run
(opts: LsOpts)
rust/actyx/ax/src/cmd/topics/ls.rs:50
↓ 1 callersMethodlt
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:429
↓ 1 callersFunctionmakeExtendedControl
(data: Internals)
js/node-manager/src/client/agents/node-manager.tsx:424
↓ 1 callersFunctionmakeWsMultiplexerV2
( config: ActyxOpts, token: string, manifest: AppManifest, )
js/sdk/src/v2/index.ts:18
↓ 1 callersFunctionmake_keystore
(storage: NodeStorage)
rust/actyx/ax-core/src/node/util.rs:16
↓ 1 callersFunctionmake_listener
Creates a `std::net::TcpListener` for the given `addr`. This also sets the `SO_REUSEADDR` flag on the socket.
rust/actyx/ax-core/src/api/hyper_serve.rs:9
↓ 1 callersFunctionmake_log_filename
()
rust/actyx/swarm/cli/src/main.rs:34
↓ 1 callersFunctionmake_signed
( manifest: &AppManifest, dev_privkey: PrivateKey, dev_cert: ManifestDeveloperCertific
rust/actyx/ax-core/src/certs/app_manifest.rs:94
↓ 1 callersFunctionmatches
brute force check if a key matches a dnf query consisting of n tag sets
rust/actyx/ax-core/src/trees/tests.rs:210
↓ 1 callersMethodmatches
(&self, local: bool, event: &ax_types::Event<T>)
rust/actyx/ax-core/src/swarm/selection.rs:29
↓ 1 callersMethodmatches
(&self, tag_set: &TagSet, app_id: &AppId)
rust/actyx/ax-core/src/swarm/mod.rs:1919
↓ 1 callersMethodmerge_ordered
Create a merge from an input stream of ordered streams, merging concurrent streams such that the resulting stream is ordered, and filtering new stream
rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:59
↓ 1 callersMethodmerge_ordered_with_initials
Create a merge from an initial set of ordered streams and an input stream of ordered streams. The initial streams are guaranteed to be merged in the c
rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:85
↓ 1 callersMethodmerge_ordered_with_stragglers
Create a merge from an input stream of ordered streams, merging concurrent streams such that the resulting stream is ordered, and adding new streams b
rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:72
↓ 1 callersFunctionmetrics
(store: BanyanStore, interval: Duration)
rust/actyx/ax-core/src/swarm/metrics.rs:17
↓ 1 callersFunctionmigrate_if_necessary
Migrates the AX node if necessary. If the node's version is current, this is a no-op.
rust/actyx/ax-core/src/node/migration/mod.rs:76
↓ 1 callersFunctionmime
(name: impl AsRef<Path>)
rust/actyx/ax-core/src/api/files/mod.rs:423
↓ 1 callersFunctionmime_wild
(mime: &str)
rust/actyx/ax-core/src/api/blob.rs:94
↓ 1 callersFunctionmkConfig
( url: string, )
js/sdk/src/v2/multiplexedWebsocket.ts:102
↓ 1 callersFunctionmkConfig
( url: string, )
js/sdk/src/v1/multiplexedWebsocket.ts:83
↓ 1 callersFunctionmkCounters
()
js/sdk/src/util/runStats.ts:170
↓ 1 callersFunctionmkFavorite
()
js/node-manager/src/client/screens/NodesOverview.tsx:105
↓ 1 callersFunctionmkGauges
()
js/sdk/src/util/runStats.ts:311
↓ 1 callersFunctionmkLamport
(value: number)
js/sdk/src/types/various.ts:95
↓ 1 callersFunctionmkSuccess
(onDone: () => void)
js/node-manager/src/client/screens/SetupUserKey.tsx:37
↓ 1 callersFunctionmkV1eventStore
(axOpts: ActyxOpts)
js/sdk/src/v1/index.ts:23
↓ 1 callersFunctionmk_blob_tuples
Maps a source artifact (m) to a target artifact (n).
rust/release/src/publisher.rs:280
↓ 1 callersFunctionmk_docker_tuples
( release: &Release, hash: &Oid, os_arch: OsArch, is_newest: bool, )
rust/release/src/publisher.rs:231
↓ 1 callersFunctionmk_query
()
rust/actyx/ax-core/src/api/ans.rs:70
↓ 1 callersFunctionmk_store
()
rust/actyx/ax-core/src/runtime/eval.rs:670
↓ 1 callersFunctionmk_swarm
( node_id: NodeId, keypair: libp2p::core::identity::Keypair, node_tx: Sender<ExternalEvent>, b
rust/actyx/ax-core/src/node/node_api/mod.rs:1099
↓ 1 callersFunctionmk_transport
(id_keys: identity::Keypair)
rust/actyx/ax-core/src/node/node_api/mod.rs:1175
↓ 1 callersFunctionmonotonicFrom
( session: string, subscriptions: Where<unknown>, fixedStart?: FixedStart, )
js/sdk/src/internal_common/subscribe_monotonic.ts:79
↓ 1 callersFunctionmsgGen
()
js/sdk/src/v2/multiplexedWebsocket.spec.ts:35
↓ 1 callersFunctionmsgType
(requestId: number)
js/sdk/src/v2/multiplexedWebsocket.spec.ts:38
↓ 1 callersMethodne
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:444
↓ 1 callersMethodnext
(&mut self)
rust/actyx/ax-core/src/ax_futures_util/stream/drainer.rs:52
↓ 1 callersMethodnext_lamport
(&self)
rust/actyx/ax-core/src/trees/tests.rs:48
↓ 1 callersFunctionnodeToStatusText
(node: UiNode)
js/node-manager/src/client/screens/NodesOverview.tsx:43
↓ 1 callersMethodnode_id
(&self)
rust/actyx/ax-types/src/scalars.rs:249
↓ 1 callersFunctionnone
()
js/sdk/src/util/typescript.ts:36
↓ 1 callersFunctionnot_found
()
rust/actyx/ax-core/src/api/tests.rs:414
↓ 1 callersMethodnow
(&self)
rust/actyx/ax-aql/src/language/parser/mod.rs:48
↓ 1 callersFunctionnpmInstallAndBuild
(cwd)
web/developer.actyx.com/bin/build-monorepo-dependencies.js:5
↓ 1 callersMethodobserve_lamport
(&self)
rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:145
↓ 1 callersFunctionok
()
rust/actyx/ax-core/src/api/tests.rs:135
↓ 1 callersFunctiononDirtied
()
js/node-manager/src/client/components/SettingsEditor.tsx:268
↓ 1 callersFunctiononDisconnect
(_: Electron.IpcRendererEvent, incomingPeer: string)
js/node-manager/src/client/agents/node-info-provider.tsx:37
↓ 1 callersMethodopen
#[instrument(level = "debug")]
rust/actyx/ax-core/src/swarm/sqlite_index_store.rs:48
↓ 1 callersFunctionopen_readonly
(path: impl AsRef<Path>)
rust/actyx/ax-core/src/node/migration/mod.rs:9
↓ 1 callersFunctionordOffsetsEvent
(offsets: OffsetMap, events: Events)
js/sdk/src/internal_common/testEventStore.ts:124
↓ 1 callersMethodouter
(&self)
rust/actyx/ax-core/src/swarm/mod.rs:489
↓ 1 callersFunctionpackage_tar_gz
(source: impl AsRef<Path>, target: impl AsRef<Path>, binary_name: Option<&str>)
rust/release/src/publisher.rs:668
↓ 1 callersFunctionpackage_zip
(source: impl AsRef<Path>, target: impl AsRef<Path>, binary_name: Option<&str>)
rust/release/src/publisher.rs:685
↓ 1 callersFunctionparent_schema
Searches recursively for a schema for `scope`, popping one level on each iteration. Search terminates either if a schema is found or scope is empty.
rust/actyx/ax-core/src/settings/repository.rs:86
↓ 1 callersFunctionparent_schema0
(tx: &mut database::Transaction, scope: &Scope)
rust/actyx/ax-core/src/settings/repository.rs:90
↓ 1 callersMethodpartial_cmp
(&self, other: &Self)
rust/release/src/versions_file.rs:68
↓ 1 callersMethodpartial_cmp
(&self, other: &Self)
rust/actyx/ax-aql/src/language/number_impl.rs:101
↓ 1 callersFunctionpayload_from_opts
Read the event: - Read from standard input if it starts with `@-` - Read from a file if it starts with a `@` instead - Otherwise, take the parameter a
rust/actyx/ax/src/cmd/events/publish.rs:39
↓ 1 callersMethodpeer_id
(&self)
rust/actyx/ax-core/src/swarm/discovery.rs:84
← previousnext →1,101–1,200 of 3,158, ranked by callers