service

Documentation

Index

• type MessageService
  • func NewMessageService(params MessageSrv) MessageService
• type MessageSrv
  • func (srv *MessageSrv) Consume(ctx context.Context)
  • func (srv *MessageSrv) CreateLogByMessage(ctx context.Context, message string) (err error)

Types

type MessageService

type MessageService interface {
	Consume(ctx context.Context)
	CreateLogByMessage(ctx context.Context, message string) (err error)
}

func NewMessageService

func NewMessageService(params MessageSrv) MessageService

type MessageSrv

type MessageSrv struct {
	Repo    repository.MessageRepository
	RepoLog logRepo.LogRepository
	Cfg     *configs.Configs
	Logger  *logrus.Logger
}

func (*MessageSrv) Consume

func (srv *MessageSrv) Consume(ctx context.Context)

func (*MessageSrv) CreateLogByMessage

func (srv *MessageSrv) CreateLogByMessage(ctx context.Context, message string) (err error)