Functions — github.com/Xu-Mj/sandcat-backend

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

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

⨍ Functions 492◇ Types & classes 237

↓ 1 callersMethodcreate_friend_tag

Friend Tags Management implementations

db/src/postgres/friend.rs:521

↓ 1 callersMethodcreate_fs

(&self, fs: FsCreate)

db/src/postgres/friend.rs:27

↓ 1 callersMethodcreate_group_category

( &self, req: &CreateGroupCategoryRequest, )

db/src/postgres/group.rs:394

↓ 1 callersMethodcreate_group_with_members

(&self, group: &GroupCreate)

db/src/postgres/group.rs:108

↓ 1 callersMethodcreate_poll

(&self, req: &CreatePollRequest)

db/src/postgres/group.rs:553

↓ 1 callersFunctiondefault_avatars

()

oss/src/lib.rs:27

↓ 1 callersMethoddel_register_code

(&self, email: &str)

cache/src/redis/mod.rs:374

↓ 1 callersMethoddelete_announcement

(&self, id: &str, user_id: &str)

db/src/postgres/group.rs:887

↓ 1 callersMethoddelete_friend

(&self, fs_id: &str, user_id: &str)

db/src/postgres/friend.rs:387

↓ 1 callersMethoddelete_friend_group

(&self, group_id: &str)

db/src/postgres/friend.rs:457

↓ 1 callersMethoddelete_friend_tag

(&self, tag_id: &str)

db/src/postgres/friend.rs:543

↓ 1 callersMethoddelete_group

(&self, group_id: &str, owner: &str)

db/src/postgres/group.rs:314

↓ 1 callersMethoddelete_group_category

(&self, id: &str)

db/src/postgres/group.rs:441

↓ 1 callersMethoddelete_group_file

(&self, file_id: &str, user_id: &str)

db/src/postgres/group.rs:494

↓ 1 callersMethoddelete_message

(&self, message_id: &str)

db/src/mongodb/sharded_message.rs:317

↓ 1 callersFunctiondownload_avatar

(url: &str, state: &AppState)

api/src/handlers/users/oauth2.rs:127

↓ 1 callersMethoddownload_avatar

(&self, key: &str)

oss/src/client.rs:152

↓ 1 callersMethoddownload_file

(&self, key: &str)

oss/src/client.rs:141

↓ 1 callersMethoddrop

(&mut self)

cache/src/redis/mod.rs:420

↓ 1 callersMethodexit_group

(&self, user_id: &str, group_id: &str)

db/src/postgres/group.rs:286

↓ 1 callersFunctionfile_routes

(state: AppState)

api/src/routes.rs:129

↓ 1 callersFunctionfriend_routes

(state: AppState)

api/src/routes.rs:39

↓ 1 callersMethodfrom

(value: String)

api/src/api_utils/lb/strategy.rs:34

↓ 1 callersFunctiongenerate_group_ids

(count: usize)

db/src/benchmarks/benchmark_sharding.rs:209

↓ 1 callersFunctiongenerate_user_ids

(count: usize, prefix: &str)

db/src/benchmarks/benchmark_sharding.rs:205

↓ 1 callersFunctionget_chan

(config: &Config, name: String)

utils/src/lib.rs:168

↓ 1 callersMethodget_cur_seq

(&self, user_id: &str)

cache/src/redis/mod.rs:185

↓ 1 callersMethodget_friend_groups

(&self, user_id: &str)

db/src/postgres/friend.rs:484

↓ 1 callersMethodget_friend_list

(&self, user_id: &str, offline_time: i64)

db/src/postgres/friend.rs:229

↓ 1 callersMethodget_friend_privacy

( &self, user_id: &str, friend_id: &str, )

db/src/postgres/friend.rs:705

↓ 1 callersMethodget_friend_tags

(&self, user_id: &str)

db/src/postgres/friend.rs:562

↓ 1 callersMethodget_group

(&self, user_id: &str, group_id: &str)

db/src/postgres/group.rs:28

↓ 1 callersMethodget_group_and_members

( &self, user_id: &str, group_id: &str, )

db/src/postgres/group.rs:41

↓ 1 callersMethodget_group_announcements

(&self, group_id: &str)

db/src/postgres/group.rs:916

↓ 1 callersMethodget_group_categories

(&self)

db/src/postgres/group.rs:459

↓ 1 callersMethodget_group_files

(&self, group_id: &str)

db/src/postgres/group.rs:525

↓ 1 callersMethodget_group_muted_members

(&self, group_id: &str)

db/src/postgres/group.rs:831

↓ 1 callersMethodget_group_polls

(&self, group_id: &str)

db/src/postgres/group.rs:682

↓ 1 callersMethodget_interaction_stats

( &self, user_id: &str, friend_id: &str, )

db/src/postgres/friend.rs:759

↓ 1 callersMethodget_max_seq

(&self)

db/src/postgres/seq.rs:61

↓ 1 callersMethodget_members

( &self, user_id: &str, group_id: &str, mem_ids: Vec<String>, )

db/src/postgres/group.rs:72

↓ 1 callersMethodget_members_id

query members id from cache if not found, query from db

msg_server/src/consumer.rs:241

↓ 1 callersMethodget_msgs

( &self, user_id: &str, send_start: i64, send_end: i64, rec_start: i64

db/src/mongodb/message.rs:182

↓ 1 callersMethodget_poll_details

(&self, poll_id: &str)

db/src/postgres/group.rs:695

↓ 1 callersMethodget_send_seq

(&self, user_id: &str)

cache/src/redis/mod.rs:205

↓ 1 callersMethodget_service

(&self)

api/src/api_utils/lb/mod.rs:47

↓ 1 callersFunctionget_strategy

(lb_type: LoadBalanceStrategyType)

api/src/api_utils/lb/strategy.rs:6

↓ 1 callersMethodget_user_by_email

(&self, email: &str)

db/src/postgres/user.rs:98

↓ 1 callersFunctiongroup_routes

(state: AppState)

api/src/routes.rs:85

↓ 1 callersMethodhandle_group_seq

( &self, msg_type: &MsgType2, msg: &mut Msg, )

msg_server/src/consumer.rs:281

↓ 1 callersMethodhandle_msg

todo handle error for the task

msg_server/src/consumer.rs:100

↓ 1 callersMethodhandle_msg_read

(&self, msg: Msg)

msg_server/src/consumer.rs:273

↓ 1 callersMethodhandle_send_seq

(&self, user_id: &str)

msg_server/src/consumer.rs:256

↓ 1 callersMethodincr_group_seq

(&self, mut members: Vec<String>)

cache/src/redis/mod.rs:261

↓ 1 callersMethodincrease_message_seq

(&self, user_id: &str)

msg_server/src/consumer.rs:265

↓ 1 callersMethodindex

(&self, service_count: usize)

api/src/api_utils/lb/strategy.rs:50

↓ 1 callersFunctioninit_oauth2

(config: &Config)

api/src/lib.rs:95

↓ 1 callersMethodinitialize_system

初始化分片系统

db/src/mongodb/sharded_message.rs:64

↓ 1 callersMethodinvite_new_members

(&self, group: &GroupInviteNew)

db/src/postgres/group.rs:161

↓ 1 callersFunctionload_seq

缓存中设置一个标志，用来标识是否已经加载过用户的max_seq

cmd/src/load_seq.rs:5

↓ 1 callersMethodmigrate

开始迁移过程

cmd/src/migrate.rs:55

↓ 1 callersMethodmodify_pwd

(&self, user_id: &str, password: &str)

db/src/postgres/user.rs:215

↓ 1 callersMethodmsg_read

(&self, user_id: &str, msg_seq: &[i64])

db/src/mongodb/sharded_message.rs:640

↓ 1 callersMethodmsg_read

(&self, user_id: &str, msg_seq: &[i64])

db/src/mongodb/message.rs:240

↓ 1 callersFunctionmsg_rec_box_cleaner

创建消息清理器，根据配置选择适当的实现

db/src/lib.rs:70

↓ 1 callersFunctionmsg_routes

(state: AppState)

api/src/routes.rs:144

↓ 1 callersMethodmute_group_member

(&self, req: &MuteGroupMemberRequest)

db/src/postgres/group.rs:704

↓ 1 callersFunctionoss

(config: &Config)

oss/src/lib.rs:23

↓ 1 callersFunctionparse_region

(region: &str)

api/src/api_utils/ip_region/mod.rs:4

↓ 1 callersMethodpin_announcement

(&self, id: &str, is_pinned: bool)

db/src/postgres/group.rs:929

↓ 1 callersMethodpool

(&self)

utils/src/sqlx_tester/mod.rs:77

↓ 1 callersMethodprocess_message

(&mut self, message: &mut Msg)

msg_gateway/src/manager.rs:169

↓ 1 callersMethodpush_group_msg

(&self, msg: Msg, members: Vec<GroupMemSeq>)

msg_server/src/pusher/service.rs:150

↓ 1 callersFunctionpush_service

(config: &Config)

msg_server/src/pusher/mod.rs:18

↓ 1 callersMethodpush_single_msg

(&self, request: Msg)

msg_server/src/pusher/service.rs:108

↓ 1 callersMethodquery_group_members_id_from_db

query members id from database and set it to cache

msg_server/src/consumer.rs:359

↓ 1 callersMethodregister

msg_gateway/src/manager.rs:134

↓ 1 callersMethodregister_service

(config: &Config)

msg_gateway/src/ws_server.rs:386

↓ 1 callersFunctionregister_user

(state: &AppState, email: String, access_token: &str)

api/src/handlers/users/oauth2.rs:141

↓ 1 callersMethodremove_group_member_batch

( &self, group_id: &str, member_id: &[&str], )

cache/src/redis/mod.rs:337

↓ 1 callersMethodremove_member

(&self, group_id: &str, user_id: &str, mem_ids: &[String])

db/src/postgres/group.rs:205

↓ 1 callersMethodremove_tags_from_friend

( &self, user_id: &str, friend_id: &str, tag_ids: &[String], )

db/src/postgres/friend.rs:618

↓ 1 callersMethodrun

(&mut self, mut receiver: mpsc::Receiver<Msg>)

msg_gateway/src/manager.rs:156

↓ 1 callersFunctionrun_migration

启动迁移过程

cmd/src/migrate.rs:201

↓ 1 callersMethodsave_group_msg

(&self, message: Msg, members: Vec<GroupMemSeq>)

db/src/mongodb/sharded_message.rs:271

↓ 1 callersMethodsave_max_seq_batch

update max_seq in batch

db/src/postgres/seq.rs:49

↓ 1 callersMethodsave_register_code

(&self, email: &str, code: &str)

cache/src/redis/mod.rs:355

↓ 1 callersMethodschedule_collection_maintenance

设置定期检查和创建新集合的任务

db/src/mongodb/sharded_message.rs:184

↓ 1 callersMethodsearch_user

not allow to use username

db/src/postgres/user.rs:107

↓ 1 callersMethodsend_group

(&self, obj_ids: Vec<GroupMemSeq>, mut msg: Msg)

msg_gateway/src/manager.rs:45

↓ 1 callersMethodsend_group_msg_to_user

( &self, request: Request<SendGroupMsgRequest>, )

msg_gateway/src/rpc.rs:84

↓ 1 callersMethodsend_msg

send message to mq generate msg id and send time

msg_server/src/productor.rs:122

↓ 1 callersMethodsend_msg_to_user

Send message to user pusher will procedure this to send message to user

msg_gateway/src/rpc.rs:70

↓ 1 callersMethodsend_rpc_message

(&self, message: Msg)

msg_gateway/src/manager.rs:204

↓ 1 callersMethodserver_url

(&self)

abi/src/config.rs:305

↓ 1 callersMethodset_seq_loaded

(&self)

cache/src/redis/mod.rs:143

↓ 1 callersFunctionstart_all

(config: Config)

cmd/src/main.rs:102

↓ 1 callersMethodunmute_group_member

( &self, group_id: &str, user_id: &str, operator_id: &str, )

db/src/postgres/group.rs:782

↓ 1 callersMethodunregister

(&mut self, id: String, platform: PlatformType)

msg_gateway/src/manager.rs:141

↓ 1 callersMethodupdate

update the service address

api/src/api_utils/lb/mod.rs:67

← previous next →101–200 of 492, ranked by callers