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
Functionget_apply_list_by_user_id
获取好友申请列表
api/src/handlers/friends/friend_handlers.rs:39
Functionget_avatar_by_name
( State(state): State<AppState>, PathExtractor(filename): PathExtractor<String>, )
api/src/handlers/files/file.rs:46
Functionget_channel_with_config
( config: &Config, service_name: impl ToString, protocol: impl ToString, )
utils/src/lib.rs:124
Functionget_channel_with_register
( register: Arc<dyn ServiceRegister>, service_name: impl ToString, protocol: impl ToString, )
utils/src/lib.rs:143
Functionget_file_by_name
( State(state): State<AppState>, PathExtractor(filename): PathExtractor<String>, )
api/src/handlers/files/file.rs:33
Functionget_friend_groups
( State(app_state): State<AppState>, PathWithAuthExtractor(id): PathWithAuthExtractor<String>, )
api/src/handlers/friends/friend_handlers.rs:225
Functionget_friend_privacy
( State(app_state): State<AppState>, PathWithAuthExtractor((user_id, friend_id)): PathWithAuthExtracto
api/src/handlers/friends/friend_handlers.rs:330
Functionget_friend_tags
( State(app_state): State<AppState>, PathWithAuthExtractor(id): PathWithAuthExtractor<String>, )
api/src/handlers/friends/friend_handlers.rs:278
Functionget_friends_list_by_user_id
( State(app_state): State<AppState>, PathWithAuthExtractor((user_id, offline_time)): PathWithAuthExtra
api/src/handlers/friends/friend_handlers.rs:21
Functionget_group
get group information need user id and group id if user is not in the group, return error
api/src/handlers/groups/group_handlers.rs:21
Functionget_group_and_members
( State(app_state): State<AppState>, PathWithAuthExtractor((user_id, group_id)): PathWithAuthExtractor
api/src/handlers/groups/group_handlers.rs:35
Functionget_group_announcements
( State(app_state): State<AppState>, PathWithAuthExtractor(group_id): PathWithAuthExtractor<String>, )
api/src/handlers/groups/group_handlers.rs:523
Methodget_group_by_id
(&self, group_id: &str)
db/src/postgres/group.rs:226
Functionget_group_categories
( State(app_state): State<AppState>, )
api/src/handlers/groups/group_handlers.rs:313
Functionget_group_files
( State(app_state): State<AppState>, PathWithAuthExtractor(group_id): PathWithAuthExtractor<String>, )
api/src/handlers/groups/group_handlers.rs:358
Functionget_group_members
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<GetMemberReq>,
api/src/handlers/groups/group_handlers.rs:51
Functionget_group_muted_members
( State(app_state): State<AppState>, PathWithAuthExtractor(group_id): PathWithAuthExtractor<String>, )
api/src/handlers/groups/group_handlers.rs:474
Functionget_group_polls
( State(app_state): State<AppState>, PathWithAuthExtractor(group_id): PathWithAuthExtractor<String>, )
api/src/handlers/groups/group_handlers.rs:421
Functionget_host_name
get host name
utils/src/lib.rs:34
Functionget_interaction_stats
( State(app_state): State<AppState>, PathWithAuthExtractor((user_id, friend_id)): PathWithAuthExtracto
api/src/handlers/friends/friend_handlers.rs:373
Methodget_messages
(&self, user_id: &str, start: i64, end: i64)
db/src/mongodb/sharded_message.rs:481
Methodget_messages
(&self, user_id: &str, start: i64, end: i64)
db/src/mongodb/message.rs:159
Methodget_messages_stream
( &self, user_id: &str, start: i64, end: i64, )
db/src/mongodb/sharded_message.rs:388
Methodget_messages_stream
( &self, user_id: &str, start: i64, end: i64, )
db/src/mongodb/message.rs:122
Functionget_poll_details
( State(app_state): State<AppState>, PathWithAuthExtractor(poll_id): PathWithAuthExtractor<String>, )
api/src/handlers/groups/group_handlers.rs:429
Functionget_rpc_channel_by_name
( config: &Config, name: &str, protocol: &str, )
utils/src/lib.rs:42
Methodget_send_to_db_flag
(msg_type: &MsgType)
msg_server/src/consumer.rs:325
Functionget_seq
( State(state): State<AppState>, PathWithAuthExtractor(user_id): PathWithAuthExtractor<String>, )
api/src/handlers/messages/msg_handlers.rs:69
Methodget_seq
(&self, user_id: &str)
cache/src/redis/mod.rs:176
Methodget_state
获取当前连接状态
msg_gateway/src/ws_server.rs:378
Functionget_timestamp_ms
辅助函数：获取毫秒级时间戳
db/src/mongodb/sharded_message.rs:985
Functionget_user_by_id
( State(app_state): State<AppState>, PathExtractor(id): PathExtractor<String>, )
api/src/handlers/users/user_handlers.rs:105
Functiongithub_callback
( Query(auth): Query<AuthResp>, ConnectInfo(addr): ConnectInfo<SocketAddr>, State(state): State<Ap
api/src/handlers/users/oauth2.rs:55
Functiongithub_login
(State(state): State<AppState>)
api/src/handlers/users/oauth2.rs:27
Functiongoogle_callback
( Query(auth): Query<AuthResp>, State(state): State<AppState>, )
api/src/handlers/users/oauth2.rs:99
Functiongoogle_login
(State(state): State<AppState>)
api/src/handlers/users/oauth2.rs:93
Methodgroup_script_load
(client: &redis::Client)
cache/src/redis/mod.rs:95
Methodhandle_group_message
( db: Arc<DbRepo>, msg_box: Arc<dyn MsgRecBoxRepo>, message: Msg, need_to_hist
msg_server/src/consumer.rs:418
Methodhandle_message
( db: Arc<DbRepo>, msg_box: Arc<dyn MsgRecBoxRepo>, message: Msg, need_to_hist
msg_server/src/consumer.rs:374
Methodinternal
(error: impl StdError + 'static + Send + Sync)
abi/src/errors/mod.rs:94
Methodinternal_box
(error: Box<dyn StdError + 'static + Send + Sync>)
abi/src/errors/mod.rs:85
Methodinternal_with_details
(details: impl Into<String>)
abi/src/errors/mod.rs:112
Functioninvite_new_members
( State(app_state): State<AppState>, JsonWithAuthExtractor(invitation): JsonWithAuthExtractor<GroupInv
api/src/handlers/groups/group_handlers.rs:123
Functionit_works
()
utils/src/sqlx_tester/mod.rs:112
Functionlogin
( State(app_state): State<AppState>, ConnectInfo(addr): ConnectInfo<SocketAddr>, JsonExtractor(mut
api/src/handlers/users/user_handlers.rs:137
Functionlogout
( State(app_state): State<AppState>, PathExtractor(uuid): PathExtractor<String>, )
api/src/handlers/users/user_handlers.rs:129
Functionmain
()
msg_gateway/src/main.rs:7
Functionmain
()
abi/build.rs:54
Functionmain
()
oss/src/main.rs:1
Functionmain
()
cmd/src/main.rs:24
Functionmain
()
api/src/main.rs:7
Functionmain
()
msg_server/src/main.rs:8
Functionmain
()
db/src/main.rs:7
Functionmain
()
db/src/benchmarks/benchmark_sharding.rs:38
Functionmanage_friend_tags
( State(app_state): State<AppState>, JsonWithAuthExtractor(req): JsonWithAuthExtractor<ManageFriendTag
api/src/handlers/friends/friend_handlers.rs:287
Methodmax_decoding_message_size
(mut self, limit: usize)
abi/src/pb/message.rs:1935
Methodmax_encoding_message_size
(mut self, limit: usize)
abi/src/pb/message.rs:1943
Functionmodify_pwd
( State(app_state): State<AppState>, JsonExtractor(mut req): JsonExtractor<ModifyPwdRequest>, )
api/src/handlers/users/user_handlers.rs:155
Functionmongodb_insert_and_batch_delete_and_get_should_works
()
db/src/mongodb/message.rs:378
Functionmongodb_insert_and_delete_and_get_works
()
db/src/mongodb/message.rs:339
Functionmongodb_insert_and_get_works
()
db/src/mongodb/message.rs:327
Functionmute_group_member
新增 - 群组禁言相关
api/src/handlers/groups/group_handlers.rs:438
Methodn
(channel: LbWithServiceDiscovery)
utils/src/client_factory.rs:11
Methodnew
(client: redis::Client)
cache/src/redis/mod.rs:41
Methodnew
创建新的任务集合
msg_gateway/src/ws_server.rs:99
Methodnew
(manager: Manager)
msg_gateway/src/rpc.rs:22
Methodnew
(tx: mpsc::Sender<Msg>, config: &Config)
msg_gateway/src/manager.rs:32
Methodnew
(service_center: Arc<dyn ServiceRegister>, service_name: String)
utils/src/lib.rs:116
Methodnew
( host: impl Into<String>, port: u16, user: impl Into<String>, password: impl
utils/src/mongodb_tester/mod.rs:15
Methodnew
( host: impl Into<String>, port: u16, user: impl Into<String>, password: impl
utils/src/sqlx_tester/mod.rs:17
Methodnew
( service_center: Fetcher, dis_interval: tokio::time::Duration, sender: mpsc::Sender<C
utils/src/service_discovery/tonic_service_discovery.rs:44
Methodnew
(group_id: String)
abi/src/types/group.rs:14
Methodnew
(user_id: String, group_id: String)
abi/src/types/msg.rs:276
Methodnew
( kind: ErrorKind, details: impl Into<String>, source: impl StdError + 'static + Send
abi/src/errors/mod.rs:54
Methodnew
(inner: T)
abi/src/pb/message.rs:1890
Methodnew
(config: &Config)
oss/src/client.rs:21
Methodnew
创建新的消息迁移器
cmd/src/migrate.rs:28
Methodnew
(config: &Config)
api/src/lib.rs:46
Methodnew
(sub: String)
api/src/handlers/users/mod.rs:72
Methodnew
( service_name: String, lb_type: impl Into<LoadBalanceStrategyType>, service_register:
api/src/api_utils/lb/mod.rs:29
Methodnew
()
api/src/api_utils/lb/strategy.rs:61
Methodnew
(kafka: FutureProducer, topic: String)
msg_server/src/productor.rs:24
Methodnew
(config: &Config)
msg_server/src/consumer.rs:33
Methodnew
(config: &Config)
msg_server/src/pusher/service.rs:29
Methodnew
(config: &Config)
db/src/lib.rs:36
Methodnew
创建新的混合分片消息存储
db/src/mongodb/sharded_message.rs:39
Methodnew
(db: Database)
db/src/mongodb/message.rs:35
Methodnew
(pool: PgPool)
db/src/postgres/group.rs:22
Methodnew
(pool: PgPool)
db/src/postgres/friend.rs:20
Methodnew
(pool: PgPool, init_max_seq: i32)
db/src/postgres/user.rs:17
Methodnew
(pool: PgPool, seq_step: i32)
db/src/postgres/seq.rs:17
Methodnew
(pool: PgPool)
db/src/postgres/message.rs:15
Methodnew_with_friend_del
(sender_id: String, receiver_id: String)
abi/src/types/msg.rs:53
Methodnew_with_friend_ship_req
( sender_id: String, receiver_id: String, fs: Vec<u8>, send_seq: i64, )
abi/src/types/msg.rs:65
Methodnew_with_friend_ship_resp
(receiver_id: String, fs: Vec<u8>, send_seq: i64)
abi/src/types/msg.rs:84
Methodnew_with_group_announcement
群组公告消息
abi/src/types/msg.rs:256
Methodnew_with_group_file
群组文件消息
abi/src/types/msg.rs:199
Methodnew_with_group_invitation
( sender_id: String, receiver_id: String, send_seq: i64, invitation: Vec<u8>,
abi/src/types/msg.rs:118
Methodnew_with_group_invite_new
( sender_id: String, receiver_id: String, send_seq: i64, invitation: Vec<u8>,
abi/src/types/msg.rs:138
Methodnew_with_group_mute
群组禁言消息
abi/src/types/msg.rs:237
← previousnext →301–400 of 492, ranked by callers