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
↓ 5 callersFunction_load_module
(module_path: Path, module_name: str)
setup_and_pack/tests/test_vendor_runtime_layout.py:17
↓ 5 callersFunction_load_yaml_mapping
(path: Path, *, ctx: str)
fluxon_test_stack/ci_2_virt_node.py:164
↓ 5 callersFunction_ops_current_deployments
(controller_url: str)
fluxon_test_stack/test_runner.py:11540
↓ 5 callersFunction_optional_file_sha256
(path: Path)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3973
↓ 5 callersFunction_otlp_tag
(field_number: int, wire_type: int)
fluxon_test_stack/distributed_benchmark_node.py:422
↓ 5 callersFunction_read_text_or_empty
(path: Path)
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:1127
↓ 5 callersMethod_refresh_local_ready_state
Refresh local state by getting current data from etcd. This ensures we don't miss any events that happened before watch started.
fluxon_py/_api_ext_chan/mpmc.py:1697
↓ 5 callersFunction_remove_path
(path: Path)
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:361
↓ 5 callersFunction_render_nodes_bash
(*, name: str, nodes: List[str])
deployment/gen_bare_deploy_bash.py:842
↓ 5 callersFunction_replace_expected_substring
(*, value: str, old: str, new: str, ctx: str)
fluxon_test_stack/start_test_bed.py:990
↓ 5 callersFunction_replace_workspace_entry
(*, link_path: Path, target_path: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3047
↓ 5 callersFunction_require_ci_runtime_contract
(raw: Any, ctx: str)
fluxon_test_stack/test_runner.py:4852
↓ 5 callersFunction_require_list_of_str
(raw: Any, field_name: str)
deployment/utils/selection_runtime.py:136
↓ 5 callersFunction_require_number
(v: Any, ctx: str)
fluxon_test_stack/test_runner.py:17569
↓ 5 callersFunction_require_path_within_root
(*, path: Path, root: Path, ctx: str)
fluxon_test_stack/test_runner.py:1385
↓ 5 callersFunction_require_scene_subject
(raw: Any, ctx: str)
fluxon_test_stack/test_runner.py:4774
↓ 5 callersFunction_require_test_stack_backend_kind
(raw: Any, ctx: str)
fluxon_test_stack/test_runner.py:4791
↓ 5 callersFunction_required_native_dir_names
(*, selected_backend_plan: dict)
setup_and_pack/nix/pack_fluxonkv_pylib.py:1481
↓ 5 callersFunction_resolve_existing_dir_path
(raw_value: str, field_name: str)
setup_and_pack/nix/lib_layout.py:933
↓ 5 callersFunction_run_stop
(supervisor_path: Path, cwd: Path, *, label: str, require_apply_id: Optional[str] = None, missing_ok: bool = F
deployment/tests/test_selection_supervisor_codegen.py:310
↓ 5 callersMethod_send_command
(self, conn: _RedisConn, *parts: Union[str, bytes])
fluxon_test_stack/benchmark_node_kv.py:1589
↓ 5 callersFunction_test_bed_manifest_transport_ctx_opt
()
fluxon_test_stack/test_runner.py:1646
↓ 5 callersFunction_to_env_key
(x: str)
deployment/utils/placeholder_utils.py:79
↓ 5 callersFunction_ui_render_log_viewer_html
(*, title: str, back_href: str, bootstrap_query: Dict[str, str])
fluxon_test_stack/test_runner.py:16136
↓ 5 callersFunction_unique_existing_paths
(paths: list[Path])
setup_and_pack/nix/pack_fluxonkv_pylib.py:273
↓ 5 callersFunction_validate_non_negative_int
(name: str, value: int)
fluxon_py/tests/test_api_chan_mpmc/test_mpmc_simple_bench2.py:839
↓ 5 callersFunction_wait_for_process_alive
( proc: subprocess.Popen, *, label: str, seconds: int, log_path: Optional[Path] = None,
examples/fluxon_quick_start/start.py:850
↓ 5 callersFunction_weighted_mean
(values: List[Tuple[float, int]])
fluxon_test_stack/distributed_benchmark_coordinator.py:717
↓ 5 callersFunction_write_yaml
(path: Path, payload: dict[str, Any])
fluxon_test_stack/ci_2_virt_node.py:639
↓ 5 callersFunction_write_yaml
(path: Path, value: dict[str, Any])
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:1341
↓ 5 callersMethodabort
Abort the underlying task. After calling, the handle will not be enqueued on drop.
fluxon_rs/fluxon_framework_compiled/src/util.rs:183
↓ 5 callersMethodadd_frame
(&mut self, start: u64, end: u64)
fluxon_rs/fluxon_util/src/vallocator/frame.rs:28
↓ 5 callersFunctionadd_workload_for_instance
( workloads_by_instance: &mut BTreeMap<String, Vec<WorkloadId>>, instance_key: String, workload: W
fluxon_rs/fluxon_ops/src/lib.rs:10799
↓ 5 callersFunctionagent_registry_export_for_name_and_root_v1
( export_name: &str, remote_root_dir_abs: &str, )
fluxon_rs/fluxon_fs_core/src/config.rs:1567
↓ 5 callersFunctionappend_raw_query
(url: &mut String, raw_query: Option<&str>)
fluxon_rs/fluxon_ops/src/lib.rs:6702
↓ 5 callersMethodas_i64
(self)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:278
↓ 5 callersMethodbase_addr
Returns the base address of the underlying segment allocator. Direct access is safe: `Allocation` holds a strong `Arc` to allocator.
fluxon_rs/fluxon_kv/src/master_seg_manager/one_seg_allocator.rs:71
↓ 5 callersFunctionbasic_auth_headers
(username: &str, password: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:10103
↓ 5 callersMethodbatch_state_key
( &self, job_id: &str, state: FluxonFsTransferBatchState, batch_id: &str,
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5231
↓ 5 callersFunctionbool_flag_value
(value: bool)
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2525
↓ 5 callersFunctionbuild_format
(color)
fluxon_py/logging.py:8
↓ 5 callersMethodbuild_remote_write_session_call_ctx
( &self, export_name: &str, relpath: &str, request_identity: Option<&FluxonFsR
fluxon_rs/fluxon_fs/src/agent.rs:1441
↓ 5 callersFunctionbuild_runtime_node_deps_with_attach_views_v4_for_tag
( spec: &InitDagYaml, tag_bit: u8, )
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:2613
↓ 5 callersFunctioncalc_flat_dict_encoded_len
( ptrs: &[(u8, usize, u32, u64, u32, Option<u32>)], )
fluxon_rs/fluxon_kv/src/memholder/kvclient_encode.rs:154
↓ 5 callersMethodcall_with_transport_policy
( &self, p2p: &P2pModule, node_id: NodeID, req: MsgPack<R>,
fluxon_rs/fluxon_commu/src/facade/p2p.rs:1126
↓ 5 callersFunctionchan_bind
( api: KvClient, chan_config: Dict[str, int], chan_id: str, chan_type: ChanType, chan_role
fluxon_py/api_ext_chan.py:642
↓ 5 callersFunctioncleanup_fsagent_mount_dir
( layout: &ManagedPathLayout, source_name: &str, )
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2613
↓ 5 callersFunctionclear_channels
(env: "ChannelState")
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:692
↓ 5 callersFunctioncontroller_list_agent_instance_keys
(fw: &Framework)
fluxon_rs/fluxon_ops/src/lib.rs:9791
↓ 5 callersFunctioncopytree_replace
(src: Path, dst: Path)
setup_and_pack/pub_prepare_build.py:434
↓ 5 callersFunctioncreate_wheel
(wheel_path: str, source_dir: str)
setup_and_pack/utils/wheel_runtime_helper.py:56
↓ 5 callersFunctioncurrent_log_file_path
()
fluxon_rs/fluxon_util/src/log.rs:592
↓ 5 callersMethoddelete_generation
( &self, kind: WorkloadKind, name: &str, authority: &str, require_appl
fluxon_rs/fluxon_ops/src/lib.rs:2716
↓ 5 callersFunctiondirect_files_only_disposition_covers_root
( assignment: &FluxonFsTransferScanAssignmentWire, root_relpath: &str, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:4264
↓ 5 callersMethodemit
(self, event: str, payload: dict)
fluxon_test_stack/gitops/gitops_lib.py:515
↓ 5 callersFunctionendpoint_health
(endpoint: &str, timeout: Duration)
fluxon_rs/fluxon_util/src/test_util.rs:97
↓ 5 callersMethodenqueue_child_units
(&mut self, child_scan_units: Vec<FluxonFsTransferScanChildUnitWire>)
fluxon_rs/fluxon_fs/src/master_http/transfer_master.rs:277
↓ 5 callersFunctionensure_fluxon_fs_external_client
(client: &KvClient)
fluxon_rs/fluxon_pyo3/src/lib.rs:827
↓ 5 callersMethodensure_owner_ready
(&self, prev_owner_start_time: &mut i64)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:917
↓ 5 callersMethodensure_path
(&mut self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:98
↓ 5 callersMethodexport_nodes_get_or_refresh
(&self, export_name: &str)
fluxon_rs/fluxon_fs/src/agent.rs:1210
↓ 5 callersFunctionextract_test_requirements
(path: Path)
fluxon_test_stack/top_attention_test_index/requirements_all.py:57
↓ 5 callersFunctionfail_fast_on_subprocess_error
(*, process_type_filter: Optional[str] = None)
fluxon_py/tests/test_api_chan_mpmc/test_api_chan_mpmc_base.py:725
↓ 5 callersFunctionfd_view_path
(file: &fs::File)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2092
↓ 5 callersFunctionfind_account_by_username
(st: &GatewayState, username: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:2801
↓ 5 callersMethodflush
(&mut self)
fluxon_rs/fluxon_fs_fuse_draft/src/file_stream.rs:265
↓ 5 callersMethodformat
(self, record)
fluxon_py/logging.py:42
↓ 5 callersMethodget
( self, key: str, )
fluxon_py/kvclient/fluxon.py:394
↓ 5 callersMethodget_holding_len
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1075
↓ 5 callersFunctiongrant_short_lease_for_test
(master_fw: &crate::Framework, ttl_seconds: u64)
fluxon_rs/fluxon_kv/src/master_lease_manager/lease_manager_test.rs:9
↓ 5 callersFunctionhmac_sha256
(key: &[u8], msg: &[u8])
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5204
↓ 5 callersMethodholder_id
(&self)
fluxon_rs/fluxon_kv/src/memholder/mod.rs:83
↓ 5 callersFunctionhost_sudo_prefix
Choose whether to use sudo for host filesystem commands. Causal chain: - containerized build steps can write root-owned artifacts into host b
setup_and_pack/utils/sudo_prefix_utils.py:64
↓ 5 callersFunctionhtml_escape_text
(s: &str)
fluxon_rs/fluxon_util/src/dag_viz_html.rs:2940
↓ 5 callersMethodinsert
(&self, key: Self::Key, value: Self::Value)
fluxon_rs/fluxon_kv/src/memholder/lifetime.rs:392
↓ 5 callersMethodinstance_key
Get the unique instance key for this store instance. Returns: Result[str, ApiError]
fluxon_py/kvclient/mooncake.py:741
↓ 5 callersFunctionio_error_is_permission_denied
(err: &std::io::Error)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:2423
↓ 5 callersMethodis_external_like
(self)
fluxon_rs/fluxon_cli/src/model.rs:439
↓ 5 callersFunctioniter_index_entry_paths
()
fluxon_test_stack/top_attention_test_index/requirements_all.py:49
↓ 5 callersFunctionkv_metric_meta
(spec: KvMetricSpec)
fluxon_rs/fluxon_cli/src/server.rs:633
↓ 5 callersMethodlease_id
(&self)
fluxon_rs/fluxon_util/src/lease_manager/keepalive_actor.rs:268
↓ 5 callersMethodlist_fs_export_registry_records
(&self)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:1376
↓ 5 callersFunctionload_deployconf_resolved_global_envs
Resolve deployconf global_envs with deployment placeholder rules.
deployment/utils/deployconf_config_utils.py:92
↓ 5 callersFunctionload_test_fluxon_share_mem_path
Load required Fluxon shared-memory path from test_config.yaml.
fluxon_py/tests/test_lib.py:86
↓ 5 callersFunctionload_tsdb_base_url
Read TSDB base query URL from build_config_ext.yml, validate scheme/port/path. Name aligned with setup_and_pack/utils/repo_config_utils.py: load_tsdb_
fluxon_rs/fluxon_util/src/dev_config.rs:171
↓ 5 callersFunctionlocal_check_arg_with_store
( src_root_dir: &TempDir, transfer_state_store: FluxonFsTransferStateStoreConfig, batc
fluxon_rs/fluxon_fs/src/local_transfer_checker.rs:1840
↓ 5 callersMethodlocal_segment_transfer_enabled
(&self)
fluxon_rs/fluxon_kv/src/client_transfer_engine/mod.rs:52
↓ 5 callersFunctionlog_transfer_worker_cleanup_failure
( phase: &str, assignment: &FluxonFsTransferWorkerAssignmentWire, resp: &FlatDict, )
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:5807
↓ 5 callersMethodnew
(base_url: String)
fluxon_rs/fluxon_cli/src/prom.rs:50
↓ 5 callersFunctionnew_external_client_launch
创建测试用的ExternalClient配置 external 与 owner 的 instance_key 必须不同；仅共享 owner 的 share_mem_path
fluxon_rs/fluxon_kv/src/kv_test.rs:1087
↓ 5 callersFunctionnew_fs_framework
Construct a fully initialized FS framework within the current Tokio runtime. This must be called from within a Tokio runtime context because the unde
fluxon_rs/fluxon_fs/src/framework.rs:50
↓ 5 callersMethodnext_states
(&self)
fluxon_rs/fluxon_ops/src/lib.rs:13721
↓ 5 callersFunctionnormalize_child_relpath
(parent: &str, child_name: &str)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:1956
↓ 5 callersFunctionnormalize_relpath_rpc
(relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:1296
↓ 5 callersFunctionnormalize_scope_relpath
(relpath: &str)
fluxon_rs/fluxon_fs_core/src/config.rs:2207
↓ 5 callersFunctionnormalize_transfer_root_relpath
(raw: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/db.rs:6
↓ 5 callersFunctionopen_at
( export_root_dir: &fs::File, relpath: &str, flags: i32, mode: Option<libc::mode_t>, )
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2125
↓ 5 callersFunctionoverlap_interval_ns
( stage_begin_at: Instant, stage_end_at: Instant, segment_begin_at: Instant, segment_end_at: I
fluxon_rs/fluxon_mq/src/consumer.rs:564
↓ 5 callersFunctionparse_bool_flag
( args: &mut impl Iterator<Item = String>, expected_flag: &str, mode_name: &str, )
fluxon_rs/fluxon_fs_fuse_draft/src/bin/fluxon_fs_fuse_draft_xfstests.rs:2400
↓ 5 callersFunctionparse_k8s_deployment_subset_documents
(doc: &str)
fluxon_rs/fluxon_ops/src/lib.rs:13573
← previousnext →801–900 of 9,070, ranked by callers