repo

Documentation

Index

• Variables
• func CloseDB()
• func CloseRedis()
• func InitDB(host string) (*gorm.DB, error)
• func InitRedis(host string) (*redis.Client, error)
• func NewGroupService(userAddr string) (*groupService, error)
• type GroupAvatarSet
• type GroupInfo
• type GroupMember
• type GroupRedis
  • func NewGroupRedis(r *redis.Client) GroupRedis
• type GroupRepo
  • func NewGroupRepo(db *gorm.DB, m *groupService) GroupRepo
• type GroupServiceServer
  • func NewGroupServiceServer(r GroupRepo) *GroupServiceServer
  • func (s GroupServiceServer) ListGroupInfos(ctx context.Context, req *grouppb.ListGroupInfosRequest) (*grouppb.ListGroupInfosResponse, error)
  • func (s *GroupServiceServer) ListGroupMembers(ctx context.Context, req *grouppb.ListGroupMembersRequest) (*grouppb.ListGroupMembersResponse, error)
• type UserInfo

Variables

var DB *gorm.DB

var ErrInvalidGroup = errors.New("invalid group")

var RDB *redis.Client

Functions

func CloseDB

func CloseDB()

CloseDB 关闭数据库连接

func CloseRedis

func CloseRedis()

CloseRedis 关闭 Redis 客户端连接

func InitDB

func InitDB(host string) (*gorm.DB, error)

InitDB 初始化数据库连接，接收动态 host 参数

func InitRedis

func InitRedis(host string) (*redis.Client, error)

InitRedis 初始化 Redis 客户端，接收动态 host 参数

func NewGroupService

func NewGroupService(userAddr string) (*groupService, error)

Types

type GroupAvatarSet

type GroupAvatarSet struct {
	GroupId  uuid.UUID
	UserInfo []*UserInfo
}

type GroupInfo

type GroupInfo struct {
	GroupID   uuid.UUID `gorm:"column:id"`
	GroupName string    `gorm:"column:name"`
	Avatar    string    `gorm:"column:avatar"`
}

type GroupMember

type GroupMember struct {
	UserID   int64
	Role     model.GroupRole
	Nickname string
	JoinTime time.Time
}

type GroupRedis

type GroupRedis interface {
}

func NewGroupRedis

func NewGroupRedis(r *redis.Client) GroupRedis

type GroupRepo

type GroupRepo interface {
	CreateGroup(ctx context.Context, ownerID int64, userIDs []int64, groupName string) (groupID uuid.UUID, err error)
	AddGroupMember(ctx context.Context, groupID uuid.UUID, userIDs []int64) error // 可进一步拓展
	KickOutGroupMember(ctx context.Context, groupID uuid.UUID, executorID int64, userIDs []int64) error
	PromoteToAdmin(ctx context.Context, groupID uuid.UUID, executorID int64, userID int64) error
	TransferGroupOwner(ctx context.Context, groupID uuid.UUID, executorID int64, userID int64) error
	DemotedToMember(ctx context.Context, groupID uuid.UUID, executorID int64, userID int64) error
	UpdateNotice(ctx context.Context, groupID uuid.UUID, executorID int64, newNoticeText string) error
	GetNotice(ctx context.Context, groupID uuid.UUID) (string, error)
	UpdateGroupName(ctx context.Context, groupID uuid.UUID, executorID int64, newGroupName string) error
	GetGroupName(ctx context.Context, groupID uuid.UUID) (string, error)
	GetGroupAvatar(ctx context.Context, groupID uuid.UUID) (*GroupAvatarSet, error)
	GetGroupInfos(ctx context.Context, groupID uuid.UUIDs) ([]*GroupInfo, error)
	UpdateSelfName(ctx context.Context, groupID uuid.UUID, userID int64, newName string) error
	GetGroupMembers(ctx context.Context, groupID uuid.UUID) ([]GroupMember, error)
}

func NewGroupRepo

func NewGroupRepo(db *gorm.DB, m *groupService) GroupRepo

type GroupServiceServer

type GroupServiceServer struct {
	grouppb.UnimplementedGroupServiceServer
	// contains filtered or unexported fields
}

func NewGroupServiceServer

func NewGroupServiceServer(r GroupRepo) *GroupServiceServer

func (GroupServiceServer) ListGroupInfos

func (s GroupServiceServer) ListGroupInfos(ctx context.Context, req *grouppb.ListGroupInfosRequest) (
	*grouppb.ListGroupInfosResponse, error,
)

func (*GroupServiceServer) ListGroupMembers

func (s *GroupServiceServer) ListGroupMembers(ctx context.Context, req *grouppb.ListGroupMembersRequest,
) (*grouppb.ListGroupMembersResponse, error)

for grpc

type UserInfo

type UserInfo struct {
	UserID   int64  `json:"user_id"`
	Nickname string `json:"nickname"`
	Avatar   string `json:"avatar"`
}