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
↓ 6 callersMethodclose
(self)
fluxon_py/_api_ext_chan/mpsc.py:406
↓ 6 callersFunctioncollect_expected_batches
( src_root_dir: &TempDir, batch_ready_bytes: i64, skip_entries: &[LocalTransferSkipEnt
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:2181
↓ 6 callersMethodcpu_mem_read_guard
(&self)
fluxon_rs/fluxon_kv/src/client_seg_pool/mod.rs:711
↓ 6 callersFunctioncreate_dir_all_with_parent_dir_chmod_retry
(path: &Path)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2128
↓ 6 callersFunctiondecode_runtime_config_b64
(config_b64: str)
fluxon_py/runtime/process_runner.py:93
↓ 6 callersFunctiondelete_key
(tx: &mut Transaction, key: Vec<u8>, context: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5386
↓ 6 callersFunctiondrop_runtime_handle
( handle: ClosedRuntimeHandle, )
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:2303
↓ 6 callersFunctionencode_runtime_config_b64
(config: Mapping[str, Any])
fluxon_py/runtime/process_runner.py:88
↓ 6 callersFunctionfinalize_payload_result
( result: CorePayloadResult, stage: &Arc<AtomicU8>, done: &Arc<AtomicBool>, payload_begin: Ins
fluxon_rs/fluxon_pyo3/src/mpsc.rs:100
↓ 6 callersMethodflush
(self)
fluxon_py/tests/test_fluxon_fs_patcher.py:109
↓ 6 callersMethodfrom_bytes
(bytes: Bytes)
fluxon_rs/fluxon_commu_contract/src/p2p/wire.rs:51
↓ 6 callersFunctionfs_agent_io_err
(path_for_err: &str, detail: impl Into<String>)
fluxon_rs/fluxon_fs/src/agent.rs:1072
↓ 6 callersMethodget_chan_id
(self)
fluxon_py/_api_ext_chan/mpsc.py:526
↓ 6 callersMethodget_etcd_config
(self)
fluxon_py/kvclient/mooncake.py:830
↓ 6 callersMethodget_producer_id
(self)
fluxon_py/_api_ext_chan/mpsc.py:522
↓ 6 callersFunctionhost_callback_failure
(detail: impl ToString)
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:1136
↓ 6 callersFunctioninit_for_p2p_owner
Register RPC caller for owner/external clients (p2p owner)
fluxon_rs/fluxon_kv/src/metrics/client.rs:13
↓ 6 callersFunctioninject_auto_refresh_tool
(html: String)
fluxon_rs/fluxon_cli/src/server.rs:336
↓ 6 callersMethodinner_mut
(&mut self)
fluxon_rs/fluxon_pyo3/src/mpsc.rs:1809
↓ 6 callersFunctioninsert_typed_request_auth_payload
(payload: &mut FlatDict, fs_rpc_token: Option<String>)
fluxon_rs/fluxon_fs/src/agent_service.rs:3577
↓ 6 callersFunctioninvalid_arg
(detail: impl Into<String>)
fluxon_rs/fluxon_kv/src/user_api/codec_flat_dict.rs:11
↓ 6 callersMethodis_detached
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/file_entry.rs:50
↓ 6 callersMethodis_external_mode
(&self)
fluxon_rs/fluxon_kv/src/lib.rs:276
↓ 6 callersMethodjob_key
(&self, job_id: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5164
↓ 6 callersFunctionkv_piece_key
( export_cache_kv_key_prefix: &str, export_name: &str, relpath: &str, sig: &str, piece_ind
fluxon_rs/fluxon_fs_core/src/s3_gateway.rs:93
↓ 6 callersMethodlist_transfer_worker_attempt_records
( &self, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:532
↓ 6 callersMethodload_effective_fs_exports
( &self, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:962
↓ 6 callersFunctionload_test_config_mapping
Load fluxon_py test_config.yaml. Contract: - The test-layer config is separate from build_config_ext.yml. - If config_path is omitted, pr
setup_and_pack/utils/repo_config_utils.py:322
↓ 6 callersFunctionlog_keepalive_error_rate_limited
Helper: rate-limit a keepalive-related log for a given lease. - key 按 lease 维度聚合（`KEEPALIVE_ERROR_LOG_KEY_PREFIX + lease_id`）； - 具体 log 内容与级别由闭包内部的 `
fluxon_rs/fluxon_util/src/lease_manager/keepalive_actor.rs:49
↓ 6 callersFunctionmap_instance_count
( env: "ChannelState", etcd_client: etcd3.Etcd3Client, func: Callable[[int], int], )
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:1535
↓ 6 callersMethodmetadata_cache_invalidate_prefix_with_identity
( &self, identity: &FluxonFsRequestIdentity, export_name: &str, relpath_prefix
fluxon_rs/fluxon_fs/src/agent.rs:5250
↓ 6 callersFunctionminimal_cache_yaml
()
fluxon_rs/fluxon_fs_core/tests/test_config.rs:8
↓ 6 callersMethodmsg_id
(&self)
fluxon_rs/fluxon_commu_contract/src/p2p/rpc.rs:176
↓ 6 callersMethodnamespace_prefix
(&self, namespace: &[u8])
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5156
↓ 6 callersFunctionnew_backend_init_failed_error
( py: Python, message: &str, backend_name: Option<&str>, )
fluxon_rs/fluxon_pyo3/src/lib.rs:1913
↓ 6 callersFunctionnew_client_launch
创建测试用的Client配置
fluxon_rs/fluxon_kv/src/kv_test.rs:1069
↓ 6 callersFunctionnew_or_bind_with_unique_key
Use an etcd distributed lock to bind or create a channel. If chan_id mapped by unique_id exists, bind to that channel; otherwise create a
fluxon_py/api_ext_chan.py:58
↓ 6 callersMethodnormalized
(&self)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:1128
↓ 6 callersMethodpath_stat
(&self, file_abs: &str)
fluxon_rs/fluxon_fs/src/agent.rs:4069
↓ 6 callersFunctionprom_str_literal
(s: &str)
fluxon_rs/fluxon_cli/src/lib.rs:2370
↓ 6 callersMethodpush_kv
(&mut self, field: &Field, v: String)
fluxon_rs/fluxon_observability/src/greptime_otlp_tracing.rs:65
↓ 6 callersFunctionquery_range_max_mbps
( prom: &PromClient, warnings: &mut Vec<String>, label: &str, promql: &str,
fluxon_rs/fluxon_cli/src/lib.rs:2505
↓ 6 callersFunctionread_body_to_bytes_limited
(mut body: Body, max_bytes: u64)
fluxon_rs/fluxon_ops/src/lib.rs:13147
↓ 6 callersMethodread_chunk_cached
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5418
↓ 6 callersMethodread_lock
(self)
fluxon_py/kvclient/mooncake.py:67
↓ 6 callersFunctionread_prom_remote_write_url_from_build_config
Read required `prom_remote_write_url` from build_config_ext.yml. Mirrors setup_and_pack/utils/repo_config_utils.py:load_tsdb_remote_write_url behavior
fluxon_rs/fluxon_util/src/dev_config.rs:154
↓ 6 callersMethodreaddir
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:346
↓ 6 callersMethodrebuild_ready_selector
(&mut self)
fluxon_rs/fluxon_mq/src/consumer.rs:2647
↓ 6 callersMethodrefresh_ready_state_from_local
(&mut self, producer_id: &str)
fluxon_rs/fluxon_mq/src/consumer.rs:2619
↓ 6 callersFunctionregister_ctrlc_callback
( on_ctrlc: Callable[[str], None], *, thread_name: str, )
fluxon_py/runtime/process_runner.py:234
↓ 6 callersFunctionrelease
(env: ChannelState, *resources)
fluxon_py/tests/test_api_chan_mpmc/test_rebind_client.py:224
↓ 6 callersFunctionrun_cmd
(cmd: list[str], *, cwd: Path)
scripts/_build_doc_site_in_container_inner.py:1994
↓ 6 callersFunctionrun_pytest
( description: str, paths: Iterable[str], *, passthrough: Sequence[str] | None = None, )
fluxon_test_stack/top_attention_test_index/_common.py:42
↓ 6 callersMethodrun_runner
(self, *args: str)
fluxon_test_stack/tests/test_test_runner_top_attention_cli.py:17
↓ 6 callersFunctionrun_singleton_process
( *, config_path: Path, singleton_spec: RuntimeSingletonSpec, stop_timeout_seconds: int, s
fluxon_py/runtime/process_runner.py:140
↓ 6 callersFunctionruntime_access_model_allows_path
( model: &FluxonFsRuntimeAccessModel, username: &str, export_name: &str, relpath: &str, mo
fluxon_rs/fluxon_fs_core/src/config.rs:1955
↓ 6 callersFunctionsafe_abs_dirpath
(input: &str)
fluxon_rs/fluxon_fs_core/src/path.rs:45
↓ 6 callersFunctionsampled_debug_seq
(counter: &'static AtomicU64)
fluxon_rs/fluxon_kv/src/metrics.rs:655
↓ 6 callersMethodscoped_instance_key
(&self, instance_key: &str)
fluxon_rs/fluxon_kv/src/kv_test.rs:787
↓ 6 callersFunctionselection_supervisor_label_from_workload_name
( kind: WorkloadKind, workload_name: &str, )
fluxon_rs/fluxon_ops/src/lib.rs:187
↓ 6 callersFunctionselection_supervisor_proc_snapshot
()
fluxon_rs/fluxon_ops/src/lib.rs:1515
↓ 6 callersMethodshutdown
(&self)
fluxon_rs/fluxon_framework_compiled/src/shutdown.rs:31
↓ 6 callersMethodshutdown
Shutdown the master
fluxon_rs/fluxon_pyo3/src/lib.rs:3970
↓ 6 callersFunctionshutdown_framework_with_timeout
(label: &str, framework: &crate::Framework)
fluxon_rs/fluxon_kv/src/kv_test.rs:1557
↓ 6 callersFunctionspawn_named
(view: &LifecycleView, name: impl Into<String>, fut: F)
fluxon_rs/fluxon_mq/src/lifecycle.rs:17
↓ 6 callersFunctionspawn_on_runtime_handle
(rt_handle: &Handle, fut: F)
fluxon_rs/fluxon_fs/src/write_session_rpc.rs:33
↓ 6 callersMethodstat
(&self, relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:240
↓ 6 callersFunctiontake_client_metric
(samples: &[PromSample])
fluxon_rs/fluxon_cli/src/prom.rs:431
↓ 6 callersMethodtarget
( &self, kind: WorkloadKind, workload_name: &str, )
fluxon_rs/fluxon_ops/src/lib.rs:1205
↓ 6 callersFunctiontest_transfer_state_with_access_config
(access_config: GatewayAccessConfig)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:7038
↓ 6 callersFunctiontest_transfer_state_with_backend_and_access_config
( backend: Arc<dyn FsS3Backend>, access_config: GatewayAccessConfig, )
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:7045
↓ 6 callersMethodts_one
( &self, metric_name: &'static str, extra_labels: &[(&'static str, String)], v
fluxon_rs/fluxon_mq/src/nonblocking_monitor.rs:305
↓ 6 callersFunctionui_fs_master_page_response
( st: &GatewayState, identity: &UiIdentity, error_msg: Option<&str>, status: StatusCode, )
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:1506
↓ 6 callersFunctionui_transfer_task_detail
(done_bytes: i64, total_bytes: i64)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr.rs:541
↓ 6 callersFunctionui_validate_object_key
(raw: &str, label: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr.rs:130
↓ 6 callersMethoduninstall
(self)
fluxon_py/fluxon_fs/patcher.py:734
↓ 6 callersFunctionunix_time_parts_to_ns
(seconds: i64, nanos: i64)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2632
↓ 6 callersMethodunlink
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5516
↓ 6 callersFunctionuser_rpc_call
( fw: &crate::Framework, node_id: NodeID, path: String, payload: Vec<u8>, timeout_ms: u64,
fluxon_rs/fluxon_kv/src/user_rpc.rs:272
↓ 6 callersMethodwrite_chunk
( &self, _request_identity: FluxonFsRequestIdentity, _export_name: Arc<str
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5473
↓ 6 callersFunctionwrite_file
(root: &TempDir, relpath: &str, data: &[u8])
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:1803
↓ 6 callersFunctionwrite_history_record
(dir: &Path, rec: &DeployHistoryRecord)
fluxon_rs/fluxon_ops/src/lib.rs:12860
↓ 5 callersFunction_append_optional_path_arg
(command: list[str], flag: str, raw_path: Optional[Path])
fluxon_test_stack/pack_test_stack_rsc.py:610
↓ 5 callersFunction_backend_writable_native_dir_name
(*, selected_backend_plan: dict)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1455
↓ 5 callersFunction_best_effort_close_result
(obj, logger, role: str)
examples/start_mpmc_demo.py:34
↓ 5 callersFunction_build_result
( *, bootstrap_log_path: Path, launcher_rc: int, selection_name: str, bare_script_name: st
deployment/tests/test_start_test_bed_bootstrap_log.py:46
↓ 5 callersFunction_case_family_from_scene_item
(item: Dict[str, Any], ctx: str)
fluxon_test_stack/test_runner.py:2422
↓ 5 callersFunction_ci_base_runtime_service_port
(resolved_case: Dict[str, Any], *, service_id: str)
fluxon_test_stack/test_runner.py:3504
↓ 5 callersFunction_ci_base_runtime_service_target_ip
(resolved_case: Dict[str, Any], *, service_id: str)
fluxon_test_stack/test_runner.py:3495
↓ 5 callersFunction_ci_has_instance
(resolved_case: Dict[str, Any], *, instance_id: str)
fluxon_test_stack/test_runner.py:2401
↓ 5 callersFunction_consume_path
(path: Path)
fluxon_test_stack/test_runner.py:15518
↓ 5 callersFunction_dispatch_release_scope_spec
(dispatch_release_scope: str)
deployment/manual_dispatch_release.py:166
↓ 5 callersFunction_download_fluxon_ops_fs_s3_file
( *, resolved_case: Dict[str, Any], bucket: str, key: str, access_key: str, secret_key
fluxon_test_stack/test_runner.py:13340
↓ 5 callersFunction_drain_proc_outputs
( proc_outputs: dict[subprocess.Popen[str], list[str]], *, timeout_seconds: float, )
fluxon_py/tests/test_mq/test_example_ctrl_c_exit.py:706
↓ 5 callersFunction_ensure_list
(x: Any)
deployment/gen_docker_deploy_bash.py:390
↓ 5 callersFunction_forbid_unknown_keys
(d: Dict[str, Any], allowed: set[str], ctx: str)
fluxon_test_stack/test_profile_adapter.py:1392
↓ 5 callersMethod_generate_test_data
Generate test data of the requested size (KV mode only).
fluxon_test_stack/distributed_benchmark_node.py:2865
↓ 5 callersFunction_get_bytes_ptr_len
(b: bytes, keepalive: List[bytes])
fluxon_py/kvclient/fluxon.py:155
↓ 5 callersFunction_instance_read_text_if_present
( resolved_case: Dict[str, Any], *, instance_id: str, path: Path )
fluxon_test_stack/test_runner.py:14562
↓ 5 callersFunction_load_build_config
Load config from build_config_ext.yml (searching upwards). Behavior: - If `config_path` is provided, load it directly. - Otherwise search
setup_and_pack/utils/repo_config_utils.py:60
← previousnext →701–800 of 9,070, ranked by callers