MCPcopy Create free account

hub / github.com/SuanCaiYv/prim / functions

Functions807 in github.com/SuanCaiYv/prim

⨍ Functions 807◇ Types & classes 467
↓ 6 callersFunctionwho_we_are
(id1: u64, id2: u64)
server/lib/src/util/mod.rs:19
↓ 6 callersMethodwith_address
(&mut self, address: SocketAddr)
server/lib/src/net/server.rs:47
↓ 6 callersMethodwith_connection_idle_timeout
(&mut self, connection_idle_timeout: u64)
server/lib/src/net/server.rs:67
↓ 6 callersMethodwith_key
(&mut self, key: rustls::PrivateKey)
server/lib/src/net/server.rs:57
↓ 6 callersMethodwith_max_connections
(&mut self, max_connections: usize)
server/lib/src/net/server.rs:62
↓ 5 callersMethodbody_mut
used for read from network
server/lib/src/entity/msg.rs:1030
↓ 5 callersFunctionconf
()
ui-prototype/src-tauri/src/config/mod.rs:99
↓ 5 callersMethoddelete
(&self, user_id1: u64, user_id2: u64, seq_num: u64)
ui-prototype/src-tauri/src/service/database.rs:206
↓ 5 callersMethodget
(&self, key: &K)
server/lib/src/util/map.rs:22
↓ 5 callersFunctionget_client_connection_map
()
server/message/src/service/mod.rs:68
↓ 5 callersFunctionget_cluster_connection_map
()
server/message/src/cluster/mod.rs:43
↓ 5 callersFunctionget_io_task_sender
()
server/message/src/service/mod.rs:93
↓ 5 callersFunctionget_rpc_client
()
server/message/src/rpc/mod.rs:25
↓ 5 callersMethodhandle
( &mut self, msg_streams: (SendStream, RecvStream), client_cal
server/lib-net-tokio/src/net/server.rs:377
↓ 5 callersMethodinsert
(&self, key: u128, value: AtomicU64)
server/seqnum/src/service/mod.rs:33
↓ 5 callersMethodpayload_length
(buf: &[u8])
server/lib/src/entity/msg.rs:162
↓ 5 callersFunctionpre_check
(msg: &[u8])
server/lib-net-tokio/src/net/mod.rs:375
↓ 5 callersMethodrun
()
server/scheduler/src/service/server.rs:154
↓ 5 callersMethodset_receiver
(buf: &mut [u8], receiver: u64)
server/lib/src/entity/msg.rs:226
↓ 5 callersMethodtoArrayBuffer
()
ui-prototype/src/entity/msg.ts:122
↓ 4 callersMethodas_large_num_map
(&self)
server/lib/src/net/mod.rs:172
↓ 4 callersMethodcall
(&self, msg: Arc<Msg>)
server/message/src/service/msglogger/mod.rs:100
↓ 4 callersFunctionclient
()
ui-prototype/src-tauri/src/service/http.rs:22
↓ 4 callersFunctioncrushed_log
(list: Vec<Arc<Msg>>, node_id: u32)
server/lib-net-tokio/src/net/mod.rs:360
↓ 4 callersFunctiondealResp
(resp: any | string)
ui-prototype/src/net/http.ts:106
↓ 4 callersMethodextension_length
(buf: &[u8])
server/lib/src/entity/msg.rs:156
↓ 4 callersFunctionget_message_node_set
()
server/scheduler/src/service/mod.rs:34
↓ 4 callersFunctionget_server_info_map
()
server/scheduler/src/service/mod.rs:30
↓ 4 callersMethodinsert
(&self, id: u32, sender: MsgSender)
server/message/src/cluster/mod.rs:38
↓ 4 callersMethodlua1
( &mut self, script: &str, argument1: Arg1, argument2: Arg2, )
server/lib/src/cache/redis_ops.rs:296
↓ 4 callersFunctionnewMsg
(msg: Msg)
ui-prototype/src/App.tsx:413
↓ 4 callersMethodpoll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
server/lib-net-tokio/src/lib.rs:62
↓ 4 callersMethodrender
(self, res: &mut Response)
server/api/src/handler/mod.rs:32
↓ 4 callersMethodrun
()
server/api/src/rpc/node.rs:78
↓ 4 callersMethodset_version
(buf: &mut [u8], version: u32)
server/lib/src/entity/msg.rs:210
↓ 4 callersMethodversion
(buf: &[u8])
server/lib/src/entity/msg.rs:204
↓ 3 callersFunctionalertMin
(message: string)
ui-prototype/src/components/portal/Portal.tsx:49
↓ 3 callersFunctionget_client_caller_map
()
server/scheduler/src/service/mod.rs:26
↓ 3 callersFunctionget_cluster_caller_map
()
server/scheduler/src/cluster/mod.rs:23
↓ 3 callersFunctionget_kv_ops
()
ui-prototype/src-tauri/src/service/mod.rs:23
↓ 3 callersFunctionget_redis_ops
()
server/scheduler/src/cache/mod.rs:10
↓ 3 callersFunctionget_redis_ops
()
server/msgprocessor/src/cache/mod.rs:9
↓ 3 callersFunctionget_seqnum_client_holder
()
server/message/src/service/mod.rs:76
↓ 3 callersFunctionget_seqnum_client_map
()
server/message/src/service/mod.rs:72
↓ 3 callersFunctionget_seqnum_node_set
()
server/scheduler/src/service/mod.rs:38
↓ 3 callersFunctionmy_id
()
server/scheduler/src/util/mod.rs:11
↓ 3 callersFunctionpushMsgMap
(msg: Msg)
ui-prototype/src/App.tsx:121
↓ 3 callersFunctionpush_group_msg
forward: true if the message need to broadcast to all nodes(imply it comes from client), false if the message comes from other nodes.
server/message/src/service/handler/mod.rs:350
↓ 3 callersMethodrender
()
ui-prototype/src/components/more/More.tsx:13
↓ 3 callersFunctionstart
()
server/scheduler/src/rpc/mod.rs:22
↓ 3 callersFunctionstart
()
server/message/src/service/mod.rs:202
↓ 3 callersMethodupdate
(&self, msg: Msg)
ui-prototype/src-tauri/src/service/database.rs:64
↓ 2 callersMethodAsBytes
()
server/golang/lib-go/entity/msg/msg.go:161
↓ 2 callersMethodall_group_node_list
( &mut self, request: impl tonic::IntoRequest<super::AllGroupNodeListReq>, )
server/message/src/rpc/node_proto.rs:277
↓ 2 callersFunctionas_bytes
(key: u128, seqnum: u64, buf: &mut [u8])
server/seqnum/src/util/mod.rs:54
↓ 2 callersMethodas_mut_body
(&mut self)
server/lib/src/entity/msg.rs:434
↓ 2 callersMethodas_mut_large_num_map
(&mut self)
server/lib/src/net/mod.rs:179
↓ 2 callersMethodas_num_list_map
(&self)
server/lib/src/net/mod.rs:154
↓ 2 callersFunctioncall_handler_list
( sender: &MsgSender, msg: &mut Arc<Msg>, handler_list: &HandlerList, states: &mut InnerStates
server/message/src/service/handler/mod.rs:209
↓ 2 callersMethodcall_seqnum_node_address
(&mut self, node_id: u32)
server/message/src/rpc/node.rs:88
↓ 2 callersMethodcall_seqnum_node_user_select
(&mut self, key: u128)
server/message/src/rpc/node.rs:79
↓ 2 callersMethodconnect
Attempt to create a new client by connecting to a given endpoint.
server/message/src/rpc/node_proto.rs:154
↓ 2 callersFunctionconnect2scheduler
( client_config: ClientConfig, timeout: Duration, handler_map: ReqwestHandlerMap, self_info: S
server/common/src/scheduler/mod.rs:17
↓ 2 callersMethodcurr_node_group_id_user_list
( &mut self, request: impl tonic::IntoRequest<super::CurrNodeGroupIdUserListReq>,
server/message/src/rpc/node_proto.rs:228
↓ 2 callersMethoddel
(&self, key: &str)
ui-prototype/src-tauri/src/service/database.rs:366
↓ 2 callersMethoddel
(&mut self, key: &str)
server/lib/src/cache/redis_ops.rs:75
↓ 2 callersMethodextension
(&self)
server/lib/src/entity/msg.rs:529
↓ 2 callersMethodfind_list
( &self, user_id1: u64, user_id2: u64, seq_num_from: u64, seq_num_to:
ui-prototype/src-tauri/src/service/database.rs:170
↓ 2 callersFunctionget
( host: &str, uri: &str, query: &serde_json::Map<String, serde_json::Value>, headers: &serde_j
ui-prototype/src-tauri/src/service/http.rs:31
↓ 2 callersFunctiongetPeerId
(id1: bigint, id2: bigint)
ui-prototype/src/App.tsx:38
↓ 2 callersFunctionget_mq_producer
()
server/message/src/service/mod.rs:89
↓ 2 callersFunctionget_msglogger_client
()
server/message/src/service/mod.rs:80
↓ 2 callersFunctionget_seqnum_map
()
server/seqnum/src/service/mod.rs:18
↓ 2 callersMethodgroup_user_list
( &mut self, request: impl tonic::IntoRequest<super::GroupUserListReq>, )
server/scheduler/src/rpc/node_proto.rs:536
↓ 2 callersMethodhandle
( &mut self, msg_streams: (SendStream, RecvStream), _: Option<
server/lib-net-tokio/src/net/client.rs:671
↓ 2 callersFunctionhandler_func
``` ------------------------- | | | quic stream established | | | ------------------------- | | \ /
server/message/src/service/handler/mod.rs:136
↓ 2 callersFunctionhandler_func
( sender: MsgSender, mut receiver: MsgMpscReceiver, io_task_sender: &IOTaskSender, handler_lis
server/message/src/cluster/handler/mod.rs:28
↓ 2 callersMethodio_channel_token
( &mut self, sender: u64, receiver: u64, node_id: u32, token: &str,
server/lib-net-tokio/src/net/client.rs:146
↓ 2 callersMethodlatest_seq_num
(&self, user_id1: u64, user_id2: u64)
ui-prototype/src-tauri/src/service/database.rs:232
↓ 2 callersFunctionloadNewMsg
(msg: Msg)
ui-prototype/src/App.tsx:419
↓ 2 callersMethodnew_net_streams
( &mut self, // every new stream needed to be authenticated. auth_msg: Arc<Msg>, )
server/lib-net-tokio/src/net/client.rs:98
↓ 2 callersFunctiononClick
(userId: bigint)
ui-prototype/src/components/chat/ChatInfo.tsx:87
↓ 2 callersFunctionoperationResult
(succeed: boolean)
ui-prototype/src/components/portal/Portal.tsx:85
↓ 2 callersMethodpeek_sort_queue_more
( &mut self, key: &str, offset: usize, size: usize, from: f64,
server/lib/src/cache/redis_ops.rs:120
↓ 2 callersFunctionpushUserMsgList
(msg: Msg)
ui-prototype/src/App.tsx:63
↓ 2 callersMethodpush_msg
( &mut self, request: impl tonic::IntoRequest<super::PushMsgReq>, )
server/api/src/rpc/node_proto.rs:183
↓ 2 callersMethodremove_sort_queue_data
(&mut self, key: &str, score: f64)
server/lib/src/cache/redis_ops.rs:238
↓ 2 callersMethodrun
(&self, msg: &mut ReqwestMsg, _states: &mut InnerStates)
server/mock/src/main.rs:28
↓ 2 callersMethodrun
(&self, msg: &mut Arc<Msg>, inner_states: &mut InnerStates)
server/message/src/service/handler/logic.rs:37
↓ 2 callersFunctionsalt
(length: usize)
server/lib/src/util/mod.rs:29
↓ 2 callersMethodsave
(&self, key: u128, seqnum: u64)
server/seqnum/src/service/handler/seqnum.rs:76
↓ 2 callersFunctionsaveMsg
(msg: Msg)
ui-prototype/src/App.tsx:640
↓ 2 callersMethodseqnum_all_node
( &mut self, request: impl tonic::IntoRequest<super::SeqnumAllNodeReq>, )
server/message/src/rpc/node_proto.rs:399
↓ 2 callersMethodseqnum_node_address
( &mut self, request: impl tonic::IntoRequest<super::SeqnumNodeAddressReq>, )
server/message/src/rpc/node_proto.rs:349
↓ 2 callersMethodseqnum_node_user_select
( &mut self, request: impl tonic::IntoRequest<super::SeqnumNodeUserSelectReq>,
server/message/src/rpc/node_proto.rs:374
↓ 2 callersFunctionsetShowFalse
()
ui-prototype/src/components/chat/RightOperator.tsx:59
↓ 2 callersMethodset_body
(&mut self, body: &[u8])
server/lib/src/entity/msg.rs:1034
↓ 2 callersMethodset_exp
( &mut self, key: &str, value: &T, exp: std::time::Duration, )
server/lib/src/cache/redis_ops.rs:46
↓ 2 callersMethodsetter
(&self)
server/lib-net-monoio/src/net/mod.rs:252
↓ 2 callersMethodsetter
(&self)
server/lib-net-tokio/src/net/mod.rs:138
← previousnext →101–200 of 807, ranked by callers