MCPcopy Create free account

hub / github.com/SuanCaiYv/prim / functions

Functions807 in github.com/SuanCaiYv/prim

⨍ Functions 807◇ Types & classes 467
Methodmax_encoding_message_size
(mut self, limit: usize)
server/message/src/rpc/node_proto.rs:224
Methodmessage_node_alive
( &self, _request: Request<MessageNodeAliveReq>, )
server/scheduler/src/rpc/node.rs:301
Methodnew
()
ui-prototype/src-tauri/src/service/database.rs:35
Methodnew
(handler_map: ReqwestHandlerMap)
server/scheduler/src/service/server.rs:30
Methodnew
(inner: T)
server/scheduler/src/rpc/node_proto.rs:170
Methodnew
()
server/scheduler/src/rpc/node.rs:43
Methodnew
(handler_map: ReqwestHandlerMap)
server/scheduler/src/cluster/server.rs:31
Methodnew
()
server/lib/src/util/map.rs:13
Methodnew
()
server/lib-net-monoio/src/net/mod.rs:50
Methodnew
(config: ServerConfig)
server/lib-net-monoio/src/net/server.rs:39
Methodnew
(config: ClientConfig, timeout: Duration)
server/lib-net-monoio/src/net/client.rs:21
Methodnew
(inner: T)
server/api/src/rpc/node_proto.rs:103
Methodnew
()
server/api/src/rpc/node.rs:24
Methodnew
( io_task_sender: IOTaskSender, handler_list: HandlerList, )
server/message/src/service/server.rs:41
Methodnew
()
server/message/src/service/msglogger/mod.rs:23
Methodnew
( seqnum_client_map: Arc<RwLock<AHashMap<u32, ReqwestOperatorManager>>>, )
server/message/src/service/handler/logic.rs:114
Methodnew
(inner: T)
server/message/src/rpc/node_proto.rs:170
Methodnew
()
server/message/src/rpc/node.rs:21
Methodnew
( seqnum_client_map: Arc<RwLock<AHashMap<u32, ReqwestOperatorManager>>>, )
server/message/src/schedule/handler/logic.rs:34
Methodnew
( handler_list: HandlerList, io_task_sender: IOTaskSender, )
server/message/src/cluster/server.rs:26
Methodnew
()
server/message/src/cluster/client.rs:26
Methodnew
(handler_map: ReqwestHandlerMap)
server/seqnum/src/service/server.rs:26
Methodnew
()
server/seqnum/src/service/handler/seqnum.rs:49
Methodnew
(sender: tokio::sync::mpsc::Sender<Instant>)
server/lib-net-tokio/src/lib.rs:24
Methodnew
(sender: mpsc::Sender<Instant>)
server/lib-net-tokio/src/net/mod.rs:107
Methodnew
(config: ServerConfig)
server/lib-net-tokio/src/net/server.rs:91
Methodnew
(config: ClientConfig)
server/lib-net-tokio/src/net/client.rs:42
Functionnew_account_id
( _: &mut Request, _resp: &mut Response, )
server/api/src/handler/user.rs:29
Methodnew_connection
( &self, config: SubConnectionConfig, auth_msg: Arc<Msg>, )
server/lib-net-tokio/src/net/client.rs:214
Methodnew_directly
(operator_list: Vec<ReqwestOperator>)
server/lib-net-monoio/src/net/mod.rs:168
Methodnew_directly
(operator_list: Vec<ReqwestOperator>)
server/lib-net-tokio/src/net/mod.rs:301
Functionnode_crash
(msg: Arc<Msg>)
server/message/src/cluster/mod.rs:61
Methodnoop
()
server/lib/src/entity/msg.rs:885
FunctiononAddFriend
()
ui-prototype/src/components/header/Add.tsx:13
FunctiononAnnouncementChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/chat/ChatHeader.tsx:39
FunctiononAvatarChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:52
FunctiononAvatarChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/chat/ChatHeader.tsx:16
FunctiononCheckCodeChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/header/Add.tsx:155
FunctiononClick
()
ui-prototype/src/components/contacts/ContactListItem.tsx:15
FunctiononClick
()
ui-prototype/src/components/chat/UserMsgListItem.tsx:44
FunctiononClick
()
ui-prototype/src/components/chat/ChatHeader.tsx:89
FunctiononClick
()
ui-prototype/src/components/header/Add.tsx:9
FunctiononClick1
()
ui-prototype/src/components/chat/ChatInfo.tsx:15
FunctiononClick2
()
ui-prototype/src/components/chat/ChatInfo.tsx:19
FunctiononClick3
()
ui-prototype/src/components/chat/ChatInfo.tsx:23
FunctiononClick4
()
ui-prototype/src/components/chat/ChatInfo.tsx:25
FunctiononCreateGroup
()
ui-prototype/src/components/header/Add.tsx:17
FunctiononCredentialChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/sign/Sign.tsx:22
FunctiononDoubleClick
()
ui-prototype/src/components/contacts/ContactListItem.tsx:19
FunctiononGroupIdChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/header/Add.tsx:248
FunctiononGroupNameChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/header/Add.tsx:151
FunctiononInviteMember
()
ui-prototype/src/components/header/Add.tsx:21
FunctiononJoinGroup
()
ui-prototype/src/components/header/Add.tsx:25
FunctiononLogout
()
ui-prototype/src/components/contacts/ContactInfo.tsx:119
FunctiononMask
()
ui-prototype/src/components/portal/Portal.tsx:5
FunctiononNameChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/chat/ChatHeader.tsx:34
FunctiononNicknameChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:44
FunctiononNicknameKeyDown
(e: React.KeyboardEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:86
FunctiononRemarkChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:48
FunctiononRemarkChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/header/Add.tsx:65
FunctiononRemarkKeyDown
(e: React.KeyboardEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:102
FunctiononSecretUrlChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/sign/Sign.tsx:26
FunctiononSignatureChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:40
FunctiononSignatureKeyDown
(e: React.KeyboardEvent<HTMLInputElement>)
ui-prototype/src/components/contacts/ContactInfo.tsx:70
FunctiononUserIdChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/header/Add.tsx:61
FunctiononUserIdChange
(e: React.ChangeEvent<HTMLInputElement>)
ui-prototype/src/components/sign/Sign.tsx:18
FunctionopenNewChat
(peerId: bigint)
ui-prototype/src/App.tsx:250
Methodpeek_sort_queue
(&mut self, key: &str)
server/lib/src/cache/redis_ops.rs:104
Methodpeek_sort_queue_more_with_score
( &mut self, key: &str, offset: usize, size: usize, from: f64,
server/lib/src/cache/redis_ops.rs:171
Methodping
(sender: u64, receiver: u64, node_id: u32)
server/lib/src/entity/msg.rs:598
Methodpoll
the request will not sent until the future is polled. note: the request may loss by network crowded, for example: if there are to much packets arrive
server/lib-net-monoio/src/net/mod.rs:97
Methodpoll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
server/message/src/service/msglogger/mod.rs:120
Methodpoll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
server/lib-net-tokio/src/net/mod.rs:148
Methodpoll_ready
( &mut self, _cx: &mut Context<'_>, )
server/scheduler/src/rpc/node_proto.rs:698
Methodpoll_ready
( &mut self, _cx: &mut Context<'_>, )
server/api/src/rpc/node_proto.rs:410
Methodpoll_ready
( &mut self, _cx: &mut Context<'_>, )
server/message/src/rpc/node_proto.rs:698
Methodpong
(sender: u64, receiver: u64, node_id: u32)
server/lib/src/entity/msg.rs:621
Methodpre_alloc
(head: &mut Head)
server/lib/src/entity/msg.rs:384
Methodpre_allocate
(payload_length: usize, extension_length: usize)
server/lib/src/entity/msg.rs:397
Methodpush_msg
this method will only forward the msg to corresponding node.
server/scheduler/src/rpc/node.rs:168
Methodpush_operator
(&self, operator: ReqwestOperator)
server/lib-net-monoio/src/net/mod.rs:182
Methodpush_set
(&mut self, key: &str, val: &T)
server/lib/src/cache/redis_ops.rs:251
FunctionrandomMsg
()
ui-prototype/src/mock/chat.ts:70
Methodraw
(sender: u64, receiver: u64, node_id: u32, payload: &[u8])
server/lib/src/entity/msg.rs:832
Methodraw2
( sender: u64, receiver: u64, node_id: u32, payload: &[u8], extension:
server/lib/src/entity/msg.rs:854
Methodraw_payload
(payload: &Vec<u8>)
server/lib/src/entity/msg.rs:810
Methodrecv_msg
( buffer: &mut Box<[u8; HEAD_LEN]>, recv_stream: &mut RecvStream, mut external_source:
server/lib-net-tokio/src/net/mod.rs:498
Methodrecv_msgc
( stream: &mut OwnedReadHalf<ClientTlsStream<TcpStream>>, )
server/lib-net-monoio/src/net/mod.rs:364
Methodrecv_msgc
( buffer: &mut Box<[u8; HEAD_LEN]>, recv_stream: &mut ReadHalf<tls_client::TlsStream<TcpStream
server/lib-net-tokio/src/net/mod.rs:664
Methodrecv_msgs
( stream: &mut OwnedReadHalf<ServerTlsStream<TcpStream>>, )
server/lib-net-monoio/src/net/mod.rs:315
Methodrecv_msgs
( buffer: &mut Box<[u8; HEAD_LEN]>, recv_stream: &mut ReadHalf<tls_server::TlsStream<TcpStream
server/lib-net-tokio/src/net/mod.rs:628
Functionremove
()
ui-prototype/src/components/chat/RightOperator.tsx:88
Methodremove
(&self, key: &u128)
server/seqnum/src/service/mod.rs:38
FunctionremoveUserMsgListItem
(peerId: bigint)
ui-prototype/src/App.tsx:375
Functionremove_member
( req: &mut Request, _resp: &mut Response, )
server/api/src/handler/group.rs:567
Methodremove_sort_queue_old_data
(&mut self, key: &str, score: f64)
server/lib/src/cache/redis_ops.rs:225
Methodrender
()
ui-prototype/src/components/chat/InputArea.tsx:54
Methodrender
()
ui-prototype/src/components/header/Chat.tsx:40
Methodrender
()
ui-prototype/src/components/header/More.tsx:34
Methodrender
()
ui-prototype/src/components/header/Contacts.tsx:34
← previousnext →601–700 of 807, ranked by callers