MCPcopy Create free account

hub / github.com/Xu-Mj/sandcat-backend / functions

Functions492 in github.com/Xu-Mj/sandcat-backend

⨍ Functions 492◇ Types & classes 237
↓ 226 callersMethodclone
(&self)
abi/src/pb/message.rs:2342
↓ 13 callersMethodincr_send_seq
(&self, user_id: &str)
cache/src/redis/mod.rs:245
↓ 13 callersMethodsend_msg
( &mut self, request: impl tonic::IntoRequest<super::SendMsgRequest>, )
abi/src/pb/message.rs:2090
↓ 10 callersMethoddatabase
(&self)
utils/src/mongodb_tester/mod.rs:60
↓ 10 callersMethodsave_message
(&self, message: &Msg)
db/src/mongodb/message.rs:67
↓ 9 callersMethodget_collection
获取指定集合
db/src/mongodb/sharded_message.rs:147
↓ 8 callersMethodget_user_range
根据用户ID获取分片范围
db/src/mongodb/sharded_message.rs:177
↓ 7 callersFunctionstart
(config: Config)
api/src/lib.rs:110
↓ 7 callersMethodurl
(&self, https: bool)
abi/src/config.rs:118
↓ 6 callersMethodsave_group_members_id
( &self, group_id: &str, members_id: Vec<String>, )
cache/src/redis/mod.rs:307
↓ 6 callersFunctionto_doc
(msg: &Msg)
db/src/mongodb/utils.rs:5
↓ 5 callersMethodget_message
(&self, message_id: &str)
db/src/mongodb/message.rs:111
↓ 5 callersMethodget_msgs
( &self, user_id: &str, send_start: i64, send_end: i64, rec_start: i64
db/src/mongodb/sharded_message.rs:534
↓ 5 callersFunctionget_test_msg
辅助函数：创建测试消息
db/src/mongodb/sharded_message.rs:993
↓ 5 callersFunctionmsg_rec_box_repo
创建消息接收盒子仓库，根据配置选择适当的实现
db/src/lib.rs:56
↓ 5 callersFunctionurl
(https: bool, host: &str, port: u16)
abi/src/config.rs:189
↓ 4 callersMethodapi_url
(&self, name: &str)
utils/src/service_register_center/consul/mod.rs:50
↓ 4 callersFunctioncache
(config: &Config)
cache/src/lib.rs:89
↓ 4 callersMethodget_collection_name
根据时间和用户ID获取集合名
db/src/mongodb/sharded_message.rs:170
↓ 4 callersMethodsave_message
(&self, message: &Msg)
db/src/mongodb/sharded_message.rs:261
↓ 4 callersMethodsend_binary
(&self, msg: Vec<u8>)
msg_gateway/src/client.rs:30
↓ 3 callersMethodbroadcast
(&self, msg: Msg)
msg_gateway/src/manager.rs:220
↓ 3 callersMethodcreate_error_message
(&self, message: &mut Msg, error: impl ToString)
msg_gateway/src/manager.rs:214
↓ 3 callersMethodfilter_by_name
(&self, name: &str)
utils/src/service_register_center/consul/mod.rs:99
↓ 3 callersFunctiongenerate_salt
()
utils/src/lib.rs:71
↓ 3 callersFunctionget_test_msg
(msg_id: String)
db/src/mongodb/message.rs:353
↓ 3 callersFunctionhash_password
(password: &[u8], salt: &str)
utils/src/lib.rs:75
↓ 3 callersFunctionprint_benchmark_results
(count: usize, duration: Duration)
db/src/benchmarks/benchmark_sharding.rs:246
↓ 3 callersMethodquery_group_members_id
the group members id in redis is a set, with group_members_id:group_id as key
cache/src/redis/mod.rs:297
↓ 3 callersFunctionregister_service
(config: &Config, com: Component)
utils/src/lib.rs:242
↓ 3 callersFunctionstart
(config: &Config)
msg_server/src/lib.rs:9
↓ 3 callersMethodupload_avatar
(&self, key: &str, content: Vec<u8>)
oss/src/client.rs:149
↓ 2 callersMethodadd_group_member_id
(&self, member_id: &str, group_id: &str)
cache/src/redis/mod.rs:323
↓ 2 callersFunctionbenchmark_group_messages
( message_box: &Arc<dyn MsgRecBoxRepo>, count: usize, )
db/src/benchmarks/benchmark_sharding.rs:130
↓ 2 callersFunctionbenchmark_single_messages
( message_box: &Arc<dyn MsgRecBoxRepo>, count: usize, )
db/src/benchmarks/benchmark_sharding.rs:94
↓ 2 callersFunctionclean_receive_box
(config: &Config)
db/src/lib.rs:80
↓ 2 callersFunctioncreate_test_message
( id: String, sender_id: String, receiver_id: String, time: i64, seq: i64, msg_type: M
db/src/benchmarks/benchmark_sharding.rs:213
↓ 2 callersMethodcreate_user
(&self, user: User)
db/src/postgres/user.rs:24
↓ 2 callersMethoddecode
(&mut self)
api/src/handlers/users/mod.rs:47
↓ 2 callersMethoddel_group_members
(&self, group_id: &str)
cache/src/redis/mod.rs:348
↓ 2 callersMethoddelete
(&self, bucket: &str, key: &str)
oss/src/client.rs:216
↓ 2 callersMethoddelete_message
(&self, message_id: &str)
db/src/mongodb/message.rs:98
↓ 2 callersMethoddelete_messages
(&self, user_id: &str, msg_seq: Vec<i64>)
db/src/mongodb/message.rs:104
↓ 2 callersMethoddiscovery
execute discovery once
utils/src/service_discovery/tonic_service_discovery.rs:60
↓ 2 callersMethoddownload
(&self, bucket: &str, key: &str)
oss/src/client.rs:202
↓ 2 callersMethodensure_collection_indexed
确保指定的集合存在并有正确的索引
db/src/mongodb/sharded_message.rs:96
↓ 2 callersMethodexists_by_name
(&self, bucket: &str, key: &str)
oss/src/client.rs:161
↓ 2 callersMethodfetch
(&self)
utils/src/lib.rs:96
↓ 2 callersFunctiongen_token
( app_state: &AppState, mut user: User, addr: SocketAddr, )
api/src/handlers/users/mod.rs:79
↓ 2 callersFunctionget_auth_url
(client: &BasicClient)
api/src/handlers/users/oauth2.rs:107
↓ 2 callersFunctionget_chan_
( config: &Config, name: String, sender: Sender<Change<SocketAddr, Endpoint>>, )
utils/src/lib.rs:174
↓ 2 callersFunctionget_channel
( mut discovery: DynamicServiceDiscovery<ServiceResolver>, channel: Channel, )
utils/src/lib.rs:159
↓ 2 callersMethodget_fs_list
get friendship list by user_id and offline_time
db/src/postgres/friend.rs:138
↓ 2 callersMethodget_message
(&self, message_id: &str)
db/src/mongodb/sharded_message.rs:371
↓ 2 callersMethodget_register_code
(&self, email: &str)
cache/src/redis/mod.rs:368
↓ 2 callersFunctionget_rpc_client
( config: &Config, service_name: String, )
utils/src/lib.rs:301
↓ 2 callersFunctionget_token_result
( client: &BasicClient, code: String, )
api/src/handlers/users/oauth2.rs:116
↓ 2 callersMethodget_user_by_id
(&self, id: &str)
db/src/postgres/user.rs:90
↓ 2 callersMethodhandle_sub_services
(&self, services: Vec<Service>)
msg_server/src/pusher/service.rs:75
↓ 2 callersMethodincrease_seq
(&self, user_id: &str)
cache/src/redis/mod.rs:229
↓ 2 callersFunctioninit_oauth2_client
(oauth2_config: &OAuth2Item)
api/src/lib.rs:101
↓ 2 callersMethodinto_response
(self)
abi/src/errors/mod.rs:276
↓ 2 callersMethodlevel
(&self)
abi/src/config.rs:41
↓ 2 callersMethodload
(filename: impl AsRef<Path>)
abi/src/config.rs:298
↓ 2 callersFunctionprocess_batch
处理一批消息
cmd/src/migrate.rs:178
↓ 2 callersMethodremove_group_member_id
(&self, group_id: &str, member_id: &str)
cache/src/redis/mod.rs:330
↓ 2 callersMethodrpc_server_url
(&self)
abi/src/config.rs:113
↓ 2 callersMethodrun
(mut self)
utils/src/service_discovery/tonic_service_discovery.rs:95
↓ 2 callersMethodsave_group_msg
( &self, mut message: Msg, members: Vec<GroupMemSeq>, )
db/src/mongodb/message.rs:73
↓ 2 callersMethodsave_max_seq
(&self, user_id: &str)
db/src/postgres/seq.rs:36
↓ 2 callersMethodsend_msg_to_clients
(&self, clients: &DashMap<PlatformType, Client>, msg: &Msg)
msg_gateway/src/manager.rs:92
↓ 2 callersMethodsend_single_msg
(&self, obj_id: &str, msg: &Msg)
msg_gateway/src/manager.rs:85
↓ 2 callersMethodsend_to_self
(&self, id: &str, msg: &Msg)
msg_gateway/src/manager.rs:62
↓ 2 callersMethodserver_url
(&self)
utils/src/mongodb_tester/mod.rs:35
↓ 2 callersMethodserver_url
(&self)
utils/src/sqlx_tester/mod.rs:62
↓ 2 callersFunctionservice_register_center
(config: &Config)
utils/src/service_register_center/mod.rs:29
↓ 2 callersMethodset_seq
(&self, max_seq: &[(String, i64, i64)])
cache/src/redis/mod.rs:149
↓ 2 callersMethodupload
(&self, bucket: &str, key: &str, content: Vec<u8>)
oss/src/client.rs:191
↓ 2 callersMethodurl
(&self)
utils/src/sqlx_tester/mod.rs:73
↓ 1 callersMethodadd_tags_to_friend
( &self, user_id: &str, friend_id: &str, tag_ids: &[String], )
db/src/postgres/friend.rs:575
↓ 1 callersMethodagree_friend_apply_request
(&self, fs: AgreeReply)
db/src/postgres/friend.rs:274
↓ 1 callersFunctionapp_routes
(state: AppState)
api/src/routes.rs:30
↓ 1 callersMethodas_str_name
String value of the enum field names used in the ProtoBuf definition. The values are not transformed in any way and thus are considered stable (if th
abi/src/pb/message.rs:204
↓ 1 callersMethodassign_friend_to_group
( &self, user_id: &str, friend_id: &str, group_id: &str, )
db/src/postgres/friend.rs:497
↓ 1 callersFunctionbenchmark_mixed_messages
( message_box: &Arc<dyn MsgRecBoxRepo>, count: usize, )
db/src/benchmarks/benchmark_sharding.rs:180
↓ 1 callersMethodbuild_endpoint
(&self, address: SocketAddr)
utils/src/service_discovery/tonic_service_discovery.rs:87
↓ 1 callersMethodchange_member_role
( &self, group_id: &str, user_id: &str, target_id: &str, new_role: &st
db/src/postgres/group.rs:944
↓ 1 callersMethodchange_set
( &self, endpoints: &HashSet<SocketAddr>, )
utils/src/service_discovery/tonic_service_discovery.rs:71
↓ 1 callersMethodcheck_avatar_bucket_exits
(&self)
oss/src/client.rs:74
↓ 1 callersMethodcheck_bucket_exists
(&self)
oss/src/client.rs:55
↓ 1 callersMethodcheck_default_avatars
(&self)
oss/src/client.rs:99
↓ 1 callersMethodcheck_seq_loaded
(&self)
cache/src/redis/mod.rs:132
↓ 1 callersMethodclassify_msg_type
(&self, mt: MsgType)
msg_server/src/consumer.rs:178
↓ 1 callersMethodclean_receive_box
(&self, period: i64, types: Vec<i32>)
db/src/mongodb/message.rs:252
↓ 1 callersMethodclose_poll
(&self, poll_id: &str, user_id: &str)
db/src/postgres/group.rs:648
↓ 1 callersMethodconnect
Attempt to create a new client by connecting to a given endpoint.
abi/src/pb/message.rs:1874
↓ 1 callersMethodconsume
(&mut self)
msg_server/src/consumer.rs:80
↓ 1 callersMethodcreate_announcement
( &self, req: &CreateAnnouncementRequest, )
db/src/postgres/group.rs:844
↓ 1 callersMethodcreate_bucket
(&self)
oss/src/client.rs:110
↓ 1 callersMethodcreate_friend_group
Friend Group Management implementations
db/src/postgres/friend.rs:411
next →1–100 of 492, ranked by callers