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
↓ 9 callersFunctionui_user_actions_html
( identity: &UiIdentity, account_password_href: &str, admin_manage_href: &str, exit_view_as_hr
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:685
↓ 9 callersFunctionwait_for_selection_present
( kind: WorkloadKind, name: &str, authority: &str, )
fluxon_rs/fluxon_ops/src/lib.rs:2027
↓ 9 callersMethodworker_attempt_key
(&self, job_id: &str, worker_task_id: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5313
↓ 9 callersFunctionwrite_error
( writer: &mut W, s: &str, )
fluxon_rs/fluxon_kv/src/redis_compat.rs:158
↓ 8 callersFunction_atomic_stdout_write_line
(line: str)
fluxon_py/tests/test_api_chan_mpmc/test_api_chan_mpmc_base.py:114
↓ 8 callersFunction_check_output_bash_with_optional_password
(*, password: str | None, cmd: str)
deployment/manual_dispatch_release.py:213
↓ 8 callersFunction_debug_print
Lightweight debug print with flush for easier tracing. Uses stdout directly so messages appear even if logging buffers.
fluxon_test_stack/distributed_benchmark_node.py:972
↓ 8 callersFunction_docker_build_optional_string_list
(raw_value: Any, *, field_name: str)
setup_and_pack/utils/docker_build_runtime_utils.py:62
↓ 8 callersFunction_docker_build_render_run
(commands: Sequence[str])
setup_and_pack/utils/docker_build_runtime_utils.py:91
↓ 8 callersFunction_hex_preview
Return hex of the first N bytes for compact diagnostics.
fluxon_py/api_msg.py:18
↓ 8 callersFunction_is_write_mode
(mode: str)
fluxon_py/fluxon_fs/patcher.py:29
↓ 8 callersFunction_load_test_bed_deployconf_path
()
fluxon_test_stack/test_runner.py:1503
↓ 8 callersFunction_load_test_bed_manifest_opt
()
fluxon_test_stack/test_runner.py:1515
↓ 8 callersFunction_load_test_stack_cluster_nodes_and_dispatch
(resolved_case: Dict[str, Any])
fluxon_test_stack/test_runner.py:10235
↓ 8 callersMethod_mark_progress
(self, *, thread_id: int, op_idx: int, finish_ts: float, latency_us: float)
fluxon_test_stack/distributed_benchmark_node.py:1246
↓ 8 callersFunction_new_mpmc_ready_channels_prefix
Get the prefix for all ready channels in MPMC channel.
fluxon_py/_api_ext_chan/mpmc.py:445
↓ 8 callersFunction_new_unique_mapping_key
(unique_id: str)
fluxon_py/api_ext_chan.py:42
↓ 8 callersFunction_nix_path_expr
(path: Path)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3961
↓ 8 callersFunction_normalize_test_spec_config
(raw: Any, ctx: str)
fluxon_test_stack/test_runner.py:4040
↓ 8 callersFunction_relay_run
( args: Sequence[Union[str, Path]], *, cwd: Optional[Path] = None, timeout_seconds: Optional[i
fluxon_py/tests/test_backend_relay_docker.py:196
↓ 8 callersFunction_require_process_running
( proc: subprocess.Popen[str], *, label: str, log_path: Path, )
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:1177
↓ 8 callersFunction_require_str
(raw: Any, field_name: str)
deployment/utils/selection_runtime.py:145
↓ 8 callersFunction_resolve_repo_root_cli_path
(*, raw_path: Path, field_name: str)
fluxon_test_stack/pack_test_stack_rsc.py:512
↓ 8 callersFunction_resolve_service_nodes
(*, services: dict[str, Any], service_name: str)
fluxon_test_stack/start_test_bed.py:2049
↓ 8 callersFunction_run_subprocess
(argv: List[str], *, cwd: str)
fluxon_test_stack/test_runner.py:11114
↓ 8 callersFunction_subst_runtime_tokens
(resolved_case: Dict[str, Any], s: str)
fluxon_test_stack/test_runner.py:2266
↓ 8 callersFunction_write_sleep_child
(root: Path, filename: str)
deployment/tests/test_selection_supervisor_codegen.py:364
↓ 8 callersMethodalloc
(&self, size: u64)
fluxon_rs/fluxon_util/src/vallocator/mod.rs:89
↓ 8 callersFunctionapply_lifecycle_phase_normalized
(v: Option<ApplyLifecyclePhase>)
fluxon_rs/fluxon_ops/src/lib.rs:6497
↓ 8 callersMethodapply_transfer_worker_heartbeat
( &self, heartbeat: &fluxon_fs_core::config::FluxonFsTransferWorkerHeartbeatWire, hear
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:759
↓ 8 callersFunctioncache_extract_invalid
(detail: impl Into<String>)
fluxon_rs/fluxon_fs_core/src/config.rs:2950
↓ 8 callersFunctionchmod_mode
(path: &Path, mode: u32)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6068
↓ 8 callersFunctionclean_etcd
()
fluxon_py/tests/test_api_chan_mpmc/test_api_chan_mpmc_base.py:495
↓ 8 callersFunctioncleanup_transfer_worker_attempt_artifacts
Every worker attempt owns exactly one task-scoped staging subtree. Cleaning it on terminal exit prevents stale `.fluxon.stage/...` artifacts from poll
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:5798
↓ 8 callersFunctioncluster_manager_call
( handle: ClosedRuntimeHandle, call: ClosedRuntimeClusterManagerCall, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1686
↓ 8 callersMethodcontains_create
(self)
fluxon_rs/fluxon_fs_fuse_draft/src/open_action.rs:32
↓ 8 callersMethodcurrent_attr_for_path
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:295
↓ 8 callersMethodcurrent_request_identity
(&self)
fluxon_rs/fluxon_fs/src/agent.rs:4851
↓ 8 callersFunctiondecode_next_result_payload
(resp: &FlatDict)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6117
↓ 8 callersFunctionencode_flat_kv_dict
( value: Dict[str, Union[int, float, bool, str, bytes, DLPacked]], )
fluxon_py/kvclient/nonzerocopy_encode.py:373
↓ 8 callersMethodetcd_client
Acquire an etcd client for this channel's backend. ChanManager 内部持有一个已连接的 etcd client，并在此处 返回其 clone；调用方无需也不应通过 LeaseManager 直接拿 底层 client。该方法为同步方法，无
fluxon_rs/fluxon_mq/src/manager.rs:218
↓ 8 callersFunctionexport_rpc_paths_for_export_name_v1
(export_name: &str)
fluxon_rs/fluxon_fs_core/src/config.rs:1525
↓ 8 callersFunctionextend_timeline_span
( out: &mut Vec<RwTimeSeries>, node_id: &str, node_role: &str, phase: &'static str, op: &'
fluxon_rs/fluxon_observability/src/kv_metrics_actor.rs:3721
↓ 8 callersMethodfinish_task
(&self, scan_task_id: &str, dedup_expire_unix_ms: i64)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2876
↓ 8 callersFunctionfmt_opt_with_unit
(v: Option<f64>, digits: usize, unit: &'static str)
fluxon_rs/fluxon_cli/src/model.rs:338
↓ 8 callersMethodinline_bytes_to_fd_plan
( &self, identity_fingerprint: Option<&str>, export_name: Option<&str>, relpat
fluxon_rs/fluxon_fs/src/agent.rs:5260
↓ 8 callersMethodinner
(&self)
fluxon_rs/fluxon_kv/src/master_seg_manager/mod.rs:278
↓ 8 callersMethodis_side_transfer_worker
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/external_api.rs:33
↓ 8 callersFunctionmaybe_run_child_check_from_env
()
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:2623
↓ 8 callersMethodmetrics_handle
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1081
↓ 8 callersFunctionmultipart_load_meta
( st: &GatewayState, request_identity: FluxonFsRequestIdentity, bucket: Arc<str>, upload_id: &
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:4190
↓ 8 callersMethodname
(&self)
fluxon_rs/fluxon_fs/src/framework.rs:33
↓ 8 callersMethodnote_transfer_failure
( &self, job_id: &str, unix_ms: i64, scope: FsTransferFailureScope, me
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:1064
↓ 8 callersFunctionnow_ms
()
fluxon_rs/fluxon_fs/src/cache_controller.rs:421
↓ 8 callersFunctionnow_unix_ms
()
fluxon_rs/fluxon_fs/src/agent.rs:6737
↓ 8 callersFunctionpermission_bucket_matches
(rule_bucket: &str, bucket: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2639
↓ 8 callersFunctionpermission_list_from_access_model
( model: &AccessModel, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2683
↓ 8 callersFunctionpersist_permission_list
( st: &GatewayState, permission_list: &[FluxonFsS3PermissionAccount], )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2818
↓ 8 callersFunctionrelease_host_callback_handle
(handle: ClosedRuntimeHostCallbackHandle)
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1524
↓ 8 callersMethodremote_call_ok_with_internal_multipart
( &self, export_name: &str, export: &FluxonFsExport, rpc_path: &str, p
fluxon_rs/fluxon_fs/src/agent.rs:6354
↓ 8 callersMethodremote_rpc_call_forever
( &self, export_name: &str, export: &FluxonFsExport, rpc_path: &str, p
fluxon_rs/fluxon_fs/src/agent.rs:5622
↓ 8 callersMethodremove
Remove a key from the store with force-delete semantics. - Treat missing key as success. - Return Mooncake semantic errors i
fluxon_py/kvclient/mooncake.py:678
↓ 8 callersMethodrequest_payload_with_identity_and_internal_multipart
( &self, mut payload: FlatDict, request_identity: Option<&FluxonFsRequestIdentity>,
fluxon_rs/fluxon_fs/src/agent.rs:5583
↓ 8 callersMethodrmdir
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:636
↓ 8 callersFunctionset_bool_once
( slot: &mut Option<bool>, next: bool, field_name: &str, )
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2478
↓ 8 callersMethodshutdown
(&self)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:2844
↓ 8 callersMethodshutdown
(&self)
fluxon_rs/fluxon_kv/src/metric_reporter/mod.rs:1202
↓ 8 callersMethodshutdown_poller_is_running
(&self)
fluxon_rs/fluxon_fs/src/agent.rs:1142
↓ 8 callersMethodsnapshot
(&self)
fluxon_rs/fluxon_ops/src/lib.rs:6006
↓ 8 callersFunctionstart_test_etcd
()
fluxon_rs/fluxon_util/src/test_util.rs:162
↓ 8 callersMethodtake_next_batch_for_send
( &self, )
fluxon_rs/fluxon_fs/src/agent.rs:697
↓ 8 callersFunctiontry_new_error_from_mooncake
Convert Mooncake error code to corresponding ApiError. Args: retcode: Mooncake error code message: Optional error message
fluxon_py/api_error.py:1152
↓ 8 callersMethodused_size_bytes
Returns currently allocated bytes in this segment.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:146
↓ 8 callersFunctionwrite_path_key
(export: &str, path: &std::path::Path)
fluxon_rs/fluxon_fs/src/agent_service.rs:381
↓ 7 callersFunction_artifact_cache_subtree_from_parent_root
( *, parent_root: Path, key_prefix_relpath: str, manifest_filename: str, ctx: str, )
fluxon_test_stack/test_runner.py:13054
↓ 7 callersFunction_backend_native_object_id
(selected_backend_plan: dict)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1451
↓ 7 callersFunction_best_effort_close
(obj: Any, *, role: str)
fluxon_py/tests/test_api_chan_mpmc/test_mpmc_simple_bench2.py:985
↓ 7 callersFunction_cluster_node_is_local
(node_cfg: dict[str, Any])
fluxon_test_stack/start_test_bed.py:1852
↓ 7 callersFunction_direct_selection_supervisor_status_is_unsupported
(*, ctx: str)
fluxon_test_stack/start_test_bed.py:3068
↓ 7 callersFunction_instance_status
(resolved_case: Dict[str, Any], *, instance_id: str)
fluxon_test_stack/test_runner.py:15212
↓ 7 callersFunction_json_string_literal
(value: str)
fluxon_test_stack/test_runner.py:11405
↓ 7 callersFunction_observe_status
(module, label: str)
deployment/tests/test_selection_supervisor_codegen.py:206
↓ 7 callersFunction_optional_non_empty_string
(raw_config: dict, key: str)
setup_and_pack/nix/lib_layout.py:814
↓ 7 callersFunction_require_int
(v: Any, name: str)
fluxon_py/fluxon_fs/config_types.py:173
↓ 7 callersFunction_require_mapping
(raw: dict, key: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3991
↓ 7 callersFunction_sh_quote
(s: str)
deployment/gen_k8s_daemonset.py:955
↓ 7 callersFunction_sudo_remove_tree
(path: Path)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3032
↓ 7 callersFunction_test_stack_runner_port_slot
(*, runner_root: Path, stride: int)
fluxon_test_stack/test_runner.py:12907
↓ 7 callersFunction_test_stack_runtime_required_python_abi
(*, resolved_case: Dict[str, Any], run_dir: Path)
fluxon_test_stack/test_runner.py:12811
↓ 7 callersFunction_test_stack_target_host_venv_python
( *, node_cfg: Dict[str, Any], target_name: str, python_abi: str, )
fluxon_test_stack/test_runner.py:12546
↓ 7 callersFunction_ui_workdir_by_id
(service_root: Path, workdir_id: str, extra_history_roots: Optional[List[Path]] = None)
fluxon_test_stack/test_runner.py:15857
↓ 7 callersFunction_write_script
(path: Path, content: str)
deployment/gen_bare_deploy_bash.py:232
↓ 7 callersFunctionaccount_has_bucket_action
( account: &AuthAccount, bucket: &str, prefix: &str, action: FluxonFsS3PermissionAction, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2734
↓ 7 callersFunctionbind_current_process_parent_death_sigterm
()
fluxon_py/runtime/process_runner.py:277
↓ 7 callersFunctionbuild_cluster_snapshot
(cfg: &MonitorConfig)
fluxon_rs/fluxon_cli/src/lib.rs:1462
↓ 7 callersFunctionbuild_rpc_token
( identity: &FluxonFsRequestIdentity, now_unix_ms: i64, )
fluxon_rs/fluxon_fs_core/src/config.rs:2074
↓ 7 callersFunctionbuild_runtime_singleton_spec
( *, module_name: str, entrypoint_path: Path, workdir: Path, )
fluxon_py/runtime/process_runner.py:102
↓ 7 callersFunctionchan_type_from_string
(value: str)
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:1553
↓ 7 callersMethodcheckpoint_continue
(&self)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:1643
↓ 7 callersMethodclose
(self)
fluxon_py/tests/test_fluxon_fs_patcher.py:114
← previousnext →501–600 of 9,070, ranked by callers