Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Xu-Mj/sandcat-backend
/ functions
Functions
492 in github.com/Xu-Mj/sandcat-backend
⨍
Functions
492
◇
Types & classes
237
Method
new_with_group_operation
when dismiss group, send id is the owner id, when member exit group, send id is the member id
abi/src/types/msg.rs:99
Method
new_with_group_poll
群组投票消息
abi/src/types/msg.rs:218
Method
new_with_group_remove_mem
( sender_id: String, group_id: String, send_seq: i64, invitation: Vec<u8>,
abi/src/types/msg.rs:158
Method
new_with_group_update
( sender_id: String, receiver_id: String, send_seq: i64, msg: Vec<u8>, )
abi/src/types/msg.rs:178
Method
not_found
()
abi/src/errors/mod.rs:155
Method
not_found_with_details
(details: impl Into<String>)
abi/src/errors/mod.rs:160
Method
online_count
(&self)
cache/src/redis/mod.rs:392
Method
path_parsing
(err: impl StdError + 'static + Send + Sync)
abi/src/errors/mod.rs:175
Function
pin_announcement
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<PinAnnouncement
api/src/handlers/groups/group_handlers.rs:535
Method
poll_ready
(&mut self, cx: &mut Context<'_>)
utils/src/service_discovery/tonic_service_discovery.rs:26
Method
poll_ready
( &mut self, _cx: &mut Context<'_>, )
abi/src/pb/message.rs:2199
Function
pull_offline_messages
( State(state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<GetDbMessagesReques
api/src/handlers/messages/msg_handlers.rs:45
Function
query_friend_info
( State(app_state): State<AppState>, PathWithAuthExtractor(user_id): PathWithAuthExtractor<String>, )
api/src/handlers/friends/friend_handlers.rs:155
Method
query_group_members_by_group_id
(&self, group_id: &str)
db/src/postgres/group.rs:246
Method
query_group_members_id
(&self, group_id: &str)
db/src/postgres/group.rs:235
Function
refresh_token
refresh auth token
api/src/handlers/users/user_handlers.rs:26
Method
register
(&self, registration: Registration)
utils/src/service_register_center/consul/mod.rs:64
Function
remove_member
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<RemoveMemberReq
api/src/handlers/groups/group_handlers.rs:176
Method
reset
(&mut self)
api/src/api_utils/lb/strategy.rs:16
Method
reset
(&mut self)
api/src/api_utils/lb/strategy.rs:55
Method
save_message
(&self, message: Msg)
db/src/postgres/message.rs:22
Method
save_send_max_seq
(&self, user_id: &str)
db/src/postgres/seq.rs:24
Function
search_user
( State(app_state): State<AppState>, PathWithAuthExtractor((user_id, pattern)): PathWithAuthExtractor<
api/src/handlers/users/user_handlers.rs:118
Method
send_compressed
(mut self, encoding: CompressionEncoding)
abi/src/pb/message.rs:1921
Function
send_email
( State(state): State<AppState>, JsonExtractor(email): JsonExtractor<Email>, )
api/src/handlers/users/user_handlers.rs:182
Method
send_group_msg_to_user
send group message to user by websocket
abi/src/pb/message.rs:1984
Method
send_message
( &self, request: Request<SendMsgRequest>, )
msg_gateway/src/rpc.rs:54
Method
send_message
send message through rpc
abi/src/pb/message.rs:1948
Method
send_msg_to_user
send single message to user by websocket
abi/src/pb/message.rs:1966
Method
send_text
(&self, msg: String)
msg_gateway/src/client.rs:26
Method
send_to_db
( db: Arc<DbRepo>, msg_box: Arc<dyn MsgRecBoxRepo>, msg: Msg, msg_type: MsgTyp
msg_server/src/consumer.rs:336
Method
service_not_found
(name: impl Into<String>)
abi/src/errors/mod.rs:117
Method
set_send_seq
(&self, max_seq: &[(String, i64)])
cache/src/redis/mod.rs:164
Function
sharded_group_message_works
()
db/src/mongodb/sharded_message.rs:883
Function
sharded_insert_and_delete_works
()
db/src/mongodb/sharded_message.rs:832
Function
sharded_insert_and_get_works
()
db/src/mongodb/sharded_message.rs:817
Function
sharded_message_read_status_works
()
db/src/mongodb/sharded_message.rs:940
Function
sharded_query_messages_works
()
db/src/mongodb/sharded_message.rs:849
Method
single_script_load
(client: &redis::Client)
cache/src/redis/mod.rs:71
Method
source
(&self)
abi/src/errors/mod.rs:190
Method
start
(config: Config)
msg_gateway/src/ws_server.rs:429
Method
start
(manager: Manager, config: &Config)
msg_gateway/src/rpc.rs:26
Method
start
(config: &Config)
msg_server/src/productor.rs:27
Function
start_register_center
(config: &Config)
utils/src/lib.rs:228
Method
test
(State(state): State<AppState>)
msg_gateway/src/ws_server.rs:410
Function
test_add_group_member_id
()
cache/src/redis/mod.rs:483
Function
test_del_group_members
()
cache/src/redis/mod.rs:503
Function
test_hash_password
()
utils/src/lib.rs:315
Function
test_increase_seq
()
cache/src/redis/mod.rs:452
Function
test_load
()
msg_gateway/src/main.rs:21
Function
test_load
()
abi/src/config.rs:365
Function
test_multi_type_ip
()
api/src/api_utils/ip_region/mod.rs:23
Function
test_query_group_members_id
()
cache/src/redis/mod.rs:469
Function
test_remove_group_member_id
()
cache/src/redis/mod.rs:492
Function
test_save_group_members_id
()
cache/src/redis/mod.rs:460
Function
test_template
()
api/src/handlers/users/user_handlers.rs:247
Method
try_from
(value: Document)
abi/src/types/msg.rs:25
Method
unauthorized
( error: impl StdError + 'static + Send + Sync, details: impl Into<String>, )
abi/src/errors/mod.rs:122
Method
unauthorized_with_details
(details: impl Into<String>)
abi/src/errors/mod.rs:130
Function
unmute_group_member
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<UnmuteRequest>,
api/src/handlers/groups/group_handlers.rs:462
Function
update_file_pin_status
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<UpdateFilePinRe
api/src/handlers/groups/group_handlers.rs:366
Function
update_friend_group
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<FriendGroup>, )
api/src/handlers/friends/friend_handlers.rs:199
Function
update_friend_privacy
好友隐私设置
api/src/handlers/friends/friend_handlers.rs:313
Function
update_friend_remark
( State(app_state): State<AppState>, JsonWithAuthExtractor(relation): JsonWithAuthExtractor<UpdateRema
api/src/handlers/friends/friend_handlers.rs:140
Method
update_friend_status
( &self, user_id: &str, friend_id: &str, status: FriendshipStatus, )
db/src/postgres/friend.rs:210
Method
update_fs
(&self, fs: FsUpdate)
db/src/postgres/friend.rs:167
Function
update_group_category
( State(app_state): State<AppState>, JsonWithAuthExtractor(category): JsonWithAuthExtractor<GroupCateg
api/src/handlers/groups/group_handlers.rs:297
Function
update_group_handler
( State(app_state): State<AppState>, PathWithAuthExtractor(user_id): PathWithAuthExtractor<String>,
api/src/handlers/groups/group_handlers.rs:154
Function
update_group_settings
新增 - 群组设置相关
api/src/handlers/groups/group_handlers.rs:247
Function
update_interaction_score
好友互动分数
api/src/handlers/friends/friend_handlers.rs:356
Method
update_login_info
(&self, user_id: &str, ip: &str)
db/src/postgres/user.rs:262
Function
update_member_settings
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<UpdateMemberSet
api/src/handlers/groups/group_handlers.rs:270
Function
update_user
( State(app_state): State<AppState>, JsonExtractor(user): JsonExtractor<UserUpdate>, )
api/src/handlers/users/user_handlers.rs:95
Method
update_user_status
( &self, user_id: &str, status: &str, message: Option<&str>, )
db/src/postgres/user.rs:234
Function
upload
( State(state): State<AppState>, mut multipart: Multipart, )
api/src/handlers/files/file.rs:12
Function
upload_avatar
( State(state): State<AppState>, mut multipart: Multipart, )
api/src/handlers/files/file.rs:59
Function
upload_group_file
新增 - 群组文件相关
api/src/handlers/groups/group_handlers.rs:321
Method
validate
(&self)
abi/src/types/group.rs:20
Method
validate
(&self)
abi/src/types/friend.rs:189
Method
verify_token
(token: String, user_id: &str, jwt_secret: &String)
msg_gateway/src/ws_server.rs:473
Function
vote_poll
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<VotePollRequest
api/src/handlers/groups/group_handlers.rs:401
Method
websocket
( user_id: String, device_id: String, token: String, platform: PlatformType,
msg_gateway/src/ws_server.rs:570
Method
websocket_handler
( Path((user_id, device_id, platform)): Path<(String, String, i32)>, headers: axum::http::Head
msg_gateway/src/ws_server.rs:503
Method
with_derive_builder
(self, path: &[&str])
abi/build.rs:20
Method
with_derive_builder_into
(self, path: &str, field: &[&str])
abi/build.rs:26
Method
with_derive_builder_option
(self, path: &str, field: &[&str])
abi/build.rs:35
Method
with_details
(kind: ErrorKind, details: impl Into<String>)
abi/src/errors/mod.rs:76
Method
with_interceptor
( inner: T, interceptor: F, )
abi/src/pb/message.rs:1898
Method
with_kind
(kind: ErrorKind)
abi/src/errors/mod.rs:67
Method
with_origin
(inner: T, origin: Uri)
abi/src/pb/message.rs:1894
Method
with_port
(&self, port: u16)
abi/src/config.rs:349
Method
ws_url
(&self, https: bool)
abi/src/config.rs:122
← previous
401–492 of 492, ranked by callers