postgres

Documentation

Index

• type Repository
  • func NewRepository(db *sqlx.DB) *Repository
  • func (r *Repository) CreateProcessedImageDetail(ctx context.Context, detail *model.ProcessedImage) (*model.ProcessedImage, error)
  • func (r *Repository) CreateTask(ctx context.Context, task *model.ImageProcessingTask) (*model.ImageProcessingTask, error)
  • func (r *Repository) GetPendingTasks(ctx context.Context, limit int) ([]model.ImageProcessingTask, error)
  • func (r *Repository) GetTaskByID(ctx context.Context, id int64) (*model.ImageProcessingTask, error)
  • func (r *Repository) UpdateTaskStatus(ctx context.Context, id int64, status model.TaskStatus, errorMessage string) error

Types

type Repository

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

func NewRepository

func NewRepository(db *sqlx.DB) *Repository

func (*Repository) CreateProcessedImageDetail

func (r *Repository) CreateProcessedImageDetail(ctx context.Context, detail *model.ProcessedImage) (*model.ProcessedImage, error)

func (*Repository) CreateTask

func (r *Repository) CreateTask(ctx context.Context, task *model.ImageProcessingTask) (*model.ImageProcessingTask, error)

func (*Repository) GetPendingTasks

func (r *Repository) GetPendingTasks(ctx context.Context, limit int) ([]model.ImageProcessingTask, error)

func (*Repository) GetTaskByID

func (r *Repository) GetTaskByID(ctx context.Context, id int64) (*model.ImageProcessingTask, error)

func (*Repository) UpdateTaskStatus

func (r *Repository) UpdateTaskStatus(ctx context.Context, id int64, status model.TaskStatus, errorMessage string) error