rpc

package
v0.0.0-...-b25a406 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2026 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AcceptFriend 

func AcceptFriend(ctx context.Context, userID, applicantID int64) error

AcceptFriend 接受好友申请

func ApplyFriend 

func ApplyFriend(ctx context.Context, userID, targetID int64, remark *string) error

ApplyFriend 发送好友申请

func BanMember 

func BanMember(ctx context.Context, operatorID, groupID, targetID int64, bannedUntil *int64) error

BanMember 禁言成员。bannedUntil=nil 或 0 表示永久禁言

func BlockFriend 

func BlockFriend(ctx context.Context, userID, targetID int64) error

BlockFriend 拉黑

func CancelSchedule 

func CancelSchedule(ctx context.Context, req *kmeeting.CancelScheduleRequest) error

CancelSchedule 取消预约会议

func CreateGroup 

func CreateGroup(ctx context.Context, userID int64, name, notice string) (*kmodel.GroupInfo, error)

CreateGroup 创建群组

func DeleteFriend 

func DeleteFriend(ctx context.Context, userID, friendID int64) error

DeleteFriend 删除好友

func DismissGroup 

func DismissGroup(ctx context.Context, operatorID, groupID int64) error

DismissGroup 解散群（仅群主）

func EndMeeting 

func EndMeeting(ctx context.Context, req *kmeeting.EndMeetingRequest) error

EndMeeting 结束会议

func GetApplyList 

func GetApplyList(ctx context.Context, userID int64, page, pageSize *int32) ([]*kmodel.FriendApplyItem, int64, error)

GetApplyList 获取申请列表

func GetBlockList 

func GetBlockList(ctx context.Context, userID int64, page, pageSize *int32) ([]*kmodel.FriendBlockItem, int64, error)

GetBlockList 获取黑名单列表

func GetConversationList 

func GetConversationList(ctx context.Context, userID int64, page, pageSize int32) ([]*kmodel.ConversationInfo, int64, error)

GetConversationList 获取用户会话列表

func GetFriendList 

func GetFriendList(ctx context.Context, userID int64, page, pageSize *int32) ([]*kmodel.FriendItem, int64, error)

GetFriendList 获取好友列表

func GetGroupInfo 

func GetGroupInfo(ctx context.Context, groupID int64) (*kmodel.GroupInfo, error)

GetGroupInfo 获取群基本信息

func GetGroupMemberList 

func GetGroupMemberList(ctx context.Context, groupID int64, page, pageSize int32) ([]*kmodel.GroupMemberInfo, int64, error)

GetGroupMemberList 获取群成员列表（分页）

func GetHelperTrace 

func GetHelperTrace(ctx context.Context, userID, sessionID int64) (*khelper.TraceInfo, error)

func GetMeetingDetail 

func GetMeetingDetail(ctx context.Context, req *kmeeting.GetMeetingDetailRequest) (*kmeeting.GetMeetingDetailResponse, error)

GetMeetingDetail 获取会议详情

func GetMessageList 

func GetMessageList(ctx context.Context, userID, peerID int64, peerType int8, cursor *int64, limit *int32) ([]*kmodel.Message, bool, error)

GetMessageList 获取会话消息列表（游标分页）

func GetMyMeetingList 

func GetMyMeetingList(ctx context.Context, req *kmeeting.GetMyMeetingListRequest) (*kmeeting.GetMyMeetingListResponse, error)

GetMyMeetingList 获取我的会议列表

func GetRecordingList 

func GetRecordingList(ctx context.Context, req *kmeeting.GetRecordingListRequest) (*kmeeting.GetRecordingListResponse, error)

GetRecordingList 获取录制列表

func GetScheduleList 

func GetScheduleList(ctx context.Context, req *kmeeting.GetScheduleListRequest) (*kmeeting.GetScheduleListResponse, error)

GetScheduleList 获取预约会议列表

func GetUserClient 

func GetUserClient() userservice.Client

GetUserClient 获取用户服务客户端

func GetUserGroups 

func GetUserGroups(ctx context.Context, userID int64, page, pageSize int32) ([]*kmodel.GroupInfo, int64, error)

GetUserGroups 获取用户加入的群列表

func GetUserInfo 

func GetUserInfo(ctx context.Context, req *user.GetUserInfoReq) (*rpc_model.UserInfo, error)

GetUserInfo 获取用户信息

func Init 

func Init()

func InitFriendClient 

func InitFriendClient()

func InitGroupClient 

func InitGroupClient()

func InitHelperClient 

func InitHelperClient()

func InitMeetingClient 

func InitMeetingClient()

func InitMessageClient 

func InitMessageClient()

func InitUserClient 

func InitUserClient()

InitUserClient 初始化用户服务客户端

func JoinGroup 

func JoinGroup(ctx context.Context, userID, groupID int64) error

JoinGroup 加入群组

func JoinMeeting 

func JoinMeeting(ctx context.Context, req *kmeeting.JoinMeetingRequest) (*kmeeting.JoinMeetingResponse, error)

JoinMeeting 加入或创建会议，返回 LiveKit token 及房间信息

func LeaveGroup 

func LeaveGroup(ctx context.Context, userID, groupID int64) error

LeaveGroup 退出群组

func Login 

func Login(ctx context.Context, req *user.LoginRequest) (*rpc_model.UserInfo, error)

Login 登录，返回用户信息

func Logout 

func Logout(ctx context.Context, req *user.LogoutReq) error

Logout 登出，删除 Redis 中的 RefreshToken

func MarkRead 

func MarkRead(ctx context.Context, userID, peerID int64, peerType int8, lastMsgID int64) error

MarkRead 标记会话已读

func RecallMessage 

func RecallMessage(ctx context.Context, userID, msgID int64) error

RecallMessage 撤回消息

func Register 

func Register(ctx context.Context, req *user.RegisterRequest) (int64, error)

Register 注册用户，返回新用户 ID

func RejectFriend 

func RejectFriend(ctx context.Context, userID, applicantID int64) error

RejectFriend 拒绝好友申请

func RemoveMember 

func RemoveMember(ctx context.Context, operatorID, groupID, targetID int64) error

RemoveMember 移除群成员

func RotateRefreshToken 

func RotateRefreshToken(ctx context.Context, req *user.RotateRefreshTokenReq) error

RotateRefreshToken 校验 RefreshToken 并重置 TTL（刷新时调用，token 值不变）

func ScheduleMeeting 

func ScheduleMeeting(ctx context.Context, req *kmeeting.ScheduleMeetingRequest) (*kmeeting.ScheduleMeetingResponse, error)

ScheduleMeeting 预约会议

func SearchGroups 

func SearchGroups(ctx context.Context, req *kgroup.SearchGroupsRequest) ([]*kmodel.GroupInfo, int64, error)

SearchGroups 按群名关键词模糊搜索群组

func SearchUsers 

func SearchUsers(ctx context.Context, req *user.SearchUsersReq) ([]*rpc_model.UserInfo, int64, error)

SearchUsers 按用户名关键词模糊搜索用户

func SetAvatar 

func SetAvatar(ctx context.Context, req *user.SetAvatarReq) error

SetAvatar 更新用户头像 URL

func SetMemberRole 

func SetMemberRole(ctx context.Context, operatorID, groupID, targetID int64, role int8) error

SetMemberRole 设置成员角色（仅群主可操作）

func SetUserInfo 

func SetUserInfo(ctx context.Context, req *user.SetUserInfoReq) error

SetUserInfo 更新用户信息

func StartRecording 

func StartRecording(ctx context.Context, req *kmeeting.StartRecordingRequest) (*kmeeting.StartRecordingResponse, error)

StartRecording 开始录制（LiveKit Egress 启动较慢，使用更长超时）

func StopRecording 

func StopRecording(ctx context.Context, req *kmeeting.StopRecordingRequest) error

StopRecording 停止录制

func StoreRefreshToken 

func StoreRefreshToken(ctx context.Context, req *user.StoreRefreshTokenReq) error

StoreRefreshToken 登录/注册成功后将 RefreshToken JWT 存入 Redis

func TransferOwner 

func TransferOwner(ctx context.Context, operatorID, groupID, newOwnerID int64) error

TransferOwner 转让群主

func UnbanMember 

func UnbanMember(ctx context.Context, operatorID, groupID, targetID int64) error

UnbanMember 解除禁言

func UnblockFriend 

func UnblockFriend(ctx context.Context, userID, targetID int64) error

UnblockFriend 解除拉黑

func UpdateGroup 

func UpdateGroup(ctx context.Context, operatorID, groupID int64, name, notice *string) error

UpdateGroup 修改群名称或公告

func UpdateMeetingStatus 

func UpdateMeetingStatus(ctx context.Context, req *kmeeting.UpdateMeetingStatusRequest) error

UpdateMeetingStatus 更新会议状态（Webhook 内部调用）

func UpdateMemberLeftAt 

func UpdateMemberLeftAt(ctx context.Context, req *kmeeting.UpdateMemberLeftAtRequest) error

UpdateMemberLeftAt 更新成员离开时间（Webhook 内部调用）

func UpdatePeerProfile 

func UpdatePeerProfile(ctx context.Context, peerID int64, name, avatar *string) error

UpdatePeerProfile 用户更新个人信息后同步 conversations 表冗余字段

func UpdateRecordingStatus 

func UpdateRecordingStatus(ctx context.Context, req *kmeeting.UpdateRecordingStatusRequest) error

UpdateRecordingStatus 更新录制状态（Webhook 内部调用）

func ViewFlashMessage 

func ViewFlashMessage(ctx context.Context, userID, msgID int64) (*kmessage.ViewFlashMessageResponse, error)

ViewFlashMessage 查看闪讯，返回消息内容（只能查看一次）

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.