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
↓ 46 callersMethodrun_async_from_sync
(&self, future: impl Future<Output = T>)
fluxon_rs/fluxon_util/src/run_async_from_sync.rs:176
↓ 45 callersMethodinner
(&self)
fluxon_rs/fluxon_kv/src/master_kv_router/mod.rs:549
↓ 45 callersFunctionnew_invalid_argument_error
(py: Python, message: &str)
fluxon_rs/fluxon_pyo3/src/lib.rs:1909
↓ 44 callersMethodflush
(&self, fh: u64)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:522
↓ 43 callersMethoddelete
(&self, key: &str)
fluxon_rs/fluxon_kv/src/client_kv_api/delete.rs:35
↓ 41 callersMethodcreate
( &self, callback_path: &str, flags: i32, mode: u32, )
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:456
↓ 41 callersFunctionresp_ok
(mut extra: FlatDict)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2843
↓ 40 callersFunction_flat_kv_err
(message: str)
fluxon_py/kvclient/nonzerocopy_encode.py:35
↓ 40 callersMethodspawn
(&self, name: N, fut: F)
fluxon_rs/fluxon_commu/src/facade/p2p.rs:161
↓ 39 callersMethodput
Convenience wrapper: put KV with optional lease_id NOTE: If `lease_id` is None, it MUST remain a pure non-lease put. We do NOT fallback to any default
fluxon_rs/fluxon_kv/src/client_kv_api/mod.rs:1858
↓ 39 callersFunctionsafe_join_root
(remote_root_dir_abs: &str, relpath: &str)
fluxon_rs/fluxon_fs/src/agent_service.rs:4854
↓ 38 callersMethodlist_transfer_batches
( &self, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:503
↓ 37 callersMethodget_chan_id
Get the channel id.
fluxon_py/_api_ext_chan/mpmc.py:2267
↓ 37 callersMethodsend_resp
(&self, resp: MsgPack<RESP>)
fluxon_rs/fluxon_commu/src/facade/p2p.rs:1016
↓ 36 callersMethod_send_json
(self, code: int, payload: Dict[str, Any])
fluxon_test_stack/test_runner.py:16321
↓ 36 callersMethod_send_json
(self, code: int, payload: dict)
fluxon_test_stack/gitops/gitops_lib.py:1769
↓ 35 callersFunction_require_str
(v: Any, ctx: str)
fluxon_test_stack/test_profile_adapter.py:1345
↓ 35 callersMethodchmod
(&self, callback_path: &str, mode: u32)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:763
↓ 35 callersFunctionnew_general_error
(py: Python, message: &str)
fluxon_rs/fluxon_pyo3/src/lib.rs:1905
↓ 35 callersFunctionrender_template
(template: &T)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_render_handlers.rs:39
↓ 35 callersFunctionresp_ok
(mut extra: FlatDict)
fluxon_rs/fluxon_fs/src/agent_service.rs:4900
↓ 35 callersFunctiontext_response
(status: StatusCode, body: String)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5278
↓ 35 callersMethodverify
Verify and validate the configuration, returning a processed Config
fluxon_rs/fluxon_kv/src/config.rs:891
↓ 34 callersFunction_write_yaml_file
(path: Path, obj: Any)
fluxon_test_stack/test_runner.py:1132
↓ 34 callersMethodapply_transfer_scan_result
( &self, result: &FluxonFsTransferScanResultWire, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:592
↓ 34 callersFunctionmooncake_format
(message: str, specific_info: str, retcode: int)
fluxon_py/api_error.py:1149
↓ 34 callersMethodput
Store a key-value pair with single or multiple data parts (non-blocking). Args: key: The key to store *value
fluxon_py/kvclient/mooncake.py:392
↓ 34 callersFunctionresp_err
(kind: FluxonFsRpcErrorKind, detail: String, errno: Option<i32>)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2848
↓ 32 callersMethodcall
( &self, node_id: &str, path: &str, payload: FlatDict, _timeout_ms: Op
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:116
↓ 32 callersMethodcall
( &self, node_id: &str, path: &str, payload: FlatDict, timeout_ms: Opt
fluxon_rs/fluxon_kv/src/user_api/rpc.rs:65
↓ 32 callersMethodget_export_cfg
(&self, export_name: &str)
fluxon_rs/fluxon_fs/src/agent.rs:1154
↓ 32 callersMethodinto_py_object
(self, py: Python)
fluxon_rs/fluxon_pyo3/src/lib.rs:2366
↓ 32 callersMethodregister
( &self, path: &str, handler: Arc<dyn Fn(String, FlatDict) -> FluxonRpcKvResult<FlatDi
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:139
↓ 32 callersMethodrpc_server
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:106
↓ 32 callersMethodtransfer_state_store_enabled
( &self, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:108
↓ 32 callersMethodwait
(&mut self)
fluxon_rs/fluxon_framework_compiled/src/shutdown.rs:77
↓ 31 callersMethodassign_transfer_batch_to_worker
( &self, job_id: &str, batch_id: &str, src_exporter_id: &str, worker_i
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:624
↓ 31 callersMethodcode
Back-compat convenience: map to unified numeric error code
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/msg_and_error.rs:435
↓ 31 callersMethodobserve_request_with_labels
---- legacy APIs kept as no-ops (call sites still exist) ----
fluxon_rs/fluxon_kv/src/metrics.rs:619
↓ 31 callersFunctionsetup_test_environment
(logger: Logger, print_config: bool = True)
fluxon_py/tests/test_lib.py:241
↓ 31 callersFunctiontest_transfer_worker_id
(job_id: &str, batch_id: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:7230
↓ 31 callersMethodtransfer_job_snapshot
( &self, job_id: &str, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:303
↓ 30 callersMethodbegin_transfer_scan_epoch
(&self, job_id: &str)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:607
↓ 29 callersMethodcreate_transfer_job
( &self, arg: FsTransferCreateJobArg, )
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:117
↓ 29 callersFunctionerrno_from_adapter_error
(err: FuseAdapterError)
fluxon_rs/fluxon_fs_fuse_draft/src/runtime_fuser.rs:1435
↓ 29 callersMethodto_json
Serialize underlying group error as JSON string
fluxon_rs/fluxon_kv/src/rpcresp_kvresult_convert/msg_and_error.rs:337
↓ 28 callersFunction_load_yaml_file
(path: Path)
fluxon_test_stack/test_runner.py:1111
↓ 28 callersMethod_send_html
(self, code: int, text: str)
fluxon_test_stack/test_runner.py:16329
↓ 28 callersFunctioninit_logger
(name: str = "fluxon")
fluxon_py/logging.py:67
↓ 28 callersFunctionms_cell_from_us
(v: Option<f64>)
fluxon_rs/fluxon_cli/src/web_renderer.rs:269
↓ 28 callersFunctionparse_step_id
(step_id: &str)
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:2911
↓ 28 callersMethodstat
(self, *, follow_symlinks: bool = True)
fluxon_py/fluxon_fs/patcher.py:581
↓ 28 callersFunctiontest_transfer_state
()
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:7031
↓ 27 callersMethodclient
(&self)
fluxon_rs/fluxon_pyo3/src/etcd.rs:57
↓ 27 callersMethodinner
Access inner external-only API. Safe to unwrap in external role.
fluxon_rs/fluxon_kv/src/external_client_api/mod.rs:340
↓ 27 callersMethodinner
Get the inner instance (panics if not initialized)
fluxon_rs/fluxon_kv/src/master_lease_manager/master_lease_manager.rs:71
↓ 27 callersMethodstatus
(&self)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr_types.rs:29
↓ 26 callersFunction_cross_process_ts_diff_us
( later_ts_us: Optional[float], earlier_ts_us: Optional[float], )
fluxon_test_stack/benchmark_node_rpc.py:638
↓ 26 callersFunction_cross_process_ts_diff_us
( later_ts_us: Optional[float], earlier_ts_us: Optional[float], )
fluxon_test_stack/benchmark_node_kv.py:506
↓ 26 callersMethod_mount_path
(self, rel: str)
fluxon_py/tests/test_fluxon_fs_remote_mount.py:156
↓ 26 callersFunction_sh_quote
(value: str)
deployment/gen_bare_deploy_bash.py:869
↓ 26 callersMethodall
()
fluxon_rs/fluxon_util/src/init_dag_compiler.rs:50
↓ 26 callersMethodfileno
(self)
fluxon_py/fluxon_fs/patcher.py:174
↓ 26 callersFunctionjson_response
(status: StatusCode, value: &T)
fluxon_rs/fluxon_fs_s3_gateway/src/lib.rs:5261
↓ 26 callersMethodok_response
( &self, rpc_path: &str, payload: FlatDict, op: &'static str, path_for
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:590
↓ 26 callersMethodproject
(&self, callback_path: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/path_projection.rs:42
↓ 26 callersFunctionsafe_join_root
(export_root_dir: &fs::File, relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2554
↓ 26 callersFunctionscan_etcd_prefix_paginated
( client: &mut Client, prefix: &str, mut on_kv: F, )
fluxon_rs/fluxon_commu_contract/src/cluster.rs:36
↓ 26 callersFunctionui_handler_error_from_s3_error
(op: &str, err: S3Error)
fluxon_rs/fluxon_fs_s3_gateway/src/ui_ssr.rs:487
↓ 25 callersMethodget_producer_id
(self)
fluxon_py/_api_ext_chan/mpmc.py:2264
↓ 25 callersMethodindex
(self)
fluxon_rs/fluxon_observability/src/kv_metrics_actor.rs:165
↓ 25 callersMethodinner
(&self)
fluxon_rs/fluxon_kv/src/memholder/lifetime.rs:431
↓ 25 callersMethodreconcile_transfer_scheduler_state
(&self, now_unix_ms: i64)
fluxon_rs/fluxon_fs_s3_gateway/src/transfer/state_api.rs:799
↓ 25 callersFunctionregister_fs_handler
( rpc_server: Arc<dyn UserRpcServer>, path: &str, state: Arc<FsExportMockState>, handler: fn(&
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:520
↓ 25 callersMethodrelease
(&self, fh: u64)
fluxon_rs/fluxon_fs_fuse_draft/src/adapter.rs:532
↓ 25 callersMethodrpc_client
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:102
↓ 24 callersMethodbase_relpath_payload
(&self, relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:612
↓ 24 callersFunctionconfigure_backend
( env: "ChannelState", *, backend_type: Optional[str] = None, backend_ip: Optional[str] = None
fluxon_py/tests/test_api_chan_mpsc/test_api_chan_mpsc_base.py:146
↓ 24 callersFunctionfmt_bytes_auto
(v: Option<f64>, per_sec: bool)
fluxon_rs/fluxon_cli/src/model.rs:352
↓ 24 callersMethodlock_key
(&self)
fluxon_rs/fluxon_fs_fuse_draft/src/path_projection.rs:20
↓ 24 callersFunctionnormalize_relpath
(relpath: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2063
↓ 24 callersFunctionnormalize_relpath_rpc
(relpath: &str)
fluxon_rs/fluxon_fs/src/agent.rs:6792
↓ 24 callersFunctionplugin_source
(name: str)
scripts/_build_doc_site_in_container_inner.py:1281
↓ 24 callersMethodregister_shutdown_poller
(&self)
fluxon_rs/fluxon_commu/src/facade/p2p.rs:140
↓ 24 callersMethodregister_shutdown_waiter
(&self)
fluxon_rs/fluxon_kv/src/client_transfer_engine/mod.rs:177
↓ 24 callersMethodseek
(self, offset: int, whence: int = io.SEEK_SET)
fluxon_py/fluxon_fs/patcher.py:189
↓ 23 callersFunction_html_escape
(v: str)
fluxon_test_stack/gitops/gitops_lib.py:899
↓ 23 callersFunction_load_start_test_bed_module
()
deployment/tests/test_start_test_bed_bootstrap_log.py:23
↓ 23 callersFunction_require_dict
(d: Any, ctx: str)
fluxon_test_stack/test_profile_adapter.py:1333
↓ 23 callersMethodavg_ns
(&self)
fluxon_rs/fluxon_mq/src/consumer.rs:622
↓ 23 callersFunctiondebug_print
(*args)
fluxon_py/config.py:21
↓ 23 callersFunctionimport_fluxon_pyo3_local
()
fluxon_py/tool/pyo3.py:88
↓ 23 callersFunctionrequire_export_name
(state: &FsExportMockState, export_name: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/fluxon_rpc_kv.rs:2052
↓ 23 callersFunctiontest_exports_handle
(root_dir_abs: &str)
fluxon_rs/fluxon_fs/src/agent_service/transfer_agent.rs:6036
↓ 22 callersFunction_load_runtime_module
()
deployment/tests/test_selection_supervisor_codegen.py:85
↓ 22 callersFunction_nix_string_literal
(value: str)
setup_and_pack/nix/pack_fluxonkv_pylib.py:3957
↓ 22 callersFunction_safe_int
(value: Any, *, default: int = 0)
fluxon_test_stack/test_runner.py:15324
↓ 22 callersMethodas_db_str
(self)
fluxon_rs/fluxon_fs_core/src/config.rs:584
↓ 22 callersFunctionclose_stores_or_log
Close a store list and keep every close failure visible.
fluxon_py/tests/test_backend.py:138
↓ 22 callersFunctionget_i64
(payload: &FlatDict, key: &str)
fluxon_rs/fluxon_fs_fuse_draft/src/backend.rs:1161
← previousnext →101–200 of 9,070, ranked by callers