MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 10 callersMethodfirst
(&self)
rust/actyx/ax-core/src/settings/scope.rs:212
↓ 10 callersMethodhandle_settings_request
(&mut self, request: SettingsRequest)
rust/actyx/ax-core/src/node/node_impl.rs:158
↓ 10 callersMethodis_root
(&self)
rust/actyx/ax-core/src/settings/scope.rs:146
↓ 10 callersMethodpersist
(&self, app_id: AppId, events: Vec<(TagSet, Payload)>)
rust/actyx/ax-core/src/swarm/event_store.rs:129
↓ 10 callersMethodrequest
(serviceId: string, payload?: unknown)
js/sdk/src/v2/multiplexedWebsocket.ts:65
↓ 10 callersFunctionsetup
()
rust/actyx/ax-core/src/api/auth/validate_signed_manifest.rs:85
↓ 10 callersMethodsimple
(self)
rust/actyx/ax-aql/src/language/parser/mod.rs:66
↓ 10 callersMethodstatus
(&mut self, s: String)
rust/actyx/ax/src/cmd/events/dump.rs:88
↓ 10 callersFunctiontestBoth
(description: string, testFn: (ord: EventsSortOrder) => Promise<void>)
js/sdk/src/internal_common/event-fns-impl.spec.ts:259
↓ 9 callersMethodall
()
rust/release/src/os_arch.rs:129
↓ 9 callersMethodapp_id
(&self)
rust/actyx/ax-core/src/trees/axtrees.rs:104
↓ 9 callersMethodas_str
Extracts a string slice containing the entire session id
rust/actyx/ax-types/src/service/events.rs:404
↓ 9 callersMethodbounded_forward
( &self, tag_expr: &TagExpr, from_offsets_excluding: OffsetMap, to_offsets_inc
rust/actyx/ax-core/src/swarm/event_store.rs:136
↓ 9 callersFunctionemitter
(source: string)
js/sdk/src/internal_common/testHelper.ts:81
↓ 9 callersFunctionmk_store
(name: &'static str)
rust/actyx/ax-core/src/swarm/event_store.rs:279
↓ 9 callersMethodnode_id
(&self)
rust/actyx/swarm/harness/src/api.rs:77
↓ 9 callersMethodoffsets
(&self)
rust/actyx/ax-core/src/api/events/service.rs:55
↓ 9 callersMethodrequest
(serviceId: string, payload?: unknown)
js/sdk/src/v1/multiplexedWebsocket.ts:60
↓ 9 callersFunctionrun
This method does not belong here, it belongs in ax-core we need to extract this and it's friends
rust/actyx/ax/src/main.rs:139
↓ 9 callersFunctionrunAndDecode
( task: native.AsyncTask, payload: object, decoder: io.Decoder<unknown, T>, )
js/node-manager/src/node/tasks.ts:28
↓ 9 callersMethodsend
(data: any)
js/sdk/src/v2/multiplexedWebsocket.spec.ts:275
↓ 9 callersFunctionser
(v: T, expected: &str)
rust/actyx/ax-types/src/offset.rs:924
↓ 9 callersMethodsettings_repo
(&self)
rust/actyx/ax-core/src/node/node_impl.rs:124
↓ 9 callersFunctionsetup
()
rust/actyx/ax-core/src/certs/developer_certificate.rs:131
↓ 9 callersMethodsub
(self, other: SimpleExpr)
rust/actyx/ax-aql/src/language/mod.rs:405
↓ 9 callersMethodtoV1WireFormat
* FOR INTERNAL USE. Convert to Actyx wire format. * @internal
js/sdk/src/types/tags.ts:83
↓ 9 callersMethodtransform_mut
Transform the current value in-place and notify observers if the function returns `true`. This does not allow a fallible operation because in case of
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:187
↓ 9 callersFunctionwith_api
( mut log: impl Write + Clone + Send + 'static, f: impl FnOnce(u16, &Path) -> anyhow::Result<()>, )
rust/actyx/ax/tests/smoke.rs:78
↓ 8 callersFunctioncancelSubscription
()
js/sdk/src/internal_common/event-fns-impl.ts:447
↓ 8 callersMethodclose
(code: any, reason: any)
js/sdk/src/v2/multiplexedWebsocket.spec.ts:344
↓ 8 callersFunctioncompact
(array)
web/developer.actyx.com/src/theme/SearchBar/utils.js:172
↓ 8 callersMethodforward_stream
(&self, selection: StreamEventSelection)
rust/actyx/ax-core/src/swarm/event_store.rs:48
↓ 8 callersFunctiongetCurrentVersion
(product)
rust/release/integration/test.js:44
↓ 8 callersFunctiongetPastVersions
(product)
rust/release/integration/test.js:54
↓ 8 callersMethodhandle
Handle the given request, spawning tasks on the given Runtime as needed.
rust/actyx/ax-core/src/swarm/event_store_ref.rs:227
↓ 8 callersFunctionhandle_cmd
(fut: impl Future<Output = ()>, verbosity: u8)
rust/actyx/ax/src/main.rs:128
↓ 8 callersMethodis_local
(&self, stream_id: StreamId)
rust/actyx/ax-core/src/swarm/mod.rs:582
↓ 8 callersMethodis_loopback
(&self)
rust/actyx/swarm/harness/src/lib.rs:97
↓ 8 callersMethodload
(path: impl AsRef<Path>)
rust/release/src/versions_file.rs:115
↓ 8 callersFunctionmkLogger
(topic: string, logFnOverride?: LogFunction)
js/sdk/src/util/logging.ts:74
↓ 8 callersFunctionmkME
(eventId: string)
js/sdk/src/types/various.spec.ts:16
↓ 8 callersFunctionmkTimestamp
(time: number)
js/sdk/src/types/various.ts:125
↓ 8 callersFunctionmk_streams
()
rust/actyx/ax-core/src/ax_futures_util/stream/merge_ordered.rs:242
↓ 8 callersMethodnatural
(&mut self)
rust/actyx/ax-aql/src/language/parser/utils.rs:56
↓ 8 callersMethodnode_id
(&self)
rust/actyx/ax-core/src/swarm/mod.rs:496
↓ 8 callersMethodnumber
(&self, n: &Num)
rust/actyx/ax-core/src/runtime/eval.rs:149
↓ 8 callersMethodpartial_cmp
(&self, other: &Self)
rust/actyx/ax-core/src/runtime/value.rs:271
↓ 8 callersMethodrandom
Uses port `0` for all services. Let the OS allocate a free port.
rust/actyx/ax-core/src/node/mod.rs:226
↓ 8 callersFunctionreject
(err: anyhow::Error)
rust/actyx/ax-core/src/api/mod.rs:74
↓ 8 callersFunctionrun_netsim
(opts: HarnessOpts, f: F)
rust/actyx/swarm/harness/src/lib.rs:113
↓ 8 callersMethodset
Send a value and notify all current receivers. This will not fail even if all receivers are dropped. It will just go into nirvana.
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:177
↓ 8 callersMethodstart
(&mut self, notifier: Sender<Result<()>>)
rust/actyx/ax-core/src/node/components/mod.rs:286
↓ 8 callersMethodtake_until_signaled
Take from this stream until the given future completes.
rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:122
↓ 8 callersFunctiontest_retain_count
(events_to_retain: u64)
rust/actyx/ax-core/src/swarm/prune.rs:523
↓ 8 callersFunctiontest_retain_size
(max_size: u64)
rust/actyx/ax-core/src/swarm/prune.rs:574
↓ 8 callersMethodtree_stream
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:83
↓ 8 callersMethodvalue
(&self)
rust/actyx/ax-core/src/runtime/value.rs:194
↓ 8 callersMethodwrite
(&self)
rust/actyx/ax-core/src/swarm/sqlite.rs:28
↓ 7 callersFunction_compareEvents
(a: Event, b: Event)
js/sdk/src/internal_common/types.ts:66
↓ 7 callersFunction_compareEvents
(a: Event, b: Event)
js/sdk/src/v1/types.ts:82
↓ 7 callersMethodall
()
rust/actyx/ax-core/src/trees/query.rs:35
↓ 7 callersFunctionapp_id
()
rust/actyx/ax-core/src/swarm/tests.rs:46
↓ 7 callersFunctionapp_manifest
()
rust/actyx/swarm/harness/src/util.rs:15
↓ 7 callersMethodas_ref
(&self)
rust/actyx/ax-core/src/api/files/pinner.rs:203
↓ 7 callersFunctionassert_bounded
( store: &'a EventStore, expr: &'static str, from: Option<&'a BTreeMap<Str
rust/actyx/ax-core/src/swarm/event_store.rs:471
↓ 7 callersFunctionbufferOp
(bufferTimeSpan: number, maxBufferSize?: number)
js/sdk/src/util/bufferOp.ts:4
↓ 7 callersMethodcbor
(&self)
rust/actyx/ax-core/src/runtime/value.rs:202
↓ 7 callersFunctioncheck
(supported: &'static [&'static str], requested: &str, pass: bool)
rust/actyx/ax-core/src/api/filters/accept.rs:46
↓ 7 callersMethodclear_settings
Clears settings for a given scope, if the defaults are valid on their own, the settings_with_defaults will still be set
rust/actyx/ax-core/src/settings/repository.rs:193
↓ 7 callersFunctionconnect
(task: &mut Sender<Task>, auth: Authority)
rust/actyx/ax-core/src/node_connection.rs:572
↓ 7 callersFunctionctx
(order: Order)
rust/actyx/ax-core/src/runtime/query.rs:227
↓ 7 callersMethoddo_request
Perform a request (to AX APIs). If an authorization error (code 401) is returned, it will try to re-authenticate. If the service is unavailable (code
rust/sdk/src/client.rs:181
↓ 7 callersMethodencode
(&self, c: DagCborCodec, w: &mut W)
rust/actyx/ax-core/src/trees/tags.rs:79
↓ 7 callersFunctioneval
(cx: &mut Context<'_>, s: &str)
rust/actyx/ax-core/src/runtime/eval.rs:662
↓ 7 callersMethodeval
run a query in the given evaluation context and collect all results
rust/actyx/ax-core/src/runtime/query.rs:67
↓ 7 callersMethodevent
Add an event. This adds the given event to the list of events that will be emitted once this publishing request is submitted by using `.await` on it.
rust/sdk/src/client.rs:500
↓ 7 callersMethodevents
Limit the number of events to keep.
rust/actyx/ax-core/src/swarm/prune.rs:335
↓ 7 callersFunctionfeeder
(q: &str)
rust/actyx/ax-core/src/runtime/query.rs:230
↓ 7 callersFunctionfilter
()
rust/actyx/ax-core/src/runtime/operation/mod.rs:224
↓ 7 callersFunctiongetApiLocation
(config: ActyxOpts)
js/sdk/src/v2/utils.ts:28
↓ 7 callersMethodinto_inner
(mut self)
rust/actyx/ax-core/src/libp2p_streaming_response/handler.rs:78
↓ 7 callersFunctionkeypair
(i: u64)
rust/actyx/swarm/cli/src/lib.rs:158
↓ 7 callersMethodlookup_opt
(&self, name: &str)
rust/actyx/ax-core/src/runtime/eval.rs:120
↓ 7 callersFunctionmkHeaders
(token: string)
js/sdk/src/v2/utils.ts:132
↓ 7 callersMethodmultiaddr
(&self)
rust/actyx/swarm/harness/src/lib.rs:87
↓ 7 callersMethodnew_observer
One way of creating a new observer. The other is to clone an existing observer.
rust/actyx/ax-core/src/ax_futures_util/stream/variable.rs:206
↓ 7 callersMethodoffset
Retrieve the offset stored for the given source The returned value is `OffsetOrMin::MIN` if nothing is stored for the given source.
rust/actyx/ax-types/src/offset.rs:506
↓ 7 callersMethodoffsets
Returns known offsets across local and replicated streams. If an authorization error (code 401) is returned, it will try to re-authenticate. If the s
rust/sdk/src/client.rs:315
↓ 7 callersMethodparse_or_default
(&mut self)
rust/actyx/ax-aql/src/language/parser/utils.rs:64
↓ 7 callersFunctionsafeErrorToStr
(err: unknown)
js/node-manager/src/common/util.ts:15
↓ 7 callersFunctionscheduler
()
js/sdk/src/util/reconnectStrategies.spec.ts:12
↓ 7 callersMethodstop_on_error
(self)
rust/actyx/ax-core/src/ax_futures_util/mod.rs:11
↓ 7 callersMethodstream_filtered_stream_ordered
Returns a [`Stream`] of events filtered with a [`Query`].
rust/actyx/ax-core/src/swarm/mod.rs:1466
↓ 7 callersFunctiontest_retain_age
(percentage_to_keep: usize)
rust/actyx/ax-core/src/swarm/prune.rs:644
↓ 7 callersMethodtime
(&self)
rust/actyx/ax-core/src/trees/axtrees.rs:86
↓ 7 callersMethodvalidate_with_defaults
Validates a `json` value, given a `schema_json`. If individual fields are not set, but given a default in the schema, the default will be set. Note: I
rust/actyx/ax-core/src/settings/validation.rs:115
↓ 7 callersMethodversions
(&self)
rust/release/src/versions_file.rs:128
↓ 7 callersMethodwith_lower_bound
Add a (exclusive) lower 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:699
↓ 6 callersFunctionEventFnsFromEventStoreV2
( nodeId: NodeId, eventStore: EventStore, snapshotStore: SnapshotStore, currentActyxVersion: () => str
js/sdk/src/internal_common/event-fns-impl.ts:73
↓ 6 callersFunctionTags
(...requiredTags: string[])
js/sdk/src/types/tags.ts:148
← previousnext →201–300 of 3,158, ranked by callers