repository

Documentation

Index

• Variables
• type LogDao
  • func NewLogDao(db *gorm.DB) LogDao
• type Repository
  • func NewPgRepository(lg *zap.Logger, cfg config.PgConfig) Repository
• type TaskDao
  • func NewTaskDao(db *gorm.DB) TaskDao

Variables

var (
	ErrRecordNotFound = errors.New("record not found")
	ErrDuplicatedKey  = errors.New("duplicated key")
)

Types

type LogDao

type LogDao interface {
	InsertLogs(ctx context.Context, logs []do.Log) error
}

func NewLogDao

func NewLogDao(db *gorm.DB) LogDao

type Repository

type Repository interface {
	Transaction(fn func(Repository) error) error

	TaskDao() TaskDao
	LogDao() LogDao
}

func NewPgRepository

func NewPgRepository(lg *zap.Logger, cfg config.PgConfig) Repository

type TaskDao

type TaskDao interface {
	InsertTask(ctx context.Context, task do.Task) (do.Task, error)
	UpdateTask(ctx context.Context, task do.Task) (do.Task, error)
	GetTask(ctx context.Context, name string) (do.Task, error)
	GetTaskForUpdate(ctx context.Context, name string) (do.Task, error)
}

func NewTaskDao

func NewTaskDao(db *gorm.DB) TaskDao