MCPcopy Create free account

hub / github.com/Actyx/Actyx / functions

Functions3,158 in github.com/Actyx/Actyx

⨍ Functions 3,158◇ Types & classes 771
↓ 1 callersFunctionpeer_id_to_node_id
(peer_id: libp2p::core::PeerId)
rust/actyx/ax-core/src/crypto/public.rs:100
↓ 1 callersFunctionpendingEmission
(o: Observable<Metadata[]>)
js/sdk/src/types/functions.ts:34
↓ 1 callersFunctionpersist
(evsUnsorted: Events)
js/sdk/src/internal_common/testEventStore.ts:174
↓ 1 callersMethodpersist
(&self, app_id: AppId, events: Vec<(TagSet, Payload)>)
rust/actyx/ax-core/src/swarm/event_store_ref.rs:127
↓ 1 callersFunctionpersistence
()
js/sdk/src/internal_common/testEventStore.ts:171
↓ 1 callersMethodpin_internal_loop
(&self)
rust/actyx/ax-core/src/api/files/pinner.rs:132
↓ 1 callersFunctionping
(peer: Peer)
js/node-manager/src/client/screens/NodeDetail.tsx:85
↓ 1 callersMethodpoll_next
(self: Pin<&mut Self>, cx: &mut Context<'_>)
rust/actyx/ax-core/src/ax_futures_util/stream/tap.rs:39
↓ 1 callersFunctionpoll_swarm
(mut swarm: Swarm<ApiBehaviour>, mut state: State)
rust/actyx/ax-core/src/node/node_api/mod.rs:235
↓ 1 callersFunctionpoll_to_deliver
( s: &mut MergeOrdered<Elem, St, Si>, cx: &mut Context<'_>, )
rust/actyx/ax-core/src/ax_futures_util/stream/merge_ordered.rs:154
↓ 1 callersMethodpop_mut
(&mut self)
rust/actyx/ax-core/src/settings/scope.rs:169
↓ 1 callersFunctionpostResultToSlack
(score, feedback)
web/developer.actyx.com/netlify/functions/nps.js:3
↓ 1 callersFunctionprofileObservable
(durations: Durations, counters: Counters)
js/sdk/src/util/runStats.ts:260
↓ 1 callersFunctionprofileSync
(durations: Durations)
js/sdk/src/util/runStats.ts:244
↓ 1 callersFunctionprometheus_encode
(families: &[prometheus::proto::MetricFamily], w: &mut W)
rust/actyx/ax-core/src/swarm/metrics.rs:150
↓ 1 callersFunctionprune
Prunes all ephemeral events for the streams configured via the respective [`RetainConfig`] in [`EphemeralEventsConfig`] in parallel. After all streams
rust/actyx/ax-core/src/swarm/prune.rs:437
↓ 1 callersMethodprune
()
js/sdk/src/internal_common/multiplexedWebSocket.ts:147
↓ 1 callersFunctionprune_history
(history: &mut Vec<HistoryEntry>, before: Timestamp)
rust/actyx/ax-core/src/node/components/swarm_observer.rs:201
↓ 1 callersFunctionpublish
(mut tx: Sender<Task>, peer: PeerId, data: Vec<PublishEvent>)
rust/actyx/node-manager-bindings/src/ops/publish.rs:23
↓ 1 callersFunctionpublishImpl
({ publishFn, tags, selectedNodeAddr, payloadField, }: { publishFn: NodeManagerAgent['api']['publish
js/node-manager/src/client/screens/Publish.tsx:193
↓ 1 callersFunctionpublish_events_chunked
Publishes `event_count` events, and waits some time between each chunk. This introduces different time stamps into the persisted events.
rust/actyx/ax-core/src/swarm/prune.rs:627
↓ 1 callersMethodpublish_root_map
( &self, store: BanyanStore, topic: String, interval: Duration, swarm_
rust/actyx/ax-core/src/swarm/gossip.rs:162
↓ 1 callersFunctionpublish_update
( event_svc: &EventService, app_id: AppId, query: Query<'static>, duration: Duration, )
rust/actyx/ax-core/src/api/files/pinner.rs:249
↓ 1 callersFunctionpurge
()
js/node-manager/src/client/agents/node-manager.tsx:126
↓ 1 callersFunctionquery
(from, to, subs, sortOrder)
js/sdk/src/internal_common/testEventStore.ts:235
↓ 1 callersFunctionqueryKnownRange
(rangeQuery: RangeQuery)
js/sdk/src/internal_common/event-fns-impl.ts:163
↓ 1 callersFunctionqueryKnownRangeChunked
( rangeQuery: RangeQuery, chunkSize: number, onChunk: (chunk: EventChunk) => void, onComplete?
js/sdk/src/internal_common/event-fns-impl.ts:179
↓ 1 callersFunctionr_aggr
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:440
↓ 1 callersFunctionr_bool
(p: P)
rust/actyx/ax-aql/src/language/parser/mod.rs:425
↓ 1 callersFunctionr_cases
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:429
↓ 1 callersFunctionr_expr_index
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:310
↓ 1 callersFunctionr_func_call
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:454
↓ 1 callersFunctionr_meta_key
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:474
↓ 1 callersFunctionr_meta_time
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:488
↓ 1 callersFunctionr_number
(mut p: P)
rust/actyx/ax-aql/src/language/parser/mod.rs:333
↓ 1 callersFunctionr_object
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:386
↓ 1 callersFunctionr_order
(p: P)
rust/actyx/ax-aql/src/language/parser/mod.rs:244
↓ 1 callersFunctionr_pragma
(p: P)
rust/actyx/ax-aql/src/language/parser/mod.rs:467
↓ 1 callersFunctionr_sub_query
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:497
↓ 1 callersFunctionr_tag
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:82
↓ 1 callersFunctionr_var_index
(p: P, ctx: Context)
rust/actyx/ax-aql/src/language/parser/mod.rs:283
↓ 1 callersFunctionrawChunksAsc
(eventsAscending: Events, chunkSize: number, reverse?: boolean)
js/sdk/src/internal_common/event-fns-impl.spec.ts:50
↓ 1 callersFunctionreadStore
(app: App)
js/node-manager/src/node/store.ts:36
↓ 1 callersFunctionready_iter
await the next item and return an iterator that yields all item that will then be directly available When the returned iterator is exhausted, a noop
rust/actyx/ax-core/src/ax_futures_util/stream/mod.rs:190
↓ 1 callersFunctionrealtimeFrom
( fishId: SessionId, subscriptions: Where<unknown>, fixedStart: FixedStart, )
js/sdk/src/internal_common/subscribe_monotonic_emulated.ts:87
↓ 1 callersMethodreceived_lamport
(&mut self, lamport: LamportTimestamp)
rust/actyx/ax-core/src/swarm/mod.rs:692
↓ 1 callersFunctionreducer
()
js/node-manager/src/client/app-state/app-state.tsx:23
↓ 1 callersMethodregister_with_components
(&mut self, tx: Sender<(ComponentType, ComponentState)>)
rust/actyx/ax-core/src/node/node_impl.rs:286
↓ 1 callersFunctionregulateNewConnections
( data: Internals, timeout: number, timeoutRef: ObsValcon<number | null>, events: { onChange: () =
js/node-manager/src/client/agents/node-manager.tsx:305
↓ 1 callersFunctionreject
(err: anyhow::Error)
rust/actyx/ax-core/src/api/events/http/handlers.rs:59
↓ 1 callersMethodreload
(&self, new_filter: EnvFilter)
rust/actyx/ax-core/src/node/components/logging/logging_sink.rs:17
↓ 1 callersFunctionremNode
(addr: string)
js/node-manager/src/client/screens/NodesOverview.tsx:384
↓ 1 callersFunctionremove_old_dbs
(dir: &Path, topic: &str)
rust/actyx/ax-core/src/node/node_api/mod.rs:905
↓ 1 callersMethodremoved
(&mut self, k: &'b treediff::value::Key, _v: &'a Value)
rust/actyx/ax-core/src/settings/json_differ.rs:40
↓ 1 callersFunctionrender_bool
(b: &bool, w: &mut impl Write)
rust/actyx/ax-aql/src/language/render.rs:165
↓ 1 callersFunctionrender_cases
(v: &NonEmptyVec<(SimpleExpr, SimpleExpr)>, w: &mut impl Write)
rust/actyx/ax-aql/src/language/render.rs:154
↓ 1 callersFunctionrender_directory_listing
TODO: Make this a bit nicer. Also take the path to `node` into account to provide upwards traversal.
rust/actyx/ax-core/src/api/files/mod.rs:173
↓ 1 callersFunctionrender_func_call
(w: &mut impl Write, f: &FuncCall)
rust/actyx/ax-aql/src/language/render.rs:142
↓ 1 callersFunctionrender_indexing
(w: &mut impl Write, e: &Ind)
rust/actyx/ax-aql/src/language/render.rs:42
↓ 1 callersFunctionrender_object
(w: &mut impl Write, e: &Obj)
rust/actyx/ax-aql/src/language/render.rs:63
↓ 1 callersFunctionrender_operation
(w: &mut impl Write, e: &Operation)
rust/actyx/ax-aql/src/language/render.rs:173
↓ 1 callersFunctionrender_simple_pair
(w: &mut impl Write, l: &SimpleExpr, op: &'static str, r: &SimpleExpr)
rust/actyx/ax-aql/src/language/render.rs:6
↓ 1 callersFunctionrender_tag_atom
(w: &mut impl Write, e: &TagAtom)
rust/actyx/ax-aql/src/language/render.rs:243
↓ 1 callersFunctionrender_unary_function
(w: &mut impl Write, f: &str, e: &SimpleExpr)
rust/actyx/ax-aql/src/language/render.rs:16
↓ 1 callersMethodreplication_target
OffsetMap describing the replication target. Currently this is driven via `highest_seen`, but should eventually be fed by the partial replication mech
rust/actyx/ax-core/src/swarm/mod.rs:378
↓ 1 callersFunctionrequest
This code is mostly duplicated from `ax/src/cmd/nodes/ls.rs`
rust/actyx/ax/src/cmd/topics/ls.rs:22
↓ 1 callersFunctionrequest
This code is mostly duplicated from `ax/src/cmd/nodes/ls.rs`
rust/actyx/ax/src/cmd/topics/delete.rs:33
↓ 1 callersMethodrequest
( serviceId: string, payload?: unknown, )
js/sdk/src/internal_common/multiplexedWebSocket.ts:163
↓ 1 callersMethodreserve_lamports
reserve a number of lamport timestamps
rust/actyx/ax-core/src/swarm/mod.rs:686
↓ 1 callersMethodretryAll
()
js/sdk/src/internal_common/multiplexedWebSocket.ts:156
↓ 1 callersFunctionreverseBookKeepingOnChunk
( initialUpperBound: OffsetMap, onChunk: (chunk: EventChunk) => Promise<void> | void, )
js/sdk/src/internal_common/event-fns-impl.ts:116
↓ 1 callersMethodroot
(&self)
rust/actyx/ax-core/src/swarm/streams.rs:176
↓ 1 callersMethodroot_map
Get a complete root map from both own and replicated streams
rust/actyx/ax-core/src/swarm/mod.rs:642
↓ 1 callersFunctionroutes
( store: BlobStore, node_info: NodeInfo, )
rust/actyx/ax-core/src/api/blob.rs:43
↓ 1 callersFunctionroutes
( node_info: NodeInfo, store: BanyanStore, event_service: EventService, pinner: FilePinner,
rust/actyx/ax-core/src/api/mod.rs:143
↓ 1 callersMethodrt
(&self)
rust/actyx/ax-core/src/node/actors.rs:32
↓ 1 callersFunctionrun
(opts: AppsOpts, json: bool)
rust/actyx/ax/src/cmd/apps/mod.rs:19
↓ 1 callersFunctionrun
(opts: SignOpts)
rust/actyx/ax/src/cmd/apps/sign.rs:16
↓ 1 callersFunctionrun
(opts: ExploreTreeOpts)
rust/actyx/ax/src/cmd/internal/trees/explore.rs:32
↓ 1 callersFunctionrun
(opts: LsOpts)
rust/actyx/ax/src/cmd/nodes/ls.rs:103
↓ 1 callersFunctionrun
(opts: UnsetOpt)
rust/actyx/ax/src/cmd/settings/unset.rs:44
↓ 1 callersFunctionrun
(opts: SchemaOpt)
rust/actyx/ax/src/cmd/settings/schema.rs:30
↓ 1 callersFunctionrun
( SetOpt { actual_opts, console_opt, }: SetOpt, )
rust/actyx/ax/src/cmd/settings/set.rs:90
↓ 1 callersFunctionrun
(opts: GetOpt)
rust/actyx/ax/src/cmd/settings/get.rs:42
↓ 1 callersFunctionrun
( SettingsLocalUnsetOpts { actual_opts, working_dir, }: SettingsLocalUnsetOpts, )
rust/actyx/ax/src/cmd/settings/local/unset.rs:40
↓ 1 callersFunctionrun
( SettingsLocalInitOpts { fail_on_existing, working_dir, }: SettingsLocalInitOpts, )
rust/actyx/ax/src/cmd/settings/local/init.rs:53
↓ 1 callersFunctionrun
( SettingsLocalSetOpts { actual_opts, working_dir, }: SettingsLocalSetOpts, )
rust/actyx/ax/src/cmd/settings/local/set.rs:46
↓ 1 callersFunctionrun
( SettingsLocalGetOpts { actual_opts: GetSettingsCommand { no_defaults, scope }, working_d
rust/actyx/ax/src/cmd/settings/local/get.rs:35
↓ 1 callersFunctionrun
(mut config: Config)
rust/actyx/swarm/cli/src/main.rs:63
↓ 1 callersFunctionrun
(tmp: &Path)
rust/actyx/swarm/harness/src/bin/versions.rs:215
↓ 1 callersFunctionrun
( node_info: NodeInfo, store: BanyanStore, event_store: EventStoreRef, blobs: BlobStore, b
rust/actyx/ax-core/src/api/mod.rs:96
↓ 1 callersMethodrun
(mut self)
rust/actyx/ax-core/src/node/node_impl.rs:301
↓ 1 callersFunctionsaveAndReloadDataViaIpc
(new_data: Data | null, onData: (data: Data) => void)
js/node-manager/src/client/store/index.tsx:18
↓ 1 callersMethodsearch
(input)
web/developer.actyx.com/src/theme/SearchBar/lunar-search.js:131
↓ 1 callersFunctionselect_multi
run multiple selections where you don’t know the order in advance (or don’t care) The individual things to check are most conveniently constructed us
rust/actyx/swarm/harness/src/lib.rs:246
↓ 1 callersMethodsemVer
* * @returns the semantic version part of the full version string, e.g. `2.6.1`
js/sdk/src/node-info.ts:70
↓ 1 callersMethodserve
(&self, app_id: AppId, req: Self::Req)
rust/actyx/ax-core/src/api/events/ws/query.rs:23
↓ 1 callersFunctionserve_it
Create a hyper server with the provided `filter`, binding to `addr`. This also sets the `TCP_NODELAY` flag on incoming connections.
rust/actyx/ax-core/src/api/hyper_serve.rs:36
↓ 1 callersFunctionservice
(event_service: EventService)
rust/actyx/ax-core/src/api/events/ws/query.rs:35
↓ 1 callersFunctionsetOrReplace
(s: object, path: string, val: unknown)
js/node-manager/src/client/screens/Settings.tsx:14
← previousnext →1,201–1,300 of 3,158, ranked by callers