MCPcopy Create free account

hub / github.com/Tele-AI/Fluxon / functions

Functions9,070 in github.com/Tele-AI/Fluxon

⨍ Functions 9,070◇ Types & classes 1,788↳ Endpoints 6
↓ 22 callersFunctionhandle_error
Log the error and close the store explicitly.
fluxon_py/tests/test_backend.py:107
↓ 22 callersFunctionjoin_abs
(base_dir_abs: &str, child: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2756
↓ 22 callersFunctionspawn_blocking_allow_sync_async_bridge
A unified spawn_blocking wrapper that allows calling `run_async_from_sync` inside the blocking closure. English note: this exists to keep the contrac
fluxon_rs/fluxon_util/src/run_async_from_sync.rs:130
↓ 22 callersFunctiontake_node_metric
(samples: &[PromSample])
fluxon_rs/fluxon_cli/src/prom.rs:400
↓ 22 callersMethodvalue_f64
(&self)
fluxon_rs/fluxon_cli/src/prom.rs:226
↓ 22 callersFunctionwrite_repeat_file
(root: &TempDir, relpath: &str, byte: u8, size: usize)
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:1811
↓ 21 callersFunction_require_dict
(raw: Any, ctx: str)
fluxon_test_stack/top_attention_test_index/_largescale_mq.py:47
↓ 21 callersFunction_shell_single_quote
(s: str)
deployment/gen_docker_deploy_bash.py:461
↓ 21 callersFunctionaccount_has_object_action
( account: &AuthAccount, bucket: &str, key: &str, action: FluxonFsS3PermissionAction, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2772
↓ 21 callersMethodget_members
(&self)
fluxon_rs/fluxon_commu/src/facade/cluster_manager.rs:906
↓ 21 callersMethodget_or_init
获取 Key 对应的值。如果不存在，则使用 init_fn 初始化。
fluxon_rs/fluxon_util/src/auto_clean_map.rs:34
↓ 21 callersMethodinto_text_response
(self)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_types.rs:49
↓ 21 callersFunctionnew_fs
()
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:1754
↓ 21 callersFunctionnew_test_producer
( construct_type: str, store: KvClient, chan_id: Optional[str], chan_config: Dict[str, int],
fluxon_py/tests/test_lib.py:430
↓ 21 callersMethodnotify
(&self)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/types.rs:486
↓ 21 callersFunctionpy_error_from_kv_error
Typed mapping: map Rust-side KvError to Python ApiError instance. 收束规则（最小必要）： - TransferEngine::TransferFailedForBlock -> TransferBlockFailedError（可重
fluxon_rs/fluxon_pyo3/src/error.rs:358
↓ 21 callersFunctionrelease
(env: "ChannelState", *resources: Union[str, KvClient])
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:212
↓ 21 callersMethodtruncate
(&self, callback_path: &str, size: u64)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:555
↓ 21 callersMethodview
(&self)
fluxon_rs/fluxon_kv/src/master_kv_router/mod.rs:397
↓ 20 callersFunction_require_clean_relpath
(raw: Any, ctx: str)
fluxon_test_stack/test_runner.py:5967
↓ 20 callersFunction_terminate_process
(proc: Optional[subprocess.Popen[str]])
deployment/tests/test_selection_supervisor_codegen.py:190
↓ 20 callersFunctioncompose_key
(prefix: &[u8], namespace: &[u8], parts: &[&[u8]])
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5354
↓ 20 callersMethodexport_root_dir_abs
(&self, export_name: &str)
fluxon_rs/fluxon_fs/src/agent_service.rs:212
↓ 20 callersMethodget_prefix
(&self, py: Python<'_>, prefix: String)
fluxon_rs/fluxon_pyo3/src/etcd.rs:194
↓ 20 callersMethodread_bytes
(self)
deployment/tests/test_selection_supervisor_codegen.py:891
↓ 20 callersMethodsend_slow_command
( &self, build: impl FnOnce(ResponseSender<T>) -> StoreCommand, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:188
↓ 20 callersMethodstat
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5391
↓ 19 callersFunction_run_supervisor_command
( *, supervisor_path: Path, label: str, owner_ts_ms: int, state_json: str, child_argv:
deployment/tests/test_selection_supervisor_codegen.py:142
↓ 19 callersMethodcall
( &self, p2p: &P2pModule, node_id: NodeID, req: MsgPack<R>,
fluxon_rs/fluxon_commu/src/facade/p2p.rs:1107
↓ 19 callersFunctionobserve_selection_status
( kind: WorkloadKind, name: &str, authority: &str, )
fluxon_rs/fluxon_ops/src/lib.rs:1876
↓ 19 callersFunctionsafe_relpath
Normalize a user-provided relative path into a safe POSIX-style relpath. Rules: - No leading slash - No `..` segments - Collapses repeated separators
fluxon_rs/fluxon_fs_core/src/path.rs:19
↓ 19 callersFunctionui_scope_access_page_response
( st: &GatewayState, identity: &UiIdentity, error_msg: Option<&str>, success_msg: Option<&str>
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:864
↓ 19 callersMethodview
(&self)
fluxon_rs/fluxon_kv/src/client_seg_pool/mod.rs:230
↓ 19 callersFunctionwrite_file
(fs: &FluxonFuseFileSystem, path: &str, bytes: &[u8])
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:1730
↓ 18 callersFunction_record_fluxon_path_metric_sample
( stat: Dict[str, Any], metric_name: str, path_bucket: str, sample_us: Optional[float], )
fluxon_test_stack/benchmark_node_rpc.py:1082
↓ 18 callersFunction_record_fluxon_path_metric_sample
( stat: Dict[str, Any], metric_name: str, path_bucket: str, sample_us: Optional[float], )
fluxon_test_stack/benchmark_node_kv.py:967
↓ 18 callersFunction_require_mapping
(value: Any, field_name: str)
fluxon_test_stack/start_test_bed.py:1036
↓ 18 callersFunctionaccess_model_required_mode_for_op
(op: FluxonFsOp)
fluxon_rs/fluxon_fs_core/src/config.rs:2046
↓ 18 callersMethodapply_transfer_worker_result
( &self, result: &FluxonFsTransferWorkerResultWire, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:730
↓ 18 callersMethodas_str
(self)
fluxon_rs/fluxon_kv/src/user_rpc.rs:30
↓ 18 callersFunctionauthorize_relpath_mode
( access_model: &AgentAccessModelHandle, payload: &FlatDict, export_name: &str, relpath: &str,
fluxon_rs/fluxon_fs/src/agent_service.rs:2438
↓ 18 callersFunctionensure_dir
(path: Path)
scripts/_build_doc_site_in_container_inner.py:1928
↓ 18 callersMethodfinish_transfer_scan_epoch
(&self, job_id: &str, scan_epoch: i64)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:616
↓ 18 callersMethodget
External Get operation (outer): retry + wait wrapper around get_inner
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:1614
↓ 17 callersFunction_docker_build_require_non_empty_string
(raw_value: Any, *, field_name: str)
setup_and_pack/utils/docker_build_runtime_utils.py:53
↓ 17 callersFunction_normalize_abs
(path: Any)
fluxon_py/fluxon_fs/patcher.py:21
↓ 17 callersFunction_require_single_object_of_kind
(*, object_ids_by_kind: dict[str, list[str]], kind: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3451
↓ 17 callersFunction_wait_until_present
(module, label: str, *, timeout_seconds: int = 15)
deployment/tests/test_selection_supervisor_codegen.py:265
↓ 17 callersMethodclose
Close the lease manager and remove all managed leases.
fluxon_py/etcd.py:229
↓ 17 callersMethodis_running
(v: &Self::View)
fluxon_rs/fluxon_kv/src/memholder/lifetime.rs:64
↓ 17 callersMethodmetadata
(&self, relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:1263
↓ 17 callersFunctionrequire_kv_framework_api
(client: &KvClient, py: Python)
fluxon_rs/fluxon_pyo3/src/lib.rs:846
↓ 17 callersFunctionresponse_plain
(status: StatusCode, body: &str)
fluxon_rs/fluxon_ops/src/lib.rs:6564
↓ 17 callersFunctionrun_cargo
( args: Iterable[str], *, env: dict[str, str] | None = None, passthrough: Sequence[str] | None
fluxon_test_stack/top_attention_test_index/_common.py:246
↓ 17 callersFunctionrun_client
( config_arg: ConfigArg<ClientConfig>, )
fluxon_rs/fluxon_kv/src/lib.rs:2403
↓ 17 callersMethodshared_storage_node_id
Get the shared storage node ID this client connects to
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:1220
↓ 17 callersMethodshutdown
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1957
↓ 16 callersFunction_fluxon_segment_metric_sample_us
( segment_sample: Mapping[str, float], metric_name: str, )
fluxon_test_stack/benchmark_node_rpc.py:1054
↓ 16 callersFunction_fluxon_segment_metric_sample_us
( segment_sample: Mapping[str, float], metric_name: str, )
fluxon_test_stack/benchmark_node_kv.py:957
↓ 16 callersFunction_native_object_dir_name
(*, object_id: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1447
↓ 16 callersFunction_runner_repo_root
()
fluxon_test_stack/test_runner.py:3824
↓ 16 callersFunction_runtime_state_json
( *, name: str, service_name: str, child_argv: List[str], root: Path, apply_id: Option
deployment/tests/test_selection_supervisor_codegen.py:121
↓ 16 callersFunction_validate_positive_int
(name: str, value: int)
fluxon_py/tests/test_api_chan_mpmc/test_mpmc_simple_bench2.py:834
↓ 16 callersFunctionaccount_can_manage_permissions
(account: &AuthAccount)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2689
↓ 16 callersFunctionbuild_transfer_scan_result_for_root_dir_abs
( root_dir_abs: &str, assignment: &FluxonFsTransferScanAssignmentWire, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:4905
↓ 16 callersFunctiondecode_result_json
(resp: &FlatDict)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6074
↓ 16 callersMethoddelete_prefix
(&self, py: Python<'_>, prefix: String)
fluxon_rs/fluxon_pyo3/src/etcd.rs:325
↓ 16 callersMethodfind_or_wait_master_node
(&self)
fluxon_rs/fluxon_kv/src/cluster_manager/app_logic_ext.rs:17
↓ 16 callersFunctionhandle_transfer_scan_assignment
( exports: &AgentExportsHandle, assignment: FluxonFsTransferScanAssignmentWire, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:5191
↓ 16 callersFunctioninvalid
(detail: impl Into<String>)
fluxon_rs/fluxon_fs_core/src/config.rs:342
↓ 16 callersMethodis_closed
Check whether shutdown has been requested.
fluxon_rs/fluxon_mq/src/shutdown.rs:37
↓ 16 callersFunctionmax_opt_f64
(values: impl Iterator<Item = Option<f64>>)
fluxon_rs/fluxon_cli/src/web_renderer.rs:305
↓ 16 callersFunctionnew_store
Factory function to create a KV cache store with the appropriate backend.
fluxon_py/kvclient/__init__.py:106
↓ 16 callersMethodput_data
Put data to the MPMC channel. Callers may invoke put_data / close concurrently from multiple threads. Coordination uses MqShutdownCtl
fluxon_py/_api_ext_chan/mpmc.py:2026
↓ 16 callersFunctionrequire_i64
(payload: &FlatDict, key: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2888
↓ 16 callersFunctionrequire_store
( env: "ChannelState", instance_key: str, *, backend_type: Optional[str] = None, backend_i
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:168
↓ 15 callersMethod_is_remote
(self, file_abs: str)
fluxon_py/fluxon_fs/patcher.py:1169
↓ 15 callersMethod_send_tcp_response
Send a TCP response.
fluxon_test_stack/distributed_benchmark_coordinator.py:1878
↓ 15 callersMethodaccess
(self)
fluxon_py/kvclient/fluxon.py:280
↓ 15 callersMethodcallback_path_for_ino
(&self, ino: INodeNo)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:254
↓ 15 callersMethodclose
(self)
fluxon_test_stack/gitops/gitops_lib.py:520
↓ 15 callersMethodget_consumer_id
Get the consumer index.
fluxon_py/_api_ext_chan/mpmc.py:2426
↓ 15 callersMethodis_exist
(&self, key: &str)
fluxon_rs/fluxon_kv/src/client_kv_api/get.rs:349
↓ 15 callersFunctionis_internal_multipart_relpath
(relpath: &str)
fluxon_rs/fluxon_fs_core/src/s3_gateway.rs:41
↓ 15 callersMethodlen
(&self)
fluxon_rs/fluxon_mq/src/consumer.rs:629
↓ 15 callersFunctionnew_none_success_instance
Compatibility wrappers: delegate to crate::error central helpers.
fluxon_rs/fluxon_pyo3/src/lib.rs:1880
↓ 15 callersFunctionobserve_selection_status_for_scope
( kind: WorkloadKind, name: &str, authority: &str, scope_key: Option<&str>, )
fluxon_rs/fluxon_ops/src/lib.rs:1823
↓ 15 callersFunctionread_etcd_endpoint_from_build_config
Read etcd endpoint from build_config_ext.yml and ensure it has http/https scheme. Accepts either a scalar string like "10.126.126.235:2579" or a YAML
fluxon_rs/fluxon_util/src/dev_config.rs:110
↓ 15 callersFunctionrelpath_cstring
(relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2086
↓ 15 callersFunctionselection_status_matches_present
( status: &SelectionSupervisorStatus, apply_id: &str, owner_ts_ms: u64, argv: &[String], c
fluxon_rs/fluxon_ops/src/lib.rs:2206
↓ 15 callersMethodset_stage
(&self, stage: &str)
fluxon_rs/fluxon_ops/src/lib.rs:4633
↓ 15 callersFunctiontest_state_with_buckets
( backend: Arc<dyn FsS3Backend>, buckets: &[&str], )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:6977
↓ 15 callersFunctiontry_from_code
Centralized: convert code+desc to KvError or Ok if code==Ok
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/rpcresp_kvresult_convert.rs:135
↓ 15 callersFunctionworkload_key
(kind: WorkloadKind, name: &str)
fluxon_rs/fluxon_ops/src/lib.rs:183
↓ 14 callersFunction_bench_kv_print
(msg: str, *, verbose_only: bool = False)
fluxon_test_stack/benchmark_node_kv.py:1836
↓ 14 callersFunction_require_list_of_str
(value: Any, field_name: str)
fluxon_test_stack/start_test_bed.py:4228
↓ 14 callersFunction_sha256_file
(path: Path)
deployment/manual_dispatch_release.py:519
↓ 14 callersFunction_write_runtime_script
(root: Path, *, term_seconds: int = 5, kill_seconds: int = 5, supersede_seconds: int = 2)
deployment/tests/test_selection_supervisor_codegen.py:102
↓ 14 callersMethodas_str
(&self)
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/msg_and_error.rs:75
↓ 14 callersMethodclone_view
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:762
← previousnext →201–300 of 9,070, ranked by callers