mysql

package

v0.0.0-...-bd14a77 Latest Latest Go to latest Published: Mar 7, 2023 License: MIT Imports: 9 Imported by: 0

Details

View Source

const (
	//ProductKafkaTopic ...
	ProductKafkaTopic = "yuuxxq8y-product"

	//TaskKafkaTopic ...
	TaskKafkaTopic = "yuuxxq8y-task"
)

This section is empty.

This section is empty.

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

ProductMySQLRepo ...

func NewProductMySQLRepo(
	db *infra.ConnPool,
) *ProductMySQLRepo

NewProductMySQLRepo ...

func (p *ProductMySQLRepo) Create(ctx context.Context, data *entities_pb.ProductInfo) (productDAO *repo.ProductModel, err error)

Create ...

func (p *ProductMySQLRepo) Find(ctx context.Context, id int) (productDAO *repo.ProductModel, err error)

Find ...

func (p *ProductMySQLRepo) Get(ctx context.Context, limit int, page int, ids []uint64) (productDAO []*repo.ProductModel, err error)

Get ...

func (p *ProductMySQLRepo) Update(ctx context.Context, product *repo.ProductModel) (err error)

Update ...

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

TaskMySQLRepo ...

func NewTaskMySQLRepo(
	db *infra.ConnPool,
) *TaskMySQLRepo

NewTaskMySQLRepo ...

func (t *TaskMySQLRepo) Create(ctx context.Context, data *entities_pb.TaskInfo) (taskDAO *repo.TaskModel, err error)

Create Task

func (t *TaskMySQLRepo) Find(ctx context.Context, id int) (taskDAO *repo.TaskModel, err error)

Find ...

func (t *TaskMySQLRepo) Get(ctx context.Context, limit int, page int, ids []uint64) (taskDAO []*repo.TaskModel, err error)

Get Task

func (t *TaskMySQLRepo) Update(ctx context.Context, task *repo.TaskModel) (err error)

Update Task