dao

Documentation

Index

• Variables
• type DAO
  • func New() DAO

Variables

var ErrQueueTypeDup = errors.ConflictError(nil).WithMessage("duplicated queue type")

ErrQueueTypeDup ...

Types

type DAO

type DAO interface {
	// Query query queue status
	Query(ctx context.Context, query *q.Query) ([]*model.JobQueueStatus, error)
	// GetByJobType get queue status by JobType
	GetByJobType(ctx context.Context, jobType string) (*model.JobQueueStatus, error)
	// UpdateStatus update queue status
	UpdateStatus(ctx context.Context, jobType string, paused bool) error
	// InsertOrUpdate create a queue status or update it if it already exists
	InsertOrUpdate(ctx context.Context, queue *model.JobQueueStatus) (int64, error)
}

DAO the dao for queue status

func New

func New() DAO

New create queue status DAO