MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 2 callersFunctionis_topic_blobs
Check if a given file name belongs to a topic's blobs.
rust/actyx/ax-core/src/node/node_api/mod.rs:618
↓ 2 callersFunctionis_topic_file
Check if a given file name represents a "main" topic file/folder.
rust/actyx/ax-core/src/node/node_api/mod.rs:613
↓ 2 callersFunctionis_topic_index
Check if a given file name belongs to a topic's index.
rust/actyx/ax-core/src/node/node_api/mod.rs:626
↓ 2 callersMethodkeepAlive
()
js/sdk/src/internal_common/multiplexedWebSocket.ts:104
↓ 2 callersMethodlatest
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:108
↓ 2 callersFunctionlatest_entry
(history: &mut Vec<HistoryEntry>, fresh_cutoff: Timestamp, now: Timestamp)
rust/actyx/ax-core/src/node/components/swarm_observer.rs:178
↓ 2 callersMethodloadLibrary
jvm/os-android/app/src/main/java/com/actyx/android/util/Native.kt:12
↓ 2 callersMethodlocal
* The same requirement, but matching only Events emitted by the very node the code is run on. * E.g. `Tags('my-tag').local()` selects all locally e
js/sdk/src/types/tags.ts:114
↓ 2 callersFunctionlogReconnectAttempt
(delayMs: number, attempt: number, name: string)
js/sdk/src/util/reconnectStrategies.ts:14
↓ 2 callersFunctionmakeInternal
(tag: string)
js/sdk/src/types/tags.ts:29
↓ 2 callersFunctionmakeLogPattern
(excludeModules: string[])
js/sdk/src/util/logging.ts:131
↓ 2 callersMethodmake_processor
(&self)
rust/actyx/ax-core/src/runtime/operation/mod.rs:47
↓ 2 callersMethodmanifest_dev_cert
(&self)
rust/actyx/ax-core/src/certs/developer_certificate.rs:106
↓ 2 callersMethodmaybe_add_key
(&self, key_id: PublicKey, peer: PeerId)
rust/actyx/ax-core/src/node/node_api/mod.rs:191
↓ 2 callersMethodmerge
* For merging with another Where statement. (Worse API than the public one, but easier to implement.) * @internal
js/sdk/src/types/tags.ts:89
↓ 2 callersFunctionmkEvent
(raw)
js/sdk/src/internal_common/testHelper.ts:26
↓ 2 callersFunctionmkMeta
( key: EventKey, offsets: OffsetMap, horizon: EventKey | undefined, cycle: number, )
js/sdk/src/v2/blobSnapshotStore.ts:49
↓ 2 callersFunctionmkNodeId
(text: string)
js/sdk/src/types/various.ts:19
↓ 2 callersMethodmkResponse
(content: ResponseMessage)
js/sdk/src/v2/multiplexedWebsocket.spec.ts:254
↓ 2 callersFunctionmk_offset_or_min
(o: u32)
rust/actyx/ax-types/src/offset.rs:807
↓ 2 callersFunctionmk_part
(file: impl AsRef<Path>)
rust/sdk/examples/files.rs:162
↓ 2 callersFunctionmk_streams
()
rust/actyx/ax-core/src/ax_futures_util/stream/merge_unordered.rs:99
↓ 2 callersFunctionmk_tag
(i: u32)
rust/actyx/ax-core/src/swarm/event_store.rs:627
↓ 2 callersFunctionmk_validator
Creates a validator for the parent scope.
rust/actyx/ax-core/src/settings/repository.rs:105
↓ 2 callersMethodmodulo
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:414
↓ 2 callersFunctionnamedSubSpace
(rawTag: string, sub: string)
js/sdk/src/types/tags.ts:14
↓ 2 callersMethodnew_observer_id
Allocate a new receiver and return its id
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:289
↓ 2 callersMethodnext
(&mut self)
rust/actyx/ax-core/src/ax_futures_util/stream/stream_dispatcher.rs:67
↓ 2 callersMethodnotify
notifies all registered senders for the key `K`. Since these are oneshot dispatchers, they will all be removed.
rust/actyx/ax-core/src/ax_futures_util/future/oneshot_dispatcher.rs:29
↓ 2 callersMethodnotify
(&mut self)
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:278
↓ 2 callersMethodnotify
notifies all registered senders for the key `K` that a new item has arrived.
rust/actyx/ax-core/src/ax_futures_util/stream/stream_dispatcher.rs:29
↓ 2 callersFunctionnullable
(base: Base)
js/sdk/src/v1/websocketSnapshotStore.ts:29
↓ 2 callersFunctionobserveBestMatch
( query: Where<E>, shouldReplace: (candidate: ActyxEvent<E>, cur: ActyxEvent<E>) => boolean, onRep
js/sdk/src/internal_common/event-fns-impl.ts:440
↓ 2 callersFunctionobserveMonotonicFromSnapshot
( fishId: SessionId, subscriptions: Where<unknown>, )
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:340
↓ 2 callersMethodparse
parse a `NodeId` using the crypt alphabet, which is order preserving
rust/actyx/ax-types/src/scalars.rs:119
↓ 2 callersFunctionparse_opt_usize
(boxed: &Option<Box<Expr>>, default: usize)
rust/actyx/ax-macros/src/lib.rs:44
↓ 2 callersFunctionparse_range
(from: Option<Box<Expr>>, to: Option<Box<Expr>>, limits: RangeLimits)
rust/actyx/ax-macros/src/lib.rs:56
↓ 2 callersFunctionpercentiles
(mut v: Vec<T>)
rust/actyx/swarm/harness/src/bin/subscribe.rs:19
↓ 2 callersFunctionpersist
()
js/node-manager/src/client/agents/favorite-manager.tsx:43
↓ 2 callersMethodpersist
(&self, path: impl AsRef<Path>)
rust/release/src/versions_file.rs:131
↓ 2 callersFunctionpipe
()
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:382
↓ 2 callersMethodpoll_next
(self: Pin<&mut Self>, cx: &mut Context<'_>)
rust/actyx/ax-core/src/ax_futures_util/stream/merge_ordered.rs:182
↓ 2 callersFunctionpoll_next_impl
( mut inner: MutexGuard<'_, VariableInner<T>>, id: usize, cx: &mut Context<'_>, f: &impl Fn(&T
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:25
↓ 2 callersMethodpow
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:417
↓ 2 callersMethodpragma
(&self, name: &str)
rust/actyx/ax-core/src/runtime/query.rs:16
↓ 2 callersMethodpreferred_order
(&self)
rust/actyx/ax-core/src/runtime/query.rs:159
↓ 2 callersFunctionprint_scope
(scope: Scope)
rust/actyx/ax/src/cmd/settings/mod.rs:56
↓ 2 callersMethodprivate_key
(&self)
rust/actyx/ax-core/src/certs/developer_certificate.rs:102
↓ 2 callersFunctionprune_replication_store
(store_name: &str, enable_pruning: bool)
rust/actyx/ax-core/src/swarm/prune.rs:730
↓ 2 callersFunctionpublish_and_query
This function: 1. publishes a single message as each machine 2. queries for said messages in each machine This process ensures that all machines have
rust/actyx/swarm/harness/src/bin/versions.rs:154
↓ 2 callersFunctionpublish_events
(event_count: u64)
rust/actyx/ax-core/src/swarm/prune.rs:513
↓ 2 callersMethodpublish_new_stream_id
(&mut self, stream_id: StreamId)
rust/actyx/ax-core/src/swarm/mod.rs:624
↓ 2 callersMethodpublished_tree
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:89
↓ 2 callersFunctionquery_from_str
(s: &str)
rust/actyx/ax-aql/src/language/parser/mod.rs:620
↓ 2 callersFunctionquery_raw_opt
()
rust/actyx/ax-core/src/api/files/mod.rs:65
↓ 2 callersFunctionquery_token_ws
Interpretes the whole query string as the access token. This method must only be used for the WS connection!
rust/actyx/ax-core/src/api/filters/authenticate.rs:26
↓ 2 callersFunctionr_interpolation
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:104
↓ 2 callersFunctionr_query
(pragmas: Vec<(&'a str, &'a str)>, features: Vec<String>, p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:574
↓ 2 callersFunctionr_tag_comp
(p: P)
rust/actyx/ax-aql/src/language/parser/mod.rs:192
↓ 2 callersFunctionrandomBase58
(digits: number)
js/sdk/src/types/various.ts:20
↓ 2 callersMethodre_authenticate
(&self)
rust/sdk/src/client.rs:169
↓ 2 callersMethodread
(&mut self, buf: &mut [u8])
rust/actyx/ax/src/cmd/events/restore.rs:201
↓ 2 callersFunctionread_msg
( io: &mut NegotiatedSubstream, max_size: u32, buffer: &mut Vec<u8>, )
rust/actyx/ax-core/src/libp2p_streaming_response/protocol_v2.rs:126
↓ 2 callersMethodread_response
( &mut self, _protocol: &Self::Protocol, io: &mut T, )
rust/actyx/ax-core/src/util/formats/banyan_protocol.rs:97
↓ 2 callersFunctionreduceUpToPresent
( query: Where<E>, reduce: (acc: R, e1: ActyxEvent<E>) => R, initial: R, )
js/sdk/src/internal_common/event-fns-impl.ts:373
↓ 2 callersFunctionregister
(sym, req)
js/sdk/src/globals.ts:26
↓ 2 callersFunctionremoveTestKeys
()
js/node-manager/src/tests/util.ts:46
↓ 2 callersMethodremove_at
(&self, scope: &Scope)
rust/actyx/ax-core/src/settings/json_value.rs:115
↓ 2 callersFunctionrender_array
(w: &mut impl Write, e: &Arr<SpreadExpr>)
rust/actyx/ax-aql/src/language/render.rs:76
↓ 2 callersFunctionrender_index
(w: &mut impl Write, e: &Index, with_dot: bool)
rust/actyx/ax-aql/src/language/render.rs:23
↓ 2 callersFunctionrender_interpolation
(w: &mut impl Write, e: &Arr<SimpleExpr>)
rust/actyx/ax-aql/src/language/render.rs:96
↓ 2 callersFunctionrender_number
(w: &mut impl Write, e: &Num)
rust/actyx/ax-aql/src/language/render.rs:56
↓ 2 callersFunctionrender_query
(w: &mut impl Write, e: &Query)
rust/actyx/ax-aql/src/language/render.rs:271
↓ 2 callersFunctionrender_tag_expr
(w: &mut impl Write, e: &TagExpr, _parent: Option<&TagExpr>)
rust/actyx/ax-aql/src/language/render.rs:209
↓ 2 callersFunctionrender_timestamp
(w: &mut impl Write, e: Timestamp)
rust/actyx/ax-aql/src/language/render.rs:229
↓ 2 callersFunctionrenewToken
()
js/sdk/src/v2/index.ts:48
↓ 2 callersFunctionrequest
(timeout: u8, mut conn: mpsc::Sender<Task>, authority: Authority)
rust/actyx/ax/src/cmd/nodes/ls.rs:80
↓ 2 callersMethodrewrite0
(&self, surfer: &mut impl Galactus)
rust/actyx/ax-aql/src/language/rewrite_impl.rs:175
↓ 2 callersMethodroot
( order: Order, store: EventStoreRef, from_offsets_excluding: OffsetMap, to_of
rust/actyx/ax-core/src/runtime/eval.rs:67
↓ 2 callersFunctionroute
(node_info: NodeInfo)
rust/actyx/ax-core/src/api/auth/mod.rs:111
↓ 2 callersFunctionrun
(opt: KeygenOpts)
rust/actyx/ax/src/cmd/swarms/keygen.rs:55
↓ 2 callersMethodrun
(opts: LsOpts)
rust/actyx/ax/src/cmd/nodes/ls.rs:121
↓ 2 callersFunctionrunWithoutResult
(task: native.AsyncTask, payload: object)
js/node-manager/src/node/tasks.ts:58
↓ 2 callersFunctionrun_test
( retain_config: RetainConfig, events: Vec<PublishEvent>, min: usize, max: usi
rust/actyx/swarm/harness/src/bin/quickcheck_ephemeral.rs:111
↓ 2 callersFunctionsaveToClipboard
(str: string)
js/node-manager/src/client/util/index.ts:128
↓ 2 callersFunctionselect
(addr: string | null, addrs: string[])
js/node-manager/src/client/screens/NodesOverview.tsx:269
↓ 2 callersFunctionselectFile
(onGet: (path: string) => void, exts?: string[])
js/node-manager/src/client/screens/AppSigning.tsx:40
↓ 2 callersFunctionselect_multi_internal
(machine: &mut Machine<Command, Event>, things: Vec<Box<Selector<'_, T>>>)
rust/actyx/swarm/harness/src/lib.rs:256
↓ 2 callersFunctionsend
Sends ByteBuffer over the FFI barrier, using a callback, if registered. Will drop the buffer, if no callback is registered.
rust/actyx/node-ffi/src/lib.rs:90
↓ 2 callersMethodserialize
(&self, serializer: S)
rust/actyx/ax-types/src/types/binary.rs:38
↓ 2 callersFunctionserve_unixfs_node
( store: BanyanStore, query: IpfsQuery, uri_path: FullPath, raw_query: Option<String>, acc
rust/actyx/ax-core/src/api/files/mod.rs:72
↓ 2 callersFunctionset
(name: string, value: Integer)
js/sdk/src/util/runStats.ts:313
↓ 2 callersMethodset_level
(&mut self, level: LogSeverity)
rust/actyx/ax-core/src/node/components/logging/logging_sink.rs:88
↓ 2 callersMethodset_node_id
(&self, node_id: NodeId)
rust/actyx/ax-core/src/node/node_storage.rs:155
↓ 2 callersFunctionsetup_logger_with_level
Sets up a logging and a panic handler that logs panics. Panics are pushed into the `log` crate. We install the `tracing_log::LogTracer` so that all `
rust/actyx/ax-core/src/util/mod.rs:32
↓ 2 callersFunctionshouldReplace
(candidate: ActyxEvent<number>, cur: ActyxEvent<number>)
js/sdk/src/internal_common/event-fns-impl.spec.ts:546
↓ 2 callersMethodshrink
(&self)
rust/actyx/swarm/harness/src/bin/quickcheck_interleaved.rs:108
↓ 2 callersMethodshutdown
(&mut self, reason: ShutdownReason)
rust/actyx/ax-core/src/node/mod.rs:296
↓ 2 callersFunctionsignAppManifest
(req: SignAppManifestRequest)
js/node-manager/src/node/tasks.ts:85
↓ 2 callersFunctionsign_manifest_from_files
Sign a given manifest with the given certificate. Will load both from the file system and, if successful, overwrite the original manifest with its si
rust/actyx/ax-core/src/certs/app_manifest.rs:69
← previousnext →701–800 of 3,158, ranked by callers