task

Documentation

Index

• type Processor
  • func New(log *zap.Logger, taskRepo TaskRepo) *Processor
  • func (p *Processor) DeleteTask(ctx context.Context, db *sqlx.DB, id string) error
  • func (p *Processor) GetTask(ctx context.Context, db *sqlx.DB, id string) (*models.Task, error)
  • func (p *Processor) GetTaskWithMaterials(ctx context.Context, db *sqlx.DB, id string) (*models.TaskWithMaterials, error)
  • func (p *Processor) InsertTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
  • func (p *Processor) ListTask(ctx context.Context, db *sqlx.DB) ([]*models.Task, error)
  • func (p *Processor) UpdateTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
• type TaskProcessor
• type TaskRepo

Types

type Processor

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

func New

func New(log *zap.Logger, taskRepo TaskRepo) *Processor

func (*Processor) DeleteTask

func (p *Processor) DeleteTask(ctx context.Context, db *sqlx.DB, id string) error

func (*Processor) GetTask

func (p *Processor) GetTask(ctx context.Context, db *sqlx.DB, id string) (*models.Task, error)

func (*Processor) GetTaskWithMaterials

func (p *Processor) GetTaskWithMaterials(
	ctx context.Context,
	db *sqlx.DB,
	id string,
) (*models.TaskWithMaterials, error)

func (*Processor) InsertTask

func (p *Processor) InsertTask(ctx context.Context, db *sqlx.DB, task *models.Task) error

func (*Processor) ListTask

func (p *Processor) ListTask(ctx context.Context, db *sqlx.DB) ([]*models.Task, error)

func (*Processor) UpdateTask

func (p *Processor) UpdateTask(ctx context.Context, db *sqlx.DB, task *models.Task) error

type TaskProcessor

type TaskProcessor interface {
	InsertTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
	UpdateTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
	GetTask(ctx context.Context, db *sqlx.DB, id string) (*models.Task, error)
	GetTaskWithMaterials(ctx context.Context, db *sqlx.DB, id string) (*models.TaskWithMaterials, error)
	ListTask(ctx context.Context, db *sqlx.DB) ([]*models.Task, error)
	DeleteTask(ctx context.Context, db *sqlx.DB, id string) error
}

type TaskRepo

type TaskRepo interface {
	SaveTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
	UpdateTask(ctx context.Context, db *sqlx.DB, task *models.Task) error
	GetTask(ctx context.Context, db *sqlx.DB, id string) (*models.Task, error)
	GetTaskWithMaterials(ctx context.Context, db *sqlx.DB, id string) (*models.TaskWithMaterials, error)
	ListTask(ctx context.Context, db *sqlx.DB) ([]*models.Task, error)
	DeleteTask(ctx context.Context, db *sqlx.DB, id string) error
}