queue

type Message struct {
	Id          int
	CreatedAt   time.Time
	Name        string
	Payload     string
	IsProcessed bool
	ProcessedAt *time.Time
	IsSuccess   *bool
	Error       *string
}

type MessageHandler func(tx *sql.Tx, message *Message) error

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

type QueueQueryConfig struct {
	TableName        string
	IdField          string
	CreatedAtField   string
	NameField        string
	PayloadField     string
	IsProcessedField string
	ProcessedAtField string
	IsSuccessField   string
	ErrorField       string
}

type QueueRepository interface {
	FindNext(tx *sql.Tx) (*Message, error)
	Create(tx *sql.Tx, task *Message) error
	Save(tx *sql.Tx, task *Message) error
	DeleteOld(tx *sql.Tx, t time.Time) (int, error)
}

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

type WorkerConfig struct {
	Log        *slog.Logger
	Repository QueueRepository
	Cron       string
	Handler    MessageHandler
}