MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 2 callersMethodsize
Limit the total size of the events to keep (in bytes).
rust/actyx/ax-core/src/swarm/prune.rs:360
↓ 2 callersMethodsplit_first
(&self)
rust/actyx/ax-core/src/settings/scope.rs:215
↓ 2 callersFunctionstart
()
js/node-manager/src/node/main.ts:58
↓ 2 callersFunctionstarts_with
()
rust/actyx/ax-core/src/settings/scope.rs:303
↓ 2 callersFunctionstore
()
rust/actyx/ax-core/src/runtime/operation/mod.rs:219
↓ 2 callersFunctionstore_events
(writer: &mut BanyanWriter)
rust/actyx/ax-core/src/node/node_api/mod.rs:1024
↓ 2 callersFunctionstore_key
(key: String, mut path: PathBuf)
rust/actyx/ax/src/cmd/swarms/keygen.rs:41
↓ 2 callersFunctionstrip_invisible_group
when this macro’s input comes from another macro, expressions may be invisibly wrapped, so strip that away
rust/actyx/ax-macros/src/lib.rs:143
↓ 2 callersFunctionsubscribeChunked
( openQuery: EventSubscription, cfg: { maxChunkSize?: number; maxChunkTimeMs?: number }, onChunk:
js/sdk/src/internal_common/event-fns-impl.ts:287
↓ 2 callersMethodsupervise
( &self, actor: SupervisionRef<ComponentCommand, <AcTokio as ActoRuntime>::ActoHandle<anyhow::
rust/actyx/ax-core/src/node/actors.rs:36
↓ 2 callersMethodtag
(&mut self, name: &'static str)
rust/actyx/ax-core/src/swarm/tests.rs:34
↓ 2 callersFunctiontag_set
(s: &str)
rust/actyx/ax-core/src/trees/query.rs:575
↓ 2 callersMethodtags
(&mut self, names: &[&'static str])
rust/actyx/ax-core/src/swarm/tests.rs:41
↓ 2 callersFunctiontest_route
()
rust/actyx/ax-core/src/api/auth/mod.rs:131
↓ 2 callersFunctiontest_setup
(request: String, logic: L, f: F)
rust/actyx/ax-core/src/libp2p_streaming_response/tests/mod.rs:150
↓ 2 callersFunctiontest_txn
()
rust/actyx/ax-core/src/trees/tests.rs:141
↓ 2 callersMethodtime
(&self)
rust/actyx/ax-core/src/trees/tests.rs:55
↓ 2 callersFunctiontimeTravelMsg
(fishId: SessionId, previousHead: EventKey, next: Events)
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:386
↓ 2 callersFunctiontoKeyValueMap
(key: K, xs: ReadonlyArray<T>)
js/sdk/src/util/typescript.ts:114
↓ 2 callersFunctiontoMetadata
(sourceId: string)
js/sdk/src/types/various.ts:270
↓ 2 callersFunctiontoSubscriptionSet
(where: Where<unknown>)
js/sdk/src/v1/websocketEventStore.ts:101
↓ 2 callersMethodto_app
(&self)
rust/actyx/ax-core/src/trees/tags.rs:43
↓ 2 callersMethodto_base64
(&self)
rust/actyx/ax-core/src/certs/app_license.rs:74
↓ 2 callersFunctionto_ev
(offset: u64, key: AxKey, stream: StreamId, payload: Payload)
rust/actyx/ax-core/src/swarm/event_store.rs:219
↓ 2 callersFunctionto_events
(tags: Vec<TagSet>)
rust/actyx/swarm/harness/src/util.rs:19
↓ 2 callersFunctionto_multiaddr
(socket_addr: SocketAddr)
rust/actyx/ax-core/src/util/mod.rs:243
↓ 2 callersMethodto_offsets_including
(&self)
rust/actyx/ax-core/src/runtime/eval.rs:108
↓ 2 callersMethodto_private
(&self)
rust/actyx/ax-core/src/private_key.rs:154
↓ 2 callersMethodto_public
(&self)
rust/actyx/ax-core/src/private_key.rs:128
↓ 2 callersMethodto_serialized
(&self)
rust/actyx/ax-core/src/trees/tags.rs:64
↓ 2 callersMethodtree_stream
Get a stream of trees for a given stream id
rust/actyx/ax-core/src/swarm/mod.rs:613
↓ 2 callersMethodtriggerMessage
(data: any)
js/sdk/src/v2/multiplexedWebsocket.spec.ts:328
↓ 2 callersMethodunbounded_forward
( &self, tag_expr: TagExpr, from_offsets_excluding: OffsetMap, )
rust/actyx/ax-core/src/swarm/event_store_ref.rs:167
↓ 2 callersMethodunbounded_forward_per_stream
( &self, tag_expr: &TagExpr, from_offsets_excluding: OffsetMap, )
rust/actyx/ax-core/src/swarm/event_store.rs:181
↓ 2 callersMethodunixfs_resolve
Resolves a [`Cid`] to a unixfs-v1 [`FileNode`] descriptor. Any needed intermediate blocks are fetched automatically. The actual data is not resolved.
rust/actyx/ax-core/src/swarm/mod.rs:1204
↓ 2 callersFunctionupdate_at
(obj: &mut serde_json::Value, scope: &Scope, value: serde_json::Value)
rust/actyx/ax-core/src/settings/json_value.rs:100
↓ 2 callersMethodupdate_node_state
(&mut self)
rust/actyx/ax-core/src/node/node_impl.rs:251
↓ 2 callersMethodupdate_root
(&self, stream_id: StreamId, root: Link, source: RootSource)
rust/actyx/ax-core/src/swarm/mod.rs:1558
↓ 2 callersMethodupgrade_outbound
(self, sock: C, info: Self::Info)
rust/actyx/ax-core/src/libp2p_streaming_response/upgrade.rs:63
↓ 2 callersFunctionuseCtrlEnter
(fn: undefined | (() => unknown), deps: unknown[] = [])
js/node-manager/src/client/components/hooks/use-keycapture.tsx:19
↓ 2 callersFunctionv
()
rust/actyx/ax-core/benches/bench_runtime_query.rs:18
↓ 2 callersMethodvalidate
(&self, val: &Value, path: &str, _scope: &scope::Scope)
rust/actyx/ax-core/src/settings/formats.rs:42
↓ 2 callersFunctionvalidateAgainstSchema
(data: object, schema: object)
js/node-manager/src/client/components/SettingsEditor.tsx:18
↓ 2 callersFunctionvalidateFixedStart
( subscriptions: Where<unknown>, present: OffsetMap, attemptStartFrom: FixedStart, whenInvalid
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:234
↓ 2 callersFunctionvalidate_manifest
( manifest: &AppManifest, ax_public_key: &PublicKey, licensing: &Licensing, )
rust/actyx/ax-core/src/api/auth/mod.rs:89
↓ 2 callersMethodvalue
(self)
rust/actyx/swarm/harness/src/lib.rs:175
↓ 2 callersFunctionvaluesOf
(m: PartialRecord<any, V>)
js/sdk/src/util/typescript.ts:78
↓ 2 callersMethodverify
Verify a selection of signatures in the given signed message This operation fails if for at least one given key ID: - the key is not known - there i
rust/actyx/ax-core/src/crypto/keystore.rs:187
↓ 2 callersFunctionverifyJSON
(str: string)
js/node-manager/src/client/screens/Publish.tsx:187
↓ 2 callersFunctionverify_token
(node_info: NodeInfo, token: Token)
rust/actyx/ax-core/src/api/auth/mod.rs:50
↓ 2 callersFunctionversionIsNewer
(v1: Version, v2: Version)
web/developer.actyx.com/src/components/page-templates/releases/util.ts:4
↓ 2 callersFunctionversionIsNewest
(v1: Version, others: Version[])
web/developer.actyx.com/src/components/page-templates/releases/util.ts:8
↓ 2 callersMethodwithId
* Returns two tags: * * - this tag * - this tag suffixed with the given `name`, e.g. `Tag<RobotEvent>('robot').withId('robot500')` *
js/sdk/src/types/tags.ts:170
↓ 2 callersFunctionwith_api
( cmd: &mut Command, use_stdout: bool, mut log: impl Write + Clone + Send + 'static, f: impl F
rust/actyx/ax/tests/version_compat.rs:256
↓ 2 callersMethodwith_keep_alive
If this is set to true, then this behaviour will keep the connection alive Otherwise the connection is released (i.e. closed if no other behaviour ke
rust/actyx/ax-core/src/libp2p_streaming_response/mod.rs:169
↓ 2 callersMethodwith_request_timeout
Timeout for the transmission of the request to the peer, default is 10sec
rust/actyx/ax-core/src/libp2p_streaming_response/mod.rs:133
↓ 2 callersFunctionwithout_peer
(addr: &Multiaddr)
rust/actyx/ax-core/src/node/components/store.rs:75
↓ 2 callersFunctionwriteStore
(app: App, data: StoreData)
js/node-manager/src/node/store.ts:33
↓ 2 callersFunctionwrite_err
(io: &mut NegotiatedSubstream, err: &ProtocolError)
rust/actyx/ax-core/src/libp2p_streaming_response/protocol_v2.rs:110
↓ 2 callersFunctionwrite_msg
( io: &'a mut NegotiatedSubstream, msg: impl serde::Serialize, max_size: u32, buffer: &'a mut
rust/actyx/ax-core/src/libp2p_streaming_response/protocol_v2.rs:82
↓ 2 callersMethodwrite_response
( &mut self, _protocol: &Self::Protocol, io: &mut T, res: Self::Response,
rust/actyx/ax-core/src/util/formats/banyan_protocol.rs:151
↓ 2 callersFunctionws
()
rust/actyx/ax-core/src/api/tests.rs:257
↓ 2 callersFunctionwsUrl
(tok: string)
js/sdk/src/v2/index.ts:24
↓ 1 callersFunctionEventsStreamName
(nodeId: string)
js/node-manager/src/client/offsets.ts:3
↓ 1 callersFunctionFavorite
(param: FavoriteParams)
js/node-manager/src/client/agents/favorite-manager.tsx:13
↓ 1 callersFunctionNodeInfoProvider
({ addr, peer, emitNodeInfoChange, emitDisconnect, timeoutRef, }: { addr: string peer: string
js/node-manager/src/client/agents/node-info-provider.tsx:18
↓ 1 callersFunctionNodeManagerAgent
({ allowedToWorkRef, timeoutRef, favoriteParams, }: { allowedToWorkRef: ObsValcon<boolean> timeoutRe
js/node-manager/src/client/agents/node-manager.tsx:30
↓ 1 callersMethodabort_task
Aborts a task.
rust/actyx/ax-core/src/swarm/mod.rs:674
↓ 1 callersFunctionaccept_text
()
rust/actyx/ax-core/src/api/filters/accept.rs:28
↓ 1 callersMethodadd
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:402
↓ 1 callersFunctionaddNode
(addr: string, peer: string, displayName: string)
js/node-manager/src/client/screens/NodesOverview.tsx:242
↓ 1 callersFunctionaddPendingOperation
(stats: DurationStats0, at: Timestamp)
js/sdk/src/util/runStats.ts:95
↓ 1 callersFunctionaddRedirect
(createData, addRoute, path, to)
web/developer.actyx.com/src/plugins/cosmos-versions/index.js:15
↓ 1 callersFunctionaddReleasePage
( createData, addRoute, product, version, commit, changes, otherVersions, )
web/developer.actyx.com/src/plugins/cosmos-versions/index.js:26
↓ 1 callersFunctionaddToThing
(thing: string, changes: string[])
web/developer.actyx.com/src/release-util.ts:97
↓ 1 callersFunctionadd_dir
(dir: PathBuf, rel_path: String)
rust/sdk/examples/files.rs:134
↓ 1 callersMethodadd_file
(&self, path: impl AsRef<Path>)
rust/release/src/repo.rs:48
↓ 1 callersFunctionadd_icon_to_bin_when_building_for_win
(icon_path: &str)
rust/actyx/ax/build.rs:4
↓ 1 callersMethodadd_key_pair_ed25519
Add an Ed25519 key pair to this store
rust/actyx/ax-core/src/crypto/keystore.rs:113
↓ 1 callersFunctionadd_offsets
(events: impl IntoIterator<Item = (AxKey, Payload)>)
rust/actyx/ax-core/src/trees/tests.rs:175
↓ 1 callersMethodadd_public_key_ed25519
Add an Ed25519 public key to this store
rust/actyx/ax-core/src/crypto/keystore.rs:121
↓ 1 callersMethodaggregate
(self)
rust/actyx/ax-aql/src/language/parser/mod.rs:59
↓ 1 callersFunctionallPersisted
()
js/sdk/src/internal_common/testEventStore.ts:197
↓ 1 callersMethodalt
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:447
↓ 1 callersFunctionannounce_addrs
(ipfs: &Ipfs)
rust/actyx/ax-core/src/node/components/store.rs:89
↓ 1 callersFunctionappDataDir
()
js/node-manager/src/tests/util.ts:40
↓ 1 callersFunctionapp_domains
()
rust/actyx/ax-core/src/certs/mod.rs:30
↓ 1 callersFunctionapp_id
()
rust/actyx/swarm/cli/src/main.rs:66
↓ 1 callersMethodapp_id_license
(&self, app_id: &AppId)
rust/actyx/ax-core/src/api/licensing.rs:55
↓ 1 callersFunctionapply_changes
(product: &Product, current_version: &Version, changes: &[Change])
rust/release/src/versions.rs:44
↓ 1 callersFunctionapply_impact
(current: &Version, impact: &VersionImpact)
rust/release/src/versions.rs:26
↓ 1 callersFunctionapply_system_schema
Set the schema for the ActyxOS system settings.
rust/actyx/ax-core/src/node/host.rs:101
↓ 1 callersMethodas_code
(&self)
rust/actyx/ax-core/src/libp2p_streaming_response/protocol_v2.rs:48
↓ 1 callersMethodas_ref
(&self)
rust/actyx/ax-types/src/scalars.rs:138
↓ 1 callersFunctionassertFinished
()
js/sdk/src/internal_common/event-fns-impl.spec.ts:130
↓ 1 callersFunctionassert_len_impl
(input: proc_macro::TokenStream)
rust/actyx/ax-macros/src/lib.rs:183
↓ 1 callersFunctionassert_unbounded
( node_id: NodeId, stream: impl Stream<Item = Event<Payload>> + 'static, e
rust/actyx/ax-core/src/swarm/event_store.rs:562
↓ 1 callersFunctionattemptConnections
( addresses: string[], timeout: number, )
js/node-manager/src/client/agents/node-manager.tsx:394
↓ 1 callersFunctionauthenticate_optional
( node_info: NodeInfo, token: impl Filter<Extract = (Option<Token>,), Error = Rejection> + Clone, )
rust/actyx/ax-core/src/api/filters/authenticate.rs:78
↓ 1 callersFunctionax_private_key
()
rust/actyx/ax-core/src/certs/mod.rs:22
← previousnext →801–900 of 3,158, ranked by callers