DatabaseBatchRepository

класс DatabaseBatchRepository реализует PrunableBatchRepository (Просмотреть исходный код)

Свойства

protected BatchFactory	$factory	Экземпляр фабрики задач.
protected Connection	$connection	Экземпляр подключения к базе данных.
protected string	$table	Таблица базы данных для хранения информации о задачах.

Методы

__construct(BatchFactory $factory, Connection $connection, string $table)

Создать новый экземпляр хранилища задач.

Batch[]

get(int $limit = 50, mixed $before = null)

Получить список задач.

Batch|null

find(string $batchId)

Получить информацию о существующей задаче.

Batch

store(PendingBatch $batch)

Сохранить новую ожидающую задачу.

void

incrementTotalJobs(string $batchId, int $amount)

Увеличить общее количество задач в задаче.

UpdatedBatchJobCounts

decrementPendingJobs(string $batchId, string $jobId)

Уменьшить общее количество ожидающих задач для задачи.

UpdatedBatchJobCounts

incrementFailedJobs(string $batchId, string $jobId)

Увеличить общее количество завершенных с ошибкой задач для задачи.

int|null

updateAtomicValues(string $batchId, Closure $callback)

Обновить атомарное значение в задаче.

void

markAsFinished(string $batchId)

Отметить задачу с заданным идентификатором как завершенную.

void

cancel(string $batchId)

Отменить задачу с заданным идентификатором.

void

delete(string $batchId)

Удалить задачу с заданным идентификатором.

int

prune(DateTimeInterface $before)

Удалить все записи, более старые, чем указанная дата.

int

pruneUnfinished(DateTimeInterface $before)

Удалить все незавершенные записи, более старые, чем указанная дата.

mixed

transaction(Closure $callback)

Выполнить заданный замыкание в хранилище в рамках транзакции.

string

serialize(mixed $value)

Сериализовать заданное значение.

mixed

unserialize(string $serialized)

Десериализовать заданное значение.

Batch

toBatch(object $batch)

Преобразовать заданную исходную задачу в объект Batch.

Подробности

__construct(BatchFactory $factory, Connection $connection, string $table)

Создать новый экземпляр хранилища задач.

Параметры

BatchFactory	$factory
Connection	$connection
string	$table

Пачка[] get(int $limit = 50, mixed $before = null)

Получить список пачек.

Параметры

int	$limit
mixed	$before

Значение возврата

Пачка[]

Пачка|null find(string $batchId)

Получить информацию о существующей пачке.

Параметры

string

$batchId

Значение возврата

Пачка|null

Пачка store(ОжидающаяПачка $batch)

Сохранить новую ожидающую пачку.

Параметры

ОжидающаяПачка

$batch

Значение возврата

Пачка

void incrementTotalJobs(string $batchId, int $amount)

Увеличить общее количество задач в пачке.

Параметры

string	$batchId
int	$amount

Значение возврата

void

ОбновленныеСчетчикиЗадачПачки decrementPendingJobs(string $batchId, string $jobId)

Уменьшить общее количество ожидающих задач для пачки.

Параметры

string	$batchId
string	$jobId

Значение возврата

ОбновленныеСчетчикиЗадачПачки

ОбновленныеСчетчикиЗадачПачки incrementFailedJobs(string $batchId, string $jobId)

Увеличить общее количество завершившихся с ошибкой задач для пачки.

Параметры

string	$batchId
string	$jobId

Значение возврата

ОбновленныеСчетчикиЗадачПачки

protected int|null updateAtomicValues(string $batchId, Closure $callback)

Обновить атомарное значение в пачке.

Параметры

string	$batchId
Closure	$callback

Значение возврата

int|null

void markAsFinished(string $batchId)

Отметить пачку с заданным идентификатором как завершенную.

Параметры

string

$batchId

Значение возврата

void

void cancel(string $batchId)

Отменить пачку с заданным идентификатором.

Параметры

string

$batchId

Значение возврата

void

void delete(string $batchId)

Удалить пакет с заданным ID.

Параметры

string

$batchId

Возвращаемое значение

void

int prune(DateTimeInterface $before)

Удалить все записи, более старые, чем указанная дата.

Параметры

DateTimeInterface

$before

Возвращаемое значение

int

int pruneUnfinished(DateTimeInterface $before)

Удалить все незавершенные записи, более старые, чем указанная дата.

Параметры

DateTimeInterface

$before

Возвращаемое значение

int

mixed transaction(Closure $callback)

Выполнить заданный Closure в рамках транзакции, специфичной для хранилища.

Параметры

Closure

$callback

Возвращаемое значение

mixed

protected string serialize(mixed $value)

Сериализовать заданное значение.

Параметры

mixed

$value

Возвращаемое значение

string

protected mixed unserialize(string $serialized)

Десериализовать заданное значение.

Параметры

string

$serialized

Возвращаемое значение

mixed

protected Batch toBatch(object $batch)

Преобразовать заданный необработанный пакет в объект Batch.

Параметры

object

$batch

Возвращаемое значение

Batch

© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/8.x/Illuminate/Bus/DatabaseBatchRepository.html