biz

Documentation

Index

• Constants
• Variables
• type Message
• type MessageRepo
• type MessageUseCase
  • func NewMessageUseCase(repo MessageRepo, logger log.Logger) *MessageUseCase
  • func (uc *MessageUseCase) GetMessageList(ctx context.Context, toUserId uint32, preMsgTime int64) ([]*Message, error)
  • func (uc *MessageUseCase) PublishMessage(ctx context.Context, toUserId uint32, actionType uint32, content string) error

Constants

const (
	PublishMessage = 1
)

Variables

var ErrInValidActionType = errors.New("invalid action type")

var ProviderSet = wire.NewSet(NewMessageUseCase)

ProviderSet is biz providers.

Types

type Message

type Message struct {
	Id         uint64
	ToUserId   uint32
	FromUserId uint32
	Content    string
	CreateTime int64
}

type MessageRepo

type MessageRepo interface {
	GetMessageList(context.Context, uint32, int64) ([]*Message, error)
	PublishMessage(context.Context, uint32, string) error
	InitStoreMessageQueue()
}

type MessageUseCase

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

func NewMessageUseCase

func NewMessageUseCase(repo MessageRepo, logger log.Logger) *MessageUseCase

func (*MessageUseCase) GetMessageList

func (uc *MessageUseCase) GetMessageList(
	ctx context.Context, toUserId uint32, preMsgTime int64,
) ([]*Message, error)

func (*MessageUseCase) PublishMessage

func (uc *MessageUseCase) PublishMessage(
	ctx context.Context, toUserId uint32, actionType uint32, content string,
) error