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
↓ 11 callersFunctionnew_local_gateway_state
( transfer_state_store: FluxonFsTransferStateStoreConfig, )
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:765
↓ 11 callersFunctionrequest_identity_from_account
(account: &AuthAccount)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2627
↓ 11 callersFunctionrun_local_transfer_check_blocking
( arg: LocalTransferCheckArg, )
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:1552
↓ 11 callersMethodshare_mem_path
Get the configured shared-memory base path (external mode). Non-external modes return empty string.
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:1227
↓ 11 callersFunctionsort_value_opt
(v: Option<f64>)
fluxon_rs/fluxon_cli/src/model.rs:1845
↓ 11 callersFunctiontag_list_to_mask
(tags: &[String], ctx: &str)
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:67
↓ 11 callersFunctiontest_worker_assignment
( relpath: &str, size: i64, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6143
↓ 11 callersMethodto_result
(self)
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/rpcresp_kvresult_convert.rs:36
↓ 11 callersFunctiontransfer_engine_call
( handle: ClosedRuntimeHandle, call: ClosedRuntimeTransferEngineCall, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1710
↓ 11 callersMethodtry_submit
(&self, op: ObserveOp)
fluxon_rs/fluxon_observability/src/kv_metrics_actor.rs:896
↓ 10 callersFunction_find_deploy_instance
(resolved_case: Dict[str, Any], *, instance_id: str)
fluxon_test_stack/test_runner.py:11462
↓ 10 callersFunction_otlp_len_field
(field_number: int, payload: bytes)
fluxon_test_stack/distributed_benchmark_node.py:426
↓ 10 callersFunction_raise_if_process_exited
( proc: subprocess.Popen, *, label: str, log_path: Optional[Path] = None, log_dir: Optiona
examples/fluxon_quick_start/start.py:832
↓ 10 callersFunction_replace_symlink
(*, link_path: Path, target_path: str)
setup_and_pack/nix/lib_layout.py:764
↓ 10 callersFunction_require_dict
(raw: Any, field_name: str)
deployment/gen_bare_deploy_bash.py:846
↓ 10 callersFunction_require_str
(raw: Any, field_name: str)
deployment/gen_bare_deploy_bash.py:863
↓ 10 callersFunction_top_attention_command
( *, command_id: str, script_name: str, case_config: bool = False, timeout_seconds: int =
fluxon_test_stack/tests/test_test_runner_testbed_contract.py:43
↓ 10 callersFunction_validate_positive_int
(name: str, value: int)
fluxon_py/tests/test_api_chan_mpmc/test_mpmc_simple_bench.py:685
↓ 10 callersFunctionaccess_model_from_permission_list
( permission_list: &[FluxonFsS3PermissionAccount], )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2677
↓ 10 callersMethodas_db_str
(&self)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/types.rs:129
↓ 10 callersMethodcallback_path_for_child
( &self, parent: INodeNo, name: &OsStr, )
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:267
↓ 10 callersMethodchan_id
(&self)
fluxon_rs/fluxon_pyo3/src/mpsc.rs:514
↓ 10 callersMethodclosed_runtime_handle
(&self)
fluxon_rs/fluxon_commu/src/facade/p2p.rs:366
↓ 10 callersFunctioncreate_channel_env
Return a mutable container that tracks backend/test resources.
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:135
↓ 10 callersMethoddedup_expire_unix_ms
(&self)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:3507
↓ 10 callersFunctiondesired_workload_authority
(w: &DesiredWorkload)
fluxon_rs/fluxon_ops/src/lib.rs:5938
↓ 10 callersFunctionduration_to_i64_us
(duration: std::time::Duration)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:69
↓ 10 callersMethodfinish_batch_send
( &self, batch: &RemoteWriteSessionClientSendBatch, result: Result<(), String>, )
fluxon_rs/fluxon_fs/src/agent.rs:761
↓ 10 callersMethodhandle
(&self, _from_node: NodeID, payload: &[u8])
fluxon_rs/fluxon_ops/src/lib.rs:2949
↓ 10 callersFunctionhandle_any_authed_impl
( st: Arc<GatewayState>, auth_ctx: AuthCtx, method: Method, path: String, uri: Uri, he
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:3132
↓ 10 callersFunctioninvalid
(detail: impl Into<String>)
fluxon_rs/fluxon_fs/src/agent_service.rs:1743
↓ 10 callersMethodjoin
(&self, child: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:1682
↓ 10 callersMethodkv
(&self)
fluxon_rs/fluxon_kv/src/user_api/fluxon_backend.rs:29
↓ 10 callersMethodload_apply_record
(&self, apply_id: &str)
fluxon_rs/fluxon_ops/src/lib.rs:6035
↓ 10 callersMethodmap_agent_err
( &self, export_name: Arc<str>, relpath: Arc<str>, e: FsAgentError, )
fluxon_rs/fluxon_fs/src/master_http.rs:202
↓ 10 callersMethodmetadata_cache_invalidate_exact_and_publish
(&self, export_name: &str, relpath: &str)
fluxon_rs/fluxon_fs/src/agent.rs:5220
↓ 10 callersFunctionnew_general_error
(py: Python<'_>, message: &str)
fluxon_rs/fluxon_pyo3/src/error.rs:127
↓ 10 callersFunctionnext_backoff
(cfg: BackoffConfig, attempt: u32)
fluxon_rs/fluxon_fs_core/src/retry.rs:16
↓ 10 callersFunctionnormalize_abs_dir_label
Normalize an absolute directory path for use as a stable metric label value. Contract: - trims whitespace - strips trailing slashes while preserving
fluxon_rs/fluxon_util/src/fs_statvfs.rs:123
↓ 10 callersMethodobservability_disabled
(&self)
fluxon_rs/fluxon_kv/src/metrics.rs:163
↓ 10 callersFunctionparse_master_config_from_yaml_text
( text: &str, )
fluxon_rs/fluxon_fs_core/src/config.rs:2348
↓ 10 callersFunctionprom_scalar_best_effort
( warnings: &mut Vec<String>, prom: &PromClient, label: &str, promql: &str,
fluxon_rs/fluxon_cli/src/lib.rs:1867
↓ 10 callersMethodremove
(self, key: str)
setup_and_pack/tests/test_quick_start_release_only.py:74
↓ 10 callersMethodshutdown
(&self)
fluxon_rs/fluxon_kv/src/cluster_manager/cluster_manager_test.rs:131
↓ 10 callersFunctionspawn_blocking
English note: - We intentionally re-export spawn_blocking through this wrapper so the entire codebase shares the same "sync-async bridge allowed" mark
fluxon_rs/limit_thirdparty/src/lib.rs:69
↓ 10 callersMethodstart
(self)
fluxon_test_stack/distributed_benchmark_node.py:1109
↓ 10 callersMethodstart
Start the keep-alive thread.
fluxon_py/etcd.py:148
↓ 10 callersMethodstream_mut
(&mut self)
fluxon_rs/fluxon_fs_fuse_draft/src/file_entry.rs:46
↓ 10 callersFunctionsudo_prefix
Choose whether to use sudo for docker-related shell commands. We intentionally prefer running docker as the current user whenever possible.
setup_and_pack/utils/sudo_prefix_utils.py:16
↓ 10 callersMethodsymlink
(&self, linkname: &str, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:825
↓ 10 callersFunctionto_snake
(ty: &str)
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:3001
↓ 10 callersFunctionui_require_bucket
(st: &GatewayState, bucket: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr.rs:471
↓ 10 callersFunctionuser_rpc_register_handler
(p2p: &P2pModule, path: String, handler: Arc<dyn UserRpcHandler>)
fluxon_rs/fluxon_kv/src/p2p/p2p_module.rs:77
↓ 10 callersFunctionverify_user_object_key
(relpath: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:3592
↓ 10 callersFunctionwait_for_selection_absent
( kind: WorkloadKind, name: &str, authority: &str, require_apply_id: Option<&str>, )
fluxon_rs/fluxon_ops/src/lib.rs:2161
↓ 9 callersFunction_owner_fluxonkv_base_config
( *, instance_key: str = "test_instance", cluster_name: str = "test_cluster", share_mem_path:
fluxon_py/tests/test_config.py:151
↓ 9 callersFunction_parse_sha256_manifest
(text: str)
deployment/manual_dispatch_release.py:148
↓ 9 callersFunction_pick_free_port
()
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:853
↓ 9 callersFunction_require_test_stack_machine_count
(raw_topology: Any, field_name: str)
fluxon_test_stack/test_runner.py:4905
↓ 9 callersFunction_required_profile_native_dir_names
(*, selected_backend_plan: dict)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1469
↓ 9 callersFunction_run
(argv: list[str], *, env: dict[str, str] | None = None)
fluxon_test_stack/ci_2_virt_node.py:654
↓ 9 callersFunction_suite_cfg_with_declared_ci_commands
(command_map: dict[str, list[dict]])
fluxon_test_stack/tests/test_test_runner_testbed_contract.py:63
↓ 9 callersFunction_to_env_key
(x: str)
deployment/gen_docker_deploy_bash.py:499
↓ 9 callersFunction_validate_release_manifest_integrity
( *, release_root: Path, manifest: Dict[str, str], ctx: str, )
fluxon_test_stack/test_runner.py:11711
↓ 9 callersFunctionagent_instance_key_from_node_name
(node_name: &str)
fluxon_rs/fluxon_ops/src/lib.rs:758
↓ 9 callersMethodbase_ptr
Removed trivial helper: inline-match OwnerStartTimeMismatch directly where needed. 获取共享内存基址（以 usize 表示的地址）；未就绪时返回 NotConfigured
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:895
↓ 9 callersMethodcallback_path
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/path_projection.rs:12
↓ 9 callersMethodclose
(self)
fluxon_test_stack/benchmark_node_kv.py:1817
↓ 9 callersFunctionclosed_cluster_manager_member_call
( handle: ClosedRuntimeHandle, call: ClosedRuntimeClusterManagerCall, )
fluxon_rs/fluxon_commu/src/facade/cluster_manager.rs:551
↓ 9 callersFunctionclosed_p2p_unit_call
( handle: ClosedRuntimeHandle, call: ClosedRuntimeP2pCall, )
fluxon_rs/fluxon_commu/src/facade/p2p.rs:289
↓ 9 callersMethoddelete_entry_paths
(&self, key: &str)
fluxon_rs/fluxon_fs/src/remote_disk_cache.rs:287
↓ 9 callersFunctionduration_to_i64_us
(duration: std::time::Duration)
fluxon_rs/fluxon_kv/src/client_kv_api/external_api.rs:25
↓ 9 callersMethodfinish
(mut self, res: Result<(), CoreMpscError>)
fluxon_rs/fluxon_pyo3/src/mpsc.rs:1815
↓ 9 callersMethodget_node_allocators
(&self, node_id: &NodeID)
fluxon_rs/fluxon_kv/src/master_seg_manager/mod.rs:319
↓ 9 callersMethodget_self_info
(&self)
fluxon_rs/fluxon_commu/src/facade/cluster_manager.rs:938
↓ 9 callersMethodgetattr
(&self, _req: &Request, ino: INodeNo, _fh: Option<FileHandle>, reply: ReplyAttr)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:445
↓ 9 callersFunctionhandle_transfer_stream_next
( registry: &TransferReadStreamRegistryHandle, payload: FlatDict, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:5974
↓ 9 callersFunctionhost_user_rpc_callback_failure
( detail: impl ToString, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1143
↓ 9 callersFunctioninit_log
Init log for production. - `log_path`: directory to write log files - `instance_key`: used in daily file names to disambiguate instances
fluxon_rs/fluxon_util/src/log.rs:285
↓ 9 callersMethodinstall
(self)
fluxon_py/fluxon_fs/patcher.py:657
↓ 9 callersFunctionio_error_to_os
(path: &str, e: std::io::Error)
fluxon_rs/fluxon_fs/src/agent.rs:6907
↓ 9 callersMethodlaunch_detached
( &self, kind: WorkloadKind, name: &str, authority: &str, service_name
fluxon_rs/fluxon_ops/src/lib.rs:1268
↓ 9 callersFunctionlive_selection_supervisors
( snapshot: &SelectionSupervisorProcSnapshot, label_filter: Option<&str>, scope_key_filter: Option
fluxon_rs/fluxon_ops/src/lib.rs:1559
↓ 9 callersFunctionmaster_invalid
(detail: impl Into<String>)
fluxon_rs/fluxon_fs_core/src/config.rs:2311
↓ 9 callersFunctionmountpoint_is_mounted
(mountpoint_dir_abs: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2854
↓ 9 callersFunctionnew_test_consumer
( construct_type: str, store: KvClient, chan_id: Optional[str], chan_config: Dict[str, int],
fluxon_py/tests/test_lib.py:384
↓ 9 callersMethodobserve
(&self)
fluxon_rs/fluxon_kv/src/metrics.rs:159
↓ 9 callersMethodobserve_request_duration_with_labels
( &self, _op: OperationKind, _stage: RequestStage, _seconds: f64, )
fluxon_rs/fluxon_kv/src/metrics.rs:630
↓ 9 callersFunctionparse_dep_entry
(dep: &str)
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:147
↓ 9 callersFunctionparse_global_config_from_yaml_text
(text: str)
fluxon_py/fluxon_fs/config_types.py:273
↓ 9 callersFunctionput_record
( tx: &mut Transaction, key: Vec<u8>, value: &T, context: &str, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5367
↓ 9 callersFunctionrequire_transfer_payload_str
(payload: &FlatDict, key: &str)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:1819
↓ 9 callersFunctionresp_err
(kind: FsAgentRpcErrorKind, detail: impl Into<String>, errno: Option<i32>)
fluxon_rs/fluxon_fs/src/agent_service.rs:2394
↓ 9 callersFunctionrun_master
( config_arg: ConfigArg<MasterConfig>, )
fluxon_rs/fluxon_kv/src/lib.rs:1545
↓ 9 callersFunctionrun_python_file
( description: str, path: str, extra_args: Iterable[str] = (), )
fluxon_test_stack/top_attention_test_index/_common.py:53
↓ 9 callersMethodsize
Returns the value size of the allocation.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:60
↓ 9 callersMethodto_fluxon_kv_client_config_yaml_str
Build the YAML string expected by the Rust `ClientConfigYaml` schema.
fluxon_py/config.py:563
↓ 9 callersMethodtotal_size_bytes
Returns total capacity (bytes) of this segment.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:141
↓ 9 callersMethodts_one
( &self, name: &'static str, extra_labels: &[(&'static str, String)], value: f
fluxon_rs/fluxon_mq/src/consumer.rs:869
↓ 9 callersFunctionui_page_html
( title_suffix: &str, home_href: &str, buckets_href: &str, transfers_href: &str, active_na
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:340
← previousnext →401–500 of 9,070, ranked by callers