domain

Documentation

Index

• type Demo
  • func NewDemo(logger *zap.Logger, database db_nosql.Database, mq miface.MessageQueue, ...) *Demo
  • func (d *Demo) Hi(uid, topic, message string) error
  • func (d *Demo) Watch(ctx context.Context, topic string, callback func(message string) error) error

Types

type Demo

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

func NewDemo

func NewDemo(
	logger *zap.Logger,
	database db_nosql.Database,
	mq miface.MessageQueue,
	gormDb *gorm.DB,
	redis *redis.Client,
) *Demo

func (*Demo) Hi

func (d *Demo) Hi(uid, topic, message string) error

func (*Demo) Watch

func (d *Demo) Watch(ctx context.Context, topic string, callback func(message string) error) error