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
↓ 3,093 callersMethodclone
(&self)
fluxon_rs/fluxon_util/src/auto_clean_map.rs:205
↓ 2,780 callersMethodget
(self, key: str)
fluxon_test_stack/benchmark_node_kv.py:1742
↓ 1,968 callersMethodunwrap
Unwrap the success value. Note: - We intentionally mark the Result as consumed in both branches. In many tests and small-sc
fluxon_py/api_error.py:925
↓ 1,362 callersMethodas_str
(self)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:94
↓ 901 callersMethodget
Convenience wrapper: get KV
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1848
↓ 780 callersMethodjoin
(&self, child: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:1335
↓ 709 callersMethodclone
(&self)
fluxon_rs/fluxon_kv/src/metric_reporter/mod.rs:460
↓ 679 callersMethodas_ref
(&self)
fluxon_rs/fluxon_commu_closed_sdk_consumer/src/lib.rs:376
↓ 612 callersMethodpush
(&mut self, future: F)
fluxon_rs/fluxon_util/src/scoped_future_set.rs:29
↓ 554 callersMethodexists
(self)
deployment/tests/test_selection_supervisor_codegen.py:888
↓ 455 callersFunction_require_dict
(d: Any, ctx: str)
fluxon_test_stack/test_runner.py:3919
↓ 440 callersFunction_require_str
(v: Any, ctx: str)
fluxon_test_stack/test_runner.py:3931
↓ 427 callersMethodlen
(&self)
fluxon_rs/fluxon_framework/src/framework.rs:58
↓ 426 callersMethodmkdir
(&self, callback_path: &str, mode: u32)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:606
↓ 406 callersMethodis_empty
(&self)
fluxon_rs/fluxon_util/src/auto_clean_map.rs:153
↓ 401 callersMethodlock
(&self, key: &str, mode: PathLockMode)
fluxon_rs/fluxon_fs_fuse_draft/src/path_lock.rs:43
↓ 395 callersMethodis_empty
(&self)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:691
↓ 310 callersMethodpush
(&self, inbound: TransferRpcFastPathInbound)
fluxon_rs/fluxon_commu_contract/src/transfer_engine/surface.rs:589
↓ 278 callersMethodis_dir
(self, *, follow_symlinks: bool = True)
fluxon_py/fluxon_fs/patcher.py:578
↓ 269 callersMethodis_ok
Return True if this is an ok result (do not inspect payload).
fluxon_py/api_error.py:921
↓ 249 callersMethodget
Retrieve a value by key (non-blocking). Args: key: The key to retrieve Returns: Result[KvFuture, Ap
fluxon_py/kvclient/mooncake.py:537
↓ 247 callersMethodinsert
(&mut self, range: Range<u64>)
fluxon_rs/fluxon_util/src/vallocator/frame.rs:53
↓ 240 callersMethodunwrap_error
Unwrap the error value.
fluxon_py/api_error.py:947
↓ 238 callersMethodnew_error
Create an error result.
fluxon_py/api_error.py:896
↓ 227 callersMethodis_file
(self, *, follow_symlinks: bool = True)
fluxon_py/fluxon_fs/patcher.py:575
↓ 217 callersMethodget
(&self)
fluxon_rs/fluxon_fs/src/agent_service.rs:316
↓ 207 callersFunctionresp_err_kverr
(e: KvError)
fluxon_rs/fluxon_fs/src/agent_service.rs:4910
↓ 192 callersMethodread
(&self, fh: u64, size: u32, offset: i64)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:484
↓ 180 callersMethodis_empty
(&self)
fluxon_rs/fluxon_commu_contract/src/p2p/wire.rs:92
↓ 151 callersMethodp2p_module
(&self)
fluxon_rs/fluxon_commu/src/facade/p2p.rs:111
↓ 147 callersFunction_require_int
(v: Any, ctx: str, *, min_v: int, max_v: int | None = None)
fluxon_test_stack/test_runner.py:3977
↓ 147 callersMethodinsert
(&self, bucket: &str, key: &str, data: &[u8])
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5628
↓ 145 callersMethodwrite
(&self, fh: u64, data: &[u8], offset: i64)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:512
↓ 141 callersMethodinsert
(&self, guard: G)
fluxon_rs/fluxon_commu/src/facade/transfer_engine.rs:64
↓ 141 callersMethodpath
(&self)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:6473
↓ 132 callersMethodencode
(mut self)
fluxon_rs/fluxon_pyo3/src/flatdict_zerocopy.rs:174
↓ 125 callersMethodcluster_manager
添加测试方法
fluxon_rs/fluxon_kv/src/cluster_manager/cluster_manager_test.rs:57
↓ 122 callersMethodremove
Remove an existing key. Must only be called for keys that were inserted.
fluxon_rs/fluxon_kv/src/master_kv_router/count_prefix_index.rs:54
↓ 119 callersMethodinsert
(&self, session_id: String, entry: WriteSessionEntry, file: fs::File)
fluxon_rs/fluxon_fs/src/agent_service.rs:585
↓ 114 callersMethodok
(cls, value: Any = None)
fluxon_test_stack/benchmark_node_kv.py:391
↓ 112 callersMethodlen
(&self)
fluxon_rs/fluxon_commu_contract/src/p2p/wire.rs:88
↓ 111 callersMethodset
(key: &'static str, value: impl Into<String>)
fluxon_rs/fluxon_util/tests/log_mgmt.rs:17
↓ 105 callersFunctionsh_quote
(s: str)
deployment/manual_dispatch_release.py:1544
↓ 104 callersMethodupdate
Push a fresh timestamp for ``chan_id`` onto the queue.
fluxon_py/_api_ext_chan/utils/priority_queue.py:29
↓ 103 callersMethodas_ptr
(&self)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:227
↓ 103 callersMethodsend
(&self, url: &str, user_agent: &str, payload: Bytes)
fluxon_rs/fluxon_observability/src/prom_remote_write_orchestrator.rs:75
↓ 101 callersMethodnew_ok
Create an ok result.
fluxon_py/api_error.py:890
↓ 99 callersMethodas_str
(&self)
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:34
↓ 99 callersMethodto_vec
(&self)
fluxon_rs/fluxon_commu_contract/src/p2p/wire.rs:114
↓ 96 callersMethodopen
(&self, callback_path: &str, flags: i32)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:452
↓ 95 callersMethodget
(&self, bucket: &str, key: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5640
↓ 89 callersFunction_html_escape
(value: Any)
fluxon_test_stack/test_runner.py:15320
↓ 89 callersFunction_require_str
(value: Any, field_name: str)
fluxon_test_stack/start_test_bed.py:4171
↓ 88 callersFunction_require_list
(d: Any, ctx: str)
fluxon_test_stack/test_runner.py:3925
↓ 88 callersMethodsort
(&mut self)
fluxon_rs/fluxon_util/src/prom_remote_write.rs:55
↓ 88 callersMethodwait
(self)
fluxon_py/kvclient/fluxon.py:966
↓ 87 callersMethodrun
(mut self, shutdown: F)
fluxon_rs/fluxon_observability/src/metrics_actor.rs:47
↓ 86 callersFunctiontext_response
(status: StatusCode, body: String)
fluxon_rs/fluxon_cli/src/server.rs:145
↓ 84 callersMethodinto_kverror
(self)
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/msg_and_error.rs:744
↓ 84 callersMethodlen
(&self)
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:235
↓ 84 callersFunctionnew_err
(msg: str)
fluxon_py/config.py:1043
↓ 83 callersMethodnext
(&mut self)
fluxon_rs/fluxon_util/src/scoped_future_set.rs:36
↓ 82 callersMethodload
(&self, instance_key: &str)
fluxon_rs/fluxon_ops/src/lib.rs:1031
↓ 81 callersMethodinner
(&self)
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1511
↓ 75 callersMethodas_str
(self)
fluxon_rs/fluxon_cli/src/model.rs:23
↓ 74 callersFunction_shell_quote
(s: str)
fluxon_test_stack/test_runner.py:11397
↓ 73 callersMethodspawn
(&self, name: N, fut: F)
fluxon_rs/fluxon_kv/src/client_transfer_engine/mod.rs:169
↓ 72 callersFunctionresponse_json
(status: StatusCode, v: &T)
fluxon_rs/fluxon_ops/src/lib.rs:6580
↓ 70 callersMethodregist
(p2p: &P2pModule)
fluxon_rs/fluxon_kv/src/metric_reporter/mod.rs:472
↓ 70 callersMethodrelpath
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/path_projection.rs:16
↓ 69 callersFunctionui_href_with_as
(href: &str, as_user: Option<&str>)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:664
↓ 69 callersMethodunlink
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:649
↓ 66 callersFunction_forbid_unknown_keys
(d: Dict[str, Any], allowed: set[str], ctx: str)
fluxon_test_stack/test_runner.py:3993
↓ 65 callersMethodpush
(&mut self, value_ns: u128)
fluxon_rs/fluxon_mq/src/consumer.rs:606
↓ 65 callersFunctionspawn
(process_type: str, cmd: List[str], identifier: str)
fluxon_py/tests/test_api_chan_mpmc/test_rebind_client.py:701
↓ 63 callersMethodtake
(&self, session_id: &str)
fluxon_rs/fluxon_fs/src/agent_service.rs:600
↓ 62 callersMethodas_str
(&self)
fluxon_rs/fluxon_ops/src/lib.rs:175
↓ 60 callersFunctionrollback_with_error
(tx: &mut Transaction, err: String)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/tikv_store.rs:5434
↓ 59 callersFunctionwrite_file
(root: &TempDir, relpath: &str, data: &[u8])
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6050
↓ 58 callersMethodas_str
(self)
fluxon_rs/fluxon_observability/src/types.rs:10
↓ 58 callersMethodclone
(&self)
fluxon_rs/fluxon_util/src/lease_manager/lease_backend_uid.rs:108
↓ 57 callersFunctionresp_err_io
(err: std::io::Error)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2863
↓ 56 callersMethodpoll
轮询一次，检查是否有新数据或触发条件 这个方法不会循环，只执行一次轮询操作。 用户需要在外部循环中调用此方法。 # 返回值 - `PollResult::BatchReady(data)`: 批处理已触发，返回要处理的数据 - `PollResult::DataCollected`: 收集了新数
fluxon_rs/fluxon_util/src/merge_recent_async_notifies/mod.rs:68
↓ 55 callersFunctionpanel_invalid
(detail: impl Into<String>)
fluxon_rs/fluxon_fs_core/src/config.rs:2422
↓ 54 callersMethodpath
(&self)
fluxon_rs/fluxon_pyo3/src/lib.rs:4240
↓ 53 callersMethodclose
(self)
fluxon_py/tests/fluxon_fs_transfer_tikv_support.py:1064
↓ 53 callersMethodget_self_info
(&self)
fluxon_rs/fluxon_kv/src/client_transfer_engine/mod.rs:72
↓ 53 callersMethodpath_for_relpath
(&self, relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:229
↓ 53 callersFunctionq
( prom: &PromClient, warnings: &mut Vec<String>, label: &str, expr: &str,
fluxon_rs/fluxon_cli/src/prom.rs:492
↓ 52 callersMethoditerdir
(self)
deployment/tests/test_selection_supervisor_codegen.py:902
↓ 52 callersFunctionrequire_str
(payload: &FlatDict, key: &str)
fluxon_rs/fluxon_fs/src/agent_service.rs:4919
↓ 52 callersFunctionrequire_str
(payload: &FlatDict, key: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2868
↓ 50 callersMethodinto_json_response
(self)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_types.rs:54
↓ 50 callersMethodkind
(&self)
fluxon_rs/fluxon_util/src/lease_manager/lease_handle.rs:63
↓ 50 callersFunctionui_require_identity
( headers: &HeaderMap, st: &GatewayState, as_user: Option<String>, )
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr.rs:81
↓ 49 callersMethodget
(&self, key: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:157
↓ 49 callersMethodinsert
Insert a new key. Must only be called once per logical key.
fluxon_rs/fluxon_kv/src/master_kv_router/count_prefix_index.rs:36
↓ 49 callersFunctionresp_err_io
(e: std::io::Error)
fluxon_rs/fluxon_fs/src/agent_service.rs:4905
↓ 48 callersFunctionregister_collector
(registry: &Registry, collector: Box<dyn Collector>)
fluxon_rs/fluxon_observability/src/kv_metrics_actor.rs:1212
↓ 47 callersMethodgetattr
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:306
next →1–100 of 9,070, ranked by callers