queue

type Message struct {
	Id        int
	CreatedAt time.Time
	Payload   any
}

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
	PayloadField   string
}

type QueueRepository interface {
	FindNext(tx *sql.Tx) (*Message, error)
	Create(tx *sql.Tx, message *Message) error
	Delete(tx *sql.Tx, message *Message) error
}

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

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