Functions — github.com/SuanCaiYv/prim

hub / github.com/SuanCaiYv/prim / functions

Functions807 in github.com/SuanCaiYv/prim

⨍ Functions 807◇ Types & classes 467

↓ 126 callersMethodclone

(&self)

server/api/src/rpc/node_proto.rs:627

↓ 118 callersMethodclone

(&self)

server/message/src/rpc/node_proto.rs:1129

↓ 68 callersMethodclone

(&self)

server/scheduler/src/rpc/node_proto.rs:1129

↓ 61 callersFunctionconfig

()

server/message/src/config/mod.rs:333

↓ 56 callersMethodas_generic_parameter_map

(&self)

server/lib/src/net/mod.rs:190

↓ 56 callersMethodget

(&self, key: u32)

server/scheduler/src/service/mod.rs:97

↓ 56 callersMethodsend

(&self, msg: Arc<Msg>)

server/lib-net-tokio/src/net/mod.rs:410

↓ 55 callersMethodas_slice

(&self)

server/lib/src/entity/msg.rs:424

↓ 53 callersMethodget

(&self, key: &str)

ui-prototype/src-tauri/src/service/database.rs:359

↓ 46 callersMethodrecv

(&mut self)

server/message/src/service/handler/mod.rs:77

↓ 44 callersMethodget

(&self)

server/message/src/service/msglogger/mod.rs:35

↓ 44 callersMethodinto

(self)

server/lib/src/entity/msg.rs:45

↓ 43 callersMethodas_bytes

(&self)

server/lib/src/entity/msg.rs:419

↓ 43 callersMethodlog

(&mut self, msg: Arc<Msg>)

server/message/src/service/mod.rs:132

↓ 40 callersFunctionconfig

()

server/scheduler/src/config/mod.rs:259

↓ 38 callersMethodsend

(&self, msg: IOTaskMsg)

server/message/src/service/handler/mod.rs:68

↓ 37 callersMethodbuild

(self)

server/lib/src/net/server.rs:77

↓ 37 callersMethodinsert

(&self, id: u64, sender: MsgSender)

server/message/src/service/mod.rs:126

↓ 35 callersMethodset

(&mut self, key: &str, value: &T)

server/lib/src/cache/redis_ops.rs:34

↓ 34 callersMethodreceiver

(buf: &[u8])

server/lib/src/entity/msg.rs:180

↓ 33 callersFunctionmy_id

()

server/message/src/util/mod.rs:11

↓ 33 callersMethodpayload

(&self)

server/lib/src/entity/msg.rs:553

↓ 31 callersMethodput_parameter

(&mut self, parameter: T)

server/lib/src/net/mod.rs:42

↓ 30 callersMethodtyp

(buf: &[u8])

server/lib/src/entity/msg.rs:168

↓ 29 callersMethodsender

(buf: &[u8])

server/lib/src/entity/msg.rs:174

↓ 28 callersMethodget

(id: i64)

server/api/src/model/msg.rs:157

↓ 26 callersFunctionget_redis_ops

()

server/api/src/cache/mod.rs:8

↓ 26 callersMethodinsert

(&self, key: u32, value: ReqwestCaller)

server/scheduler/src/service/mod.rs:101

↓ 26 callersFunctiontimestamp

()

server/lib/src/util/mod.rs:8

↓ 25 callersMethodread

(&mut self, buf: &mut [u8])

server/lib/src/entity/msg.rs:128

↓ 25 callersFunctiontimestamp

()

ui-prototype/src/util/base.ts:4

↓ 25 callersFunctionverify_user

(req: &mut Request, redis_ops: &mut RedisOps)

server/api/src/handler/mod.rs:37

↓ 23 callersFunctionget_sql_pool

()

server/api/src/sql/mod.rs:20

↓ 23 callersFunctionpreparse

(obj: serde_json::Value)

ui-prototype/src-tauri/src/main.rs:536

↓ 23 callersMethodset_type

(buf: &mut [u8], typ: Type)

server/lib/src/entity/msg.rs:242

↓ 22 callersMethodas_str

(&self)

server/lib/src/net/mod.rs:100

↓ 22 callersMethodclose

(self)

server/lib-net-tokio/src/net/mod.rs:422

↓ 22 callersFunctionconfig

()

server/seqnum/src/config/mod.rs:207

↓ 22 callersMethodremove

(&self, key: &K)

server/lib/src/util/map.rs:30

↓ 21 callersMethodvalue

(&self)

server/lib/src/entity/msg.rs:99

↓ 20 callersMethodas_mut_slice

(&mut self)

server/lib/src/entity/msg.rs:429

↓ 19 callersMethodto_bytes

(&self)

server/lib/src/entity/server.rs:97

↓ 17 callersMethodresource_id

(&self)

server/lib/src/entity/msg.rs:1010

↓ 16 callersMethodseqnum

(&self)

server/lib/src/entity/msg.rs:474

↓ 16 callersMethodwith_cert

(&mut self, cert: rustls::Certificate)

server/lib/src/net/server.rs:52

↓ 16 callersMethodwith_max_bi_streams

(&mut self, max_bi_streams: usize)

server/lib/src/net/server.rs:72

↓ 15 callersMethodcall

(&self, mut req: ReqwestMsg)

server/lib-net-tokio/src/net/mod.rs:321

↓ 15 callersFunctionconfig

()

server/api/src/config/mod.rs:207

↓ 15 callersMethodget_mut

(&self, key: &K)

server/lib/src/util/map.rs:26

↓ 15 callersMethodinsert

(&self, key: K, value: V)

server/lib/src/util/map.rs:17

↓ 14 callersMethodcall

(&mut self, req: http::Request<B>)

server/scheduler/src/rpc/node_proto.rs:704

↓ 13 callersFunctionget_rpc_client

()

server/api/src/rpc/mod.rs:13

↓ 13 callersMethodinsert

(&self, addr: SocketAddr)

server/scheduler/src/cluster/mod.rs:53

↓ 13 callersMethodupdate

(&self)

server/api/src/model/msg.rs:132

↓ 13 callersMethodwrite

(self, _req: &mut Request, _depot: &mut Depot, resp: &mut Response)

server/api/src/error/mod.rs:18

↓ 12 callersMethodset

( &self, key: &str, value: &serde_json::Value, )

ui-prototype/src-tauri/src/service/database.rs:342

↓ 11 callersMethodas_mut_generic_parameter_map

(&mut self)

server/lib/src/net/mod.rs:197

↓ 11 callersMethodcall_push_msg

(&mut self, msg: &Msg)

server/api/src/rpc/node.rs:45

↓ 11 callersFunctionconnect

(remote: string, token: string, mode: string, userId: bigint, nodeId: number)

ui-prototype/src/App.tsx:591

↓ 11 callersMethoddelete

(&self)

server/api/src/model/msg.rs:148

↓ 11 callersMethodget

(&'a self, id: &u64)

server/message/src/service/mod.rs:122

↓ 11 callersMethodinsert

(&self)

server/api/src/model/msg.rs:117

↓ 11 callersMethodset

(&self, new_value: Result<()>)

server/message/src/service/msglogger/mod.rs:29

↓ 11 callersMethodset_seqnum

(&mut self, seq_num: u64)

server/lib/src/entity/msg.rs:519

↓ 11 callersMethodtimestamp

(buf: &[u8])

server/lib/src/entity/msg.rs:192

↓ 11 callersMethodwith_ipv4_type

(&mut self, ipv4_type: bool)

server/lib/src/net/client.rs:53

↓ 10 callersMethodgenerate_ack

(&self, node_id: u32, client_timestamp: u64)

server/lib/src/entity/msg.rs:716

↓ 10 callersMethodget

(&self, id: u32)

server/scheduler/src/cluster/mod.rs:85

↓ 10 callersMethodget

(&'a self, id: &u32)

server/message/src/cluster/mod.rs:34

↓ 10 callersMethodpush_sort_queue

( &mut self, key: &str, val: &T, score: f64, )

server/lib/src/cache/redis_ops.rs:86

↓ 10 callersMethodreq_id

(&self)

server/lib/src/entity/msg.rs:1002

↓ 10 callersMethodset

(&self, new_timeout: Instant)

server/lib-net-tokio/src/net/mod.rs:111

↓ 10 callersMethodwith_domain

(&mut self, domain: String)

server/lib/src/net/client.rs:58

↓ 10 callersMethodwith_keep_alive_interval

(&mut self, keep_alive_interval: Duration)

server/lib/src/net/client.rs:68

↓ 10 callersMethodwith_remote_address

(&mut self, remote_address: SocketAddr)

server/lib/src/net/client.rs:48

↓ 9 callersMethodas_num

(&self)

server/lib/src/net/mod.rs:82

↓ 9 callersMethodinsert

(&self, msg: Msg)

ui-prototype/src-tauri/src/service/database.rs:50

↓ 9 callersMethodremove

(&self, key: u32)

server/scheduler/src/service/mod.rs:105

↓ 9 callersFunctionstart

()

server/seqnum/src/service/mod.rs:43

↓ 8 callersMethodget

(&self)

server/lib-net-monoio/src/net/mod.rs:62

↓ 8 callersMethodget

(&self)

server/lib-net-tokio/src/net/mod.rs:196

↓ 8 callersFunctionis_group_msg

(user_id: u64)

server/message/src/service/handler/mod.rs:286

↓ 8 callersMethodnode_id

(buf: &[u8])

server/lib/src/entity/msg.rs:186

↓ 7 callersMethodconnect

(addrs: Vec<SocketAddr>, password_list: Option<Vec<String>>)

server/lib/src/cache/redis_ops.rs:16

↓ 7 callersMethodinto

(self)

server/api/src/model/msg.rs:55

↓ 7 callersMethodset_req_id

(&mut self, req_id: u64)

server/lib/src/entity/msg.rs:1006

↓ 7 callersMethodset_timestamp

(buf: &mut [u8], timestamp: u64)

server/lib/src/entity/msg.rs:267

↓ 6 callersFunctionalertComponentNormal

(cmt: any)

ui-prototype/src/components/portal/Portal.tsx:66

↓ 6 callersFunctionbuffer2Array

(buffer: ArrayBuffer)

ui-prototype/src/util/base.ts:13

↓ 6 callersMethodchannels

(&mut self)

server/lib-net-tokio/src/net/mod.rs:929

↓ 6 callersFunctionforward_only_user

( msg: &mut Arc<Msg>, inner_states: &mut InnerStates, )

server/message/src/service/handler/business.rs:19

↓ 6 callersFunctionfrom_bytes

(buf: &[u8])

server/seqnum/src/util/mod.rs:59

↓ 6 callersFunctionget_msg_ops

()

ui-prototype/src-tauri/src/service/mod.rs:13

↓ 6 callersFunctionget_redis_ops

()

server/message/src/cache/mod.rs:9

↓ 6 callersFunctionread_buffer

( recv_stream: &mut RecvStream, external_source: Option<&'a [u8]>, buffer: &mut [u8], )

server/lib-net-tokio/src/net/mod.rs:437

↓ 6 callersFunctionsaveUserMsgList

()

ui-prototype/src/App.tsx:651

↓ 6 callersMethodselect

( &self, user_id1: u64, user_id2: u64, seq_num: u64, )

ui-prototype/src-tauri/src/service/database.rs:135

↓ 6 callersMethodset

(&self, new_value: Result<ReqwestMsg>)

server/lib-net-monoio/src/net/mod.rs:56

↓ 6 callersMethodset_sender

(buf: &mut [u8], sender: u64)

server/lib/src/entity/msg.rs:218

↓ 6 callersFunctionstart

(id: usize)

server/msglogger/src/recv.rs:19

next →1–100 of 807, ranked by callers