dao

Documentation

Index

• type MysqlManagerImpl
  • func NewMysqlManager(db *gorm.DB) *MysqlManagerImpl
  • func (m *MysqlManagerImpl) CreateChatMessage(ctx context.Context, chatMessage *model.ChatMessage) error
• type RedisManagerImpl
  • func NewRedisManager(redis *redis.Client) *RedisManagerImpl
  • func (r *RedisManagerImpl) CheckRoomExists(ctx context.Context, roomId int64) (bool, error)
  • func (r *RedisManagerImpl) SendMessage(ctx context.Context, request *chat.ChatMessage) (err error)

Types

type MysqlManagerImpl

type MysqlManagerImpl struct {
	// contains filtered or unexported fields
}

func NewMysqlManager

func NewMysqlManager(db *gorm.DB) *MysqlManagerImpl

func (*MysqlManagerImpl) CreateChatMessage

func (m *MysqlManagerImpl) CreateChatMessage(ctx context.Context, chatMessage *model.ChatMessage) error

type RedisManagerImpl

type RedisManagerImpl struct {
	// contains filtered or unexported fields
}

func NewRedisManager

func NewRedisManager(redis *redis.Client) *RedisManagerImpl

func (*RedisManagerImpl) CheckRoomExists

func (r *RedisManagerImpl) CheckRoomExists(ctx context.Context, roomId int64) (bool, error)

func (*RedisManagerImpl) SendMessage

func (r *RedisManagerImpl) SendMessage(ctx context.Context, request *chat.ChatMessage) (err error)

使用公共的 InternalMessage 结构体作为消息的载体，便于转换。