mvcc

type CommitHandler func(db.Writer) error

type Option func(*options)

type RowHandler func(Tx, db.Writer, fdb.KeyValue) error

type Tx interface {
	// Ссылка на подключение к БД, на всякий случай
	Conn() db.Connection

	// Неудачное завершение (отклонение) транзакции
	// Поддерживает опции Writer
	Cancel(args ...Option)

	// Успешное завершение (принятие) транзакции
	// Перед завершением выполняет хуки OnCommit
	// Поддерживает опции Writer
	Commit(args ...Option) error

	// Выборка актуального значения для ключа
	Select(fdb.Key, ...Option) (fdb.KeyValue, error)

	// Выборка нескольких объектов, в результате использовано печатное представление ключа
	SelectMany(keys []fdb.Key, args ...Option) (res map[string]fdb.KeyValue, err error)

	// Удаление значения для ключа
	// Поддерживает опции Writer
	Delete([]fdb.Key, ...Option) error

	// Вставка или обновление значения для ключа
	// Поддерживает опции Writer
	Upsert([]fdb.KeyValue, ...Option) error

	// Последовательная выборка всех активных ключей в диапазоне
	// Поддерживает опции From, To, Reverse, Limit, PackSize, Exclusive, Writer
	ListAll(context.Context, ...Option) ([]fdb.KeyValue, error)

	// Последовательная выборка всех активных ключей в диапазоне
	// Поддерживает опции From, To, Reverse, Limit, PackSize, Exclusive, Writer
	SeqScan(context.Context, ...Option) (<-chan fdb.KeyValue, <-chan error)

	// Загрузка бинарных данных по ключу, указывается ожидаемый размер
	LoadBLOB(fdb.Key, ...Option) ([]byte, error)

	// Удаление бинарных данных по ключу
	// Поддерживает опции Writer
	DropBLOB(fdb.Key, ...Option) error

	// Сохранение бинарных данных по ключу
	SaveBLOB(fdb.Key, []byte, ...Option) error

	// Блокировка записи с доступом на чтение по сигнальному ключу
	SharedLock(...fdb.Key) error

	// Немедленно освобождает блокировку всех ключей, указанных в SharedLock
	ReleaseLocks()

	// Регистрация хука для выполнения при удачном завершении транзакции
	OnCommit(CommitHandler)

	// Запуск очистки устаревших записей ключей по указанному префиксу
	Vacuum(fdb.Key, ...Option) error

	// Изменение сигнального ключа, чтобы сработали Watch
	// По сути, выставляет хук OnCommit с правильным содержимым
	Touch(fdb.Key)

	// Ожидание изменения сигнального ключа в Touch
	Watch(fdb.Key) (db.Waiter, error)
}

type TxHandler func(Tx) error