MCPcopy Create free account

hub / github.com/SuanCaiYv/prim / functions

Functions807 in github.com/SuanCaiYv/prim

⨍ Functions 807◇ Types & classes 467
↓ 2 callersFunctionsignNavigate
()
ui-prototype/src/App.tsx:36
↓ 2 callersFunctionverify_token
(token: &str, key: &[u8], audience: u64)
server/lib/src/util/jwt.rs:55
↓ 2 callersMethodwhich_node
( &self, request: Request<WhichNodeReq>, )
server/scheduler/src/rpc/node.rs:125
↓ 2 callersMethodwhich_node
( &mut self, request: impl tonic::IntoRequest<super::WhichNodeReq>, )
server/api/src/rpc/node_proto.rs:164
↓ 2 callersMethodwhich_to_connect
( &mut self, request: impl tonic::IntoRequest<super::WhichToConnectReq>, )
server/api/src/rpc/node_proto.rs:221
↓ 1 callersMethodAsSlice
()
server/golang/lib-go/entity/reqwest/msg.go:45
↓ 1 callersMethodSetReqId
(reqId uint64)
server/golang/lib-go/entity/reqwest/msg.go:57
↓ 1 callersFunctionadd
(left: usize, right: usize)
server/lib-net-monoio/src/lib.rs:3
↓ 1 callersMethodall_group_node_list
( &mut self, request: impl tonic::IntoRequest<super::AllGroupNodeListReq>, )
server/scheduler/src/rpc/node_proto.rs:277
↓ 1 callersFunctionarray2Buffer
(array: Array<number>)
ui-prototype/src/util/base.ts:22
↓ 1 callersMethodas_any
(&self)
server/lib/src/cache/redis_ops.rs:321
↓ 1 callersMethodas_bool
(&self)
server/lib/src/net/mod.rs:64
↓ 1 callersMethodas_last_ack
(&self)
server/lib/src/net/mod.rs:136
↓ 1 callersMethodas_mut_any
(&mut self)
server/lib/src/cache/redis_ops.rs:325
↓ 1 callersMethodas_mut_num_list_map
(&mut self)
server/lib/src/net/mod.rs:161
↓ 1 callersMethodatomic_increment
(&mut self, key: &str)
server/lib/src/cache/redis_ops.rs:274
↓ 1 callersFunctionaudience_of_token
(token: &str)
server/lib/src/util/jwt.rs:43
↓ 1 callersMethodcall_all_group_node_list
(&mut self, group_id: u64)
server/message/src/rpc/node.rs:64
↓ 1 callersMethodcall_curr_node_group_id_user_list
( &mut self, group_id: u64, )
server/message/src/rpc/node.rs:49
↓ 1 callersMethodcall_group_user_list
(&mut self, group_id: u64)
server/scheduler/src/rpc/node.rs:57
↓ 1 callersMethodcall_seqnum_all_node
(&mut self)
server/message/src/rpc/node.rs:70
↓ 1 callersMethodcall_which_node
(&mut self, user_id: u64)
server/api/src/rpc/node.rs:38
↓ 1 callersMethodcall_which_to_connect
(&mut self, user_id: u64)
server/api/src/rpc/node.rs:68
↓ 1 callersFunctionclear_log
clear log file of the day before 7 days
server/msglogger/src/logger.rs:13
↓ 1 callersMethodconnect
Attempt to create a new client by connecting to a given endpoint.
server/scheduler/src/rpc/node_proto.rs:154
↓ 1 callersMethodconnect
Attempt to create a new client by connecting to a given endpoint.
server/api/src/rpc/node_proto.rs:87
↓ 1 callersMethodcontains
(&self, addr: &SocketAddr)
server/scheduler/src/cluster/mod.rs:63
↓ 1 callersMethodcurr_node_group_id_user_list
( &mut self, request: impl tonic::IntoRequest<super::CurrNodeGroupIdUserListReq>,
server/scheduler/src/rpc/node_proto.rs:228
↓ 1 callersMethodcurr_node_group_id_user_list
( &mut self, request: impl tonic::IntoRequest<super::CurrNodeGroupIdUserListReq>,
server/api/src/rpc/node_proto.rs:145
↓ 1 callersFunctiondelete
( host: &str, uri: &str, query: &serde_json::Map<String, serde_json::Value>, headers: &serde_j
ui-prototype/src-tauri/src/service/http.rs:160
↓ 1 callersMethoddelete_list
( &self, user_id1: u64, user_id2: u64, seq_num_list: &[u64], )
ui-prototype/src-tauri/src/service/database.rs:220
↓ 1 callersFunctiondisconnect
()
ui-prototype/src/App.tsx:619
↓ 1 callersMethodextension_mut
(&mut self)
server/lib/src/entity/msg.rs:541
↓ 1 callersFunctionget_cluster_connection_set
()
server/scheduler/src/cluster/mod.rs:27
↓ 1 callersFunctionget_msgprocessor_set
()
server/scheduler/src/service/mod.rs:42
↓ 1 callersFunctionget_redis_ops
()
server/mock/src/cache/mod.rs:10
↓ 1 callersFunctionget_rpc_client
()
server/scheduler/src/rpc/mod.rs:15
↓ 1 callersFunctiongroup_task
(group_id: u64, mut io_receiver: GroupTaskReceiver)
server/message/src/service/handler/mod.rs:384
↓ 1 callersMethodgroup_user_list
( &mut self, request: impl tonic::IntoRequest<super::GroupUserListReq>, )
server/api/src/rpc/node_proto.rs:311
↓ 1 callersMethodgroup_user_list
( &mut self, request: impl tonic::IntoRequest<super::GroupUserListReq>, )
server/message/src/rpc/node_proto.rs:536
↓ 1 callersFunctionhandle_connection
( mut receiver: mpsc::bounded::Rx<(u64, Msg)>, sender: mpsc::bounded::Tx<u64>, mut rx: mpsc::bound
server/msglogger/src/recv.rs:102
↓ 1 callersFunctioninbox
()
ui-prototype/src/App.tsx:501
↓ 1 callersMethodinsert_or_update
(&self, msg: Msg)
ui-prototype/src-tauri/src/service/database.rs:123
↓ 1 callersMethodinsert_or_update_list
(&self, msg_list: Vec<Msg>)
ui-prototype/src-tauri/src/service/database.rs:109
↓ 1 callersMethodio_channel
(&mut self)
server/lib-net-tokio/src/net/client.rs:162
↓ 1 callersMethodio_channels
( &mut self, )
server/lib-net-monoio/src/net/mod.rs:494
↓ 1 callersMethodio_channels
(&mut self)
server/lib-net-tokio/src/net/mod.rs:1687
↓ 1 callersFunctionio_task
only messages that need to be deal by post-service or cached into cache will be sent to this task. those messages types maybe: all message part / all
server/message/src/service/handler/mod.rs:292
↓ 1 callersMethodis_bool
(&self)
server/lib/src/net/mod.rs:60
↓ 1 callersFunctionload
()
server/seqnum/src/main.rs:174
↓ 1 callersFunctionloadOldMsg
(msg: Msg)
ui-prototype/src/App.tsx:424
↓ 1 callersFunctionload_config
(config_path: &str)
ui-prototype/src-tauri/src/config/mod.rs:80
↓ 1 callersFunctionload_config
(config_path: &str)
server/scheduler/src/config/mod.rs:244
↓ 1 callersFunctionload_config
(config_path: &str)
server/api/src/config/mod.rs:199
↓ 1 callersFunctionload_config
(config_path: &str)
server/message/src/config/mod.rs:318
↓ 1 callersFunctionload_config
(config_path: &str)
server/seqnum/src/config/mod.rs:192
↓ 1 callersFunctionload_group_user_list
todo!(new member add)
server/message/src/service/handler/mod.rs:372
↓ 1 callersFunctionload_io_task
()
server/message/src/service/mod.rs:137
↓ 1 callersFunctionload_msglogger
()
server/message/src/service/mod.rs:178
↓ 1 callersFunctionload_my_id
(my_id_preload: u32)
server/scheduler/src/util/mod.rs:15
↓ 1 callersFunctionload_my_id
(my_id_preload: u32)
server/msgprocessor/src/util/mod.rs:15
↓ 1 callersFunctionload_my_id
(my_id_preload: u32)
server/message/src/util/mod.rs:15
↓ 1 callersFunctionload_my_id
(my_id_preload: u32)
server/seqnum/src/util/mod.rs:14
↓ 1 callersFunctionload_seqnum_map
()
server/message/src/service/mod.rs:146
↓ 1 callersFunctionload_signal
()
ui-prototype/src-tauri/src/main.rs:47
↓ 1 callersFunctionlogger
(msg: Msg, file: &mut monoio::fs::File)
server/msglogger/src/logger.rs:6
↓ 1 callersFunctionmergeUserMsgList
()
ui-prototype/src/App.tsx:518
↓ 1 callersMethodmessage_node_alive
( &mut self, request: impl tonic::IntoRequest<super::MessageNodeAliveReq>, )
server/scheduler/src/rpc/node_proto.rs:424
↓ 1 callersMethodmessage_node_alive
( &mut self, request: impl tonic::IntoRequest<super::MessageNodeAliveReq>, )
server/message/src/rpc/node_proto.rs:424
↓ 1 callersFunctionmy_id
()
server/msgprocessor/src/util/mod.rs:11
↓ 1 callersFunctionmy_id
()
server/mock/src/util/mod.rs:12
↓ 1 callersFunctionmy_id
()
server/seqnum/src/util/mod.rs:10
↓ 1 callersMethodnew_connection
(&self, remote_address: SocketAddr)
server/message/src/cluster/client.rs:40
↓ 1 callersFunctionnode_offline
(node_id: u32)
server/message/src/cluster/mod.rs:54
↓ 1 callersFunctionnode_online
(address: SocketAddr, node_id: u32, new_peer: bool)
server/message/src/cluster/mod.rs:47
↓ 1 callersFunctiononLogin
()
ui-prototype/src/components/sign/Sign.tsx:30
↓ 1 callersMethodoperation_channel
(&mut self)
server/lib-net-tokio/src/net/client.rs:300
↓ 1 callersMethodpayload_mut
(&mut self)
server/lib/src/entity/msg.rs:563
↓ 1 callersFunctionpost
( host: &str, uri: &str, query: &serde_json::Map<String, serde_json::Value>, headers: &serde_j
ui-prototype/src-tauri/src/service/http.rs:118
↓ 1 callersMethodpush_msg
( &mut self, request: impl tonic::IntoRequest<super::PushMsgReq>, )
server/scheduler/src/rpc/node_proto.rs:302
↓ 1 callersMethodpush_msg
( &mut self, request: impl tonic::IntoRequest<super::PushMsgReq>, )
server/message/src/rpc/node_proto.rs:302
↓ 1 callersMethodpush_operator
(&self, operator: ReqwestOperator)
server/lib-net-tokio/src/net/mod.rs:314
↓ 1 callersFunctionput
( host: &str, uri: &str, query: &serde_json::Map<String, serde_json::Value>, headers: &serde_j
ui-prototype/src-tauri/src/service/http.rs:71
↓ 1 callersMethodrecorder_list
( &mut self, request: impl tonic::IntoRequest<super::RecorderListReq>, )
server/api/src/rpc/node_proto.rs:202
↓ 1 callersFunctionrecvMsg
(msg: Msg)
ui-prototype/src/App.tsx:399
↓ 1 callersMethodremove
(&self, addr: &SocketAddr)
server/scheduler/src/cluster/mod.rs:58
↓ 1 callersMethodrender
()
ui-prototype/src/components/Header.tsx:32
↓ 1 callersFunctionrenderContentMenu
()
ui-prototype/src/components/chat/RightOperator.tsx:97
↓ 1 callersMethodrun
()
server/scheduler/src/cluster/server.rs:99
↓ 1 callersMethodrun
(&self, msg: &mut Arc<Msg>, inner_states: &mut InnerStates)
server/message/src/cluster/handler/logic.rs:21
↓ 1 callersMethodrun
()
server/seqnum/src/service/server.rs:81
↓ 1 callersMethodseqnum_all_node
( &mut self, request: impl tonic::IntoRequest<super::SeqnumAllNodeReq>, )
server/scheduler/src/rpc/node_proto.rs:399
↓ 1 callersMethodseqnum_node_address
( &mut self, request: impl tonic::IntoRequest<super::SeqnumNodeAddressReq>, )
server/scheduler/src/rpc/node_proto.rs:349
↓ 1 callersMethodseqnum_node_user_select
( &mut self, request: impl tonic::IntoRequest<super::SeqnumNodeUserSelectReq>,
server/scheduler/src/rpc/node_proto.rs:374
↓ 1 callersMethodset
(&self, timeout: Instant)
server/lib-net-tokio/src/lib.rs:28
↓ 1 callersFunctionsetBaseUrl
(url: string)
ui-prototype/src/net/http.ts:125
↓ 1 callersFunctionsetUnSetAckSet
(msg: Msg)
ui-prototype/src/App.tsx:178
↓ 1 callersFunctionsetUserMsgListItemUnread
(peerId: bigint, unread: boolean)
ui-prototype/src/App.tsx:206
↓ 1 callersMethodset_extension_length
(buf: &mut [u8], extension_length: usize)
server/lib/src/entity/msg.rs:250
↓ 1 callersMethodset_payload_length
(buf: &mut [u8], payload_length: usize)
server/lib/src/entity/msg.rs:259
← previousnext →201–300 of 807, ranked by callers