基于 Rust Arrow Flight 的物联网和时序数据传输及转换工具 霍琳贺io/crates/utoipa • Metrics: https://crates.io/crates/metrics • Database: https://crates.io/crates/sqlx • RPC: https://crates.io/crates/arrow-flight https://crates.io/crates/tonic • Authentication: https://crates io/crates/dashmap Arrow • Schema with metadata • RecordBatch • IPC Stream Tonic + Arrow Flight • 以流为中心的 RPC 框架 Tokio - Future and .abort() • Future • JoinHandle::abort() Tokio - Cancel • Case 2: tokio::select0 码力 | 29 页 | 2.26 MB | 1 年前3
应用 waPC (rust) 做软件测试工具• Memcache • Time • Sleep • now websocket standin for wasm • 可用 Javascript 在游览器里面 模拟数据 • 发 RPC 请求 • 可以上传 proto 文档 • 可以验证数据 前段链接 Wasm Mock Server 随机 waPC 注册逻辑 Use wasm without fear 支持以 websocket0 码力 | 30 页 | 2.50 MB | 1 年前3
新一代分布式高性能图数据库的构建 - 沈游人LSM-Tree 容灾保障 ( BR ) 元数据层 事务管理 MVOCC 计算层 Cypher AST 优化器 图计算 内存加速引 擎 服务接口 HTTP/RPC Spark 连接器 Python UDF 执行器 索引管理 一致性存储 RAFT 分片管理 元数据 集群管理 用户权限 GNN 应用层 Atlas 图平台 Atlas0 码力 | 38 页 | 24.68 MB | 1 年前3
Working with Asynchrony Generically: A Tour of C++ Executorsto a compute resource (aka, scheduler) • A unit of lazy async work (aka, sender) • A completion handler (aka, receiver) • A small, initial set of generic async algorithms: • E.g., then, when_all, sync_wait ranges beg asynchronous range adaptors.102 Step 3: Model Ctrl-C as a sender103 struct ctrl_c_handler { struct pending { virtual void complete() = 0; virtual ~pending() {} }; static inline pending->complete(); } return TRUE; } ctrl_c_handler() { BOOL result = ::SetConsoleCtrlHandler(&consoleHandler,TRUE); assert(result); } ~ctrl_c_handler() { BOOL result = ::SetConsoleCtrlHa0 码力 | 121 页 | 7.73 MB | 6 月前3
共 4 条
- 1













