MCPcopy Create free account

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

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

↓ 7 callersMethodclose
Close the MPMC channel. The shared shutdown flag is only a stop-request signal. Actual inner lease-handle cleanup must be guarded by
fluxon_py/_api_ext_chan/mpmc.py:1784
↓ 7 callersFunctionclose_store_or_log
Close the store and keep the close outcome visible in test logs.
fluxon_py/tests/test_backend.py:124
↓ 7 callersFunctionconfigure_backend
( env: ChannelState, *, backend_type: Optional[str] = None, backend_ip: Optional[str] = None )
fluxon_py/tests/test_api_chan_mpmc/test_rebind_client.py:205
↓ 7 callersFunctioncstring_path
(path: &str)
fluxon_rs/fluxon_fs/src/agent.rs:7012
↓ 7 callersFunctiondecode_flat_dict_bytes
(data: &[u8])
fluxon_rs/fluxon_kv/src/user_api/codec_flat_dict.rs:17
↓ 7 callersMethodeffective_master_pull_interval_ms
(&self)
fluxon_rs/fluxon_fs/src/agent.rs:1146
↓ 7 callersFunctionencode_flat_dict_bytes
(value: &FlatDict)
fluxon_rs/fluxon_kv/src/user_api/codec_flat_dict.rs:39
↓ 7 callersFunctionencode_owned_bytes
(bytes: Vec<u8>)
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1049
↓ 7 callersFunctionensure_parent_dirs
( st: &GatewayState, request_identity: FluxonFsRequestIdentity, export_name: Arc<str>, relpath
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:3908
↓ 7 callersMethodentry_and_relpath
( &self, fh: u64, )
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:949
↓ 7 callersMethodframework
(&self)
fluxon_rs/fluxon_kv/src/user_api/fluxon_backend.rs:41
↓ 7 callersMethodget
(&self, key: String, callback: Option<PyObject>, py: Python)
fluxon_rs/fluxon_pyo3/src/lib.rs:3151
↓ 7 callersFunctionget_current_git_commitid
()
fluxon_rs/fluxon_util/src/git_version_build_record.rs:1
↓ 7 callersMethodget_ready_channels
Thread-safe getter for ready channels. Returns: List[str]: Copy of ready channel IDs list
fluxon_py/_api_ext_chan/mpmc.py:809
↓ 7 callersMethodinner_map
(&self)
fluxon_rs/fluxon_kv/src/memholder/lifetime.rs:455
↓ 7 callersFunctionis_relpath_skipped
(skip_entries: &[FluxonFsTransferSkipEntryWire], relpath: &str)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:1976
↓ 7 callersFunctionis_relpath_skipped
( skip_entries: Iterable[FluxonFsTransferSkipEntry], relpath: str, )
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:473
↓ 7 callersMethodis_running
(&self)
fluxon_rs/fluxon_framework_compiled/src/shutdown.rs:20
↓ 7 callersMethodlist_dir
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5404
↓ 7 callersMethodlist_transfer_batch_collect_infos
( &self, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:539
↓ 7 callersFunctionload_case_config_payload
(path: str | Path, *, expected_scene_id: str)
fluxon_test_stack/top_attention_test_index/_common.py:91
↓ 7 callersFunctionload_test_fluxon_cluster_name
Load required Fluxon cluster name from test_config.yaml.
fluxon_py/tests/test_lib.py:81
↓ 7 callersMethodmerge_from
(&mut self, rhs: &Self)
fluxon_rs/fluxon_kv/src/client_kv_api/msg_pack.rs:29
↓ 7 callersFunctionobject_sig_string
(size: i64, mtime_ns: i64)
fluxon_rs/fluxon_fs_core/src/s3_gateway.rs:47
↓ 7 callersFunctionobserve_all_selection_statuses_for_snapshot
( snapshot: &SelectionSupervisorProcSnapshot, scope_key: Option<&str>, )
fluxon_rs/fluxon_ops/src/lib.rs:1884
↓ 7 callersFunctionp2p_module_call
( handle: ClosedRuntimeHandle, call: ClosedRuntimeP2pCall, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1698
↓ 7 callersMethodreached
(&self)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:84
↓ 7 callersMethodrecover_after_p2p_error
(&self, prev_owner_start_time: &mut i64)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:979
↓ 7 callersFunctionrefresh_closed_self_info_cache
( runtime: &ClosedClusterManagerRuntime, self_info: crate::ClusterMember, )
fluxon_rs/fluxon_commu/src/facade/cluster_manager.rs:641
↓ 7 callersMethodregister
(&self)
fluxon_rs/fluxon_kv/src/client_seg_pool/mod.rs:828
↓ 7 callersMethodremote_call_ok
( &self, export_name: &str, export: &FluxonFsExport, rpc_path: &str, p
fluxon_rs/fluxon_fs/src/agent.rs:6332
↓ 7 callersMethodremote_write_session_client_lookup
( &self, session_id: &str, )
fluxon_rs/fluxon_fs/src/agent.rs:1471
↓ 7 callersMethodrename
(&self, src_path: &str, dst_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:691
↓ 7 callersMethodrequest_shutdown
(self)
fluxon_py/_api_ext_chan/mpmc.py:1920
↓ 7 callersFunctionrequire_binary
(name: str)
scripts/_build_doc_site_in_container_inner.py:1952
↓ 7 callersFunctionresolve_readable_log_path
(base_path: &Path)
fluxon_rs/fluxon_util/src/log.rs:377
↓ 7 callersFunctionresp_empty
(status: StatusCode)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5246
↓ 7 callersFunctionresp_xml
(status: StatusCode, xml: String)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5236
↓ 7 callersFunctionretry_after_parent_dir_chmod
( repair_anchor: &Path, op: &str, target_path: &Path, mut attempt: F, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2097
↓ 7 callersMethodrun
(self, mut rx: tokio::sync::ampsc::Receiver<M::DeleteTask>)
fluxon_rs/fluxon_kv/src/memholder/ensure_memholder_mgmt_delete.rs:72
↓ 7 callersFunctionrun_etcd_op
( backend: AutoCleanMapEntry<Vec<String>, EtcdKvBackend>, context: String, mut op: F, )
fluxon_rs/fluxon_pyo3/src/etcd.rs:109
↓ 7 callersFunctionshould_warn
(now: Instant, last_warn: &mut Option<Instant>, cfg: WarnConfig)
fluxon_rs/fluxon_fs_core/src/retry.rs:26
↓ 7 callersFunctiontest_state_with_permission_list
( backend: Arc<dyn FsS3Backend>, buckets: &[&str], permission_list: Vec<FluxonFsS3Perm
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:6996
↓ 7 callersFunctiontransfer_scan_event_result_view
( event: &FluxonFsTransferScanEventWire, )
fluxon_rs/fluxon_fs/src/master_http/transfer_master.rs:806
↓ 7 callersMethodtruncate
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5488
↓ 7 callersMethodui_transfer_task_for_owner
( &self, task_id: &str, owner_username: &str, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:1543
↓ 7 callersFunctionui_transfer_task_snapshot_with_controls
( snapshot: &UiTransferTaskSnapshot, command: UiTransferTaskCommand, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2559
↓ 7 callersMethodvalidate_requester_owner_status_updated
(&self, started_time: i64)
fluxon_rs/fluxon_kv/src/client_kv_api/external_api.rs:322
↓ 6 callersFunction_backend_prepare_build_scenario
(*, selected_backend_plan: dict)
setup_and_pack/nix/pack_fluxonkv_pylib.py:708
↓ 6 callersFunction_best_effort_close
(obj: Any, *, role: str)
fluxon_py/tests/test_api_chan_mpmc/test_mpmc_simple_bench.py:1218
↓ 6 callersFunction_ci_case_instance_ids
(resolved_case: Dict[str, Any])
fluxon_test_stack/test_runner.py:2393
↓ 6 callersFunction_ci_runtime_cleanup_case
(resolved_case: Dict[str, Any], *, ctx: str)
fluxon_test_stack/test_runner.py:11478
↓ 6 callersFunction_copy_file_if_exists
(src: Path, dst: Path)
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:1351
↓ 6 callersFunction_decode_http_json
(data: bytes, *, ctx: str)
fluxon_test_stack/test_runner.py:10962
↓ 6 callersFunction_ensure_generated_dir
(path: Path)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1227
↓ 6 callersFunction_finalize_run_slot
( case_runs: Dict[str, Any], slot: _RunSlot, *, outcome: str, counted: bool, finished_
fluxon_test_stack/test_runner.py:7484
↓ 6 callersFunction_http_json
(req: urllib.request.Request)
fluxon_test_stack/test_profile_adapter.py:1242
↓ 6 callersFunction_http_json_allow_error_status_retry_until_deadline
( url: str, *, method: str, deadline: float, ctx: str, data: bytes | None = None,
fluxon_test_stack/start_test_bed.py:3752
↓ 6 callersFunction_http_open
(req: urllib.request.Request, *, timeout: int)
examples/fluxon_quick_start/start.py:194
↓ 6 callersFunction_is_process_running
(pid: int)
fluxon_py/runtime/process_runner.py:542
↓ 6 callersFunction_kv_http_error_response
(error: ApiError)
examples/fluxon_quick_start/start.py:385
↓ 6 callersFunction_load_benchmark_section
从 benchmark_config.py 中加载 CONFIG['benchmark']。
fluxon_test_stack/distributed_benchmark_coordinator.py:153
↓ 6 callersFunction_load_runs_index
(path: Path)
fluxon_test_stack/gitops/gitops_lib.py:788
↓ 6 callersFunction_local_ipv4_addresses
()
fluxon_test_stack/test_runner.py:10126
↓ 6 callersFunction_manifest
( *, name: str, logical_selection: str, service_name: str, atomic_group: str | None, )
deployment/tests/test_start_test_bed_deploy_payload.py:30
↓ 6 callersFunction_new_controller_request
( url: str, *, method: str, data: bytes | None = None, content_type: str | None = None, )
fluxon_test_stack/test_profile_adapter.py:1212
↓ 6 callersFunction_new_controller_request
( url: str, *, method: str, data: bytes | None = None, content_type: str | None = None, )
fluxon_test_stack/test_runner.py:11248
↓ 6 callersFunction_new_mpmc_meta_key
Get the meta key of the given MPMC channel id.
fluxon_py/_api_ext_chan/mpmc.py:403
↓ 6 callersFunction_optional_non_empty_string
(raw: dict, key: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:4033
↓ 6 callersFunction_print_fixture_progress
(detail: str)
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:167
↓ 6 callersFunction_prometheus_query_range
( *, base_url: str, promql: str, start_s: float, end_s: float, step: str, )
fluxon_test_stack/distributed_benchmark_node.py:778
↓ 6 callersFunction_record_run_index
(path: Path, run_id: str, patch: dict)
fluxon_test_stack/gitops/gitops_lib.py:793
↓ 6 callersFunction_remove_path
(path: Path)
fluxon_test_stack/pack_test_stack_rsc.py:1692
↓ 6 callersFunction_resolved_case_family
(resolved_case: Dict[str, Any])
fluxon_test_stack/test_runner.py:2385
↓ 6 callersFunction_run
(cmd: list[str], cwd: Path | None = None)
fluxon_test_stack/gitops/gitops_lib.py:600
↓ 6 callersFunction_run_argv
( argv: list[str], *, dry_run: bool, cwd: Path | None = None, env: dict[str, str] | None =
setup_and_pack/setup_dev_env.py:716
↓ 6 callersFunction_run_checked
(cmd: list[str], *, cwd: Path)
setup_and_pack/rather_no_git_submodule.py:163
↓ 6 callersFunction_run_ssh_transport_command
( *, argv: List[str], password: Optional[str], ctx: str, timeout_seconds: Optional[float],
fluxon_test_stack/test_runner.py:11181
↓ 6 callersFunction_selection_service_names_for_target_node
( *, deployconf: dict[str, Any], selection_name: str, node_name: str, )
fluxon_test_stack/start_test_bed.py:2981
↓ 6 callersFunction_set_service_port
(service_cfg: dict[str, Any], *, port: int)
fluxon_test_stack/start_test_bed.py:977
↓ 6 callersFunction_shell_quote
(s: str)
fluxon_test_stack/test_profile_adapter.py:168
↓ 6 callersFunction_sudo_copy_path
(*, source_path: Path, target_path: Path)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3022
↓ 6 callersFunction_sudo_prefix
()
setup_and_pack/setup_dev_env.py:748
↓ 6 callersFunction_test_stack_runtime_mooncake_wheel_path_opt
(*, run_dir: Path)
fluxon_test_stack/test_runner.py:12592
↓ 6 callersFunction_verify_host_port
Strictly validate host:port string and return (host, port).
setup_and_pack/utils/repo_config_utils.py:109
↓ 6 callersFunctionacquire_transient_write_path_guard
( active_write_paths: &ActiveWritePathsHandle, key: &str, op: &str, )
fluxon_rs/fluxon_fs/src/agent_service.rs:401
↓ 6 callersMethodaddr
Returns the addr of the allocation.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:55
↓ 6 callersMethodallocate
Allocates a block of memory of `size` bytes. Returns an RAII guard for the allocation.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:123
↓ 6 callersFunctionappend_agent_error
( errs_by_instance: &mut BTreeMap<String, Vec<String>>, instance_key: &str, err: String, )
fluxon_rs/fluxon_ops/src/lib.rs:10843
↓ 6 callersMethodas_query_str
(self)
fluxon_rs/fluxon_cli/src/config.rs:54
↓ 6 callersFunctionbuild_agent_results
( workloads_by_instance: &BTreeMap<String, Vec<WorkloadId>>, errs_by_instance: BTreeMap<String, Vec<St
fluxon_rs/fluxon_ops/src/lib.rs:10854
↓ 6 callersFunctionbuild_ext_error
( py: Python<'_>, class_name: &str, message: &str, fill: impl FnOnce(&Bound<'_, PyDict>), )
fluxon_rs/fluxon_pyo3/src/error.rs:17
↓ 6 callersFunctionbuild_known_dispositions_for_scan
Scan restart does not persist scan units. Instead, the master ships already durable committed coverage for the subtree so the source agent can suppres
fluxon_rs/fluxon_fs/src/master_http/transfer_master.rs:287
↓ 6 callersFunctionbuild_symlink_collect_infos
( entries: Vec<FluxonFsTransferSymlinkNoticeEntryWire>, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2190
↓ 6 callersFunctionbuild_transfer_scan_event
( assignment: &FluxonFsTransferScanAssignmentWire, event_seq_no: i64, event_kind: FluxonFsTransfer
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2528
↓ 6 callersFunctionc_static_string
( ptr: *const c_char, field: &'static str, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:939
↓ 6 callersMethodchown
(&self, callback_path: &str, uid: u32, gid: u32)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:773
↓ 6 callersMethodclone
(&self)
fluxon_rs/fluxon_util/src/lease_manager/lease_backend_handle.rs:45
↓ 6 callersMethodclone_view
(&self)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:289
↓ 6 callersMethodclose
(self)
fluxon_test_stack/benchmark_node_rpc.py:514
← previousnext →601–700 of 9,070, ranked by callers