queue

type Message struct {
	Id          int
	Queue       *string
	CreatedTs   time.Time
	Payload     string
	IsProcessed bool
	ProcessedTs *time.Time
	IsSuccess   *bool
	Error       *string
}

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

type MessageQueryConfig struct {
	TableName        string
	IdField          string
	QueueField       string
	CreatedTsField   string
	PayloadField     string
	IsProcessedField string
	ProcessedTsField string
	IsSuccessField   string
	ErrorField       string
}

type MessageRepository interface {
	FindNext(tx *sql.Tx) (*Message, error)
	Create(tx *sql.Tx, m *Message) error
	Save(tx *sql.Tx, m *Message) error
	DeleteProcessed(tx *sql.Tx, t time.Time) (int, error)
}

type PostgresMessageRepository struct {
	Config *MessageQueryConfig
}

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

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