DynamoBatchRepository

class DynamoBatchRepository implements BatchRepository (View source)

Свойства

protected BatchFactory	$factory	Экземпляр фабрики задач.
protected DynamoDbClient	$dynamoDbClient	Экземпляр подключения к базе данных.
protected string	$applicationName	Имя приложения.
protected string	$table	Таблица для хранения информации о задачах.
protected int	$ttl	Значение времени жизни записей о задачах.
protected string	$ttlAttribute	Имя атрибута времени жизни для записей о задачах.
protected Marshaler	$marshaler	Экземпляр маршалера DynamoDB.

Методы

__construct(BatchFactory $factory, DynamoDbClient $dynamoDbClient, string $applicationName, string $table, int|null $ttl, string|null $ttlAttribute)

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

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)

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

void

markAsFinished(string $batchId)

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

void

cancel(string $batchId)

Отменить партию с заданным ID.

void

delete(string $batchId)

Удалить партию с заданным ID.

mixed

transaction(Closure $callback)

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

void

rollBack()

Откатить последнюю базу данных транзакцию для подключения.

Batch

toBatch(object $batch)

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

void

createAwsDynamoTable()

Создать базу данных DynamoDB таблицу.

void

deleteAwsDynamoTable()

Удалить базу данных DynamoDB таблицу.

string|null

getExpiryTime()

Получить время истечения срока действия на основе настроенного времени жизни.

array

ttlExpressionAttributeName()

Получить имя атрибута выражения для атрибута времени жизни.

string

serialize(mixed $value)

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

mixed

unserialize(string $serialized)

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

DynamoDbClient

getDynamoClient()

Получить базу данных DynamoDB экземпляр клиента.

string

getTable()

Имя таблицы, содержащей записи о партиях.

Подробности

__construct(BatchFactory $factory, DynamoDbClient $dynamoDbClient, string $applicationName, string $table, int|null $ttl, string|null $ttlAttribute)

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

Параметры

BatchFactory	$factory
DynamoDbClient	$dynamoDbClient
строка	$applicationName
строка	$table
int\|null	$ttl
строка\|null	$ttlAttribute

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

Получить список пакетных задач.

Параметры

int	$limit
mixed	$before

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

Batch[]

Batch|null find(string $batchId)

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

Параметры

строка

$batchId

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

Batch|null

Batch store(PendingBatch $batch)

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

Параметры

PendingBatch

$batch

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

Batch

void incrementTotalJobs(string $batchId, int $amount)

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

Параметры

строка	$batchId
int	$amount

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

void

UpdatedBatchJobCounts decrementPendingJobs(string $batchId, string $jobId)

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

Параметры

строка	$batchId
строка	$jobId

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

UpdatedBatchJobCounts

UpdatedBatchJobCounts incrementFailedJobs(string $batchId, string $jobId)

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

Параметры

строка	$batchId
строка	$jobId

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

UpdatedBatchJobCounts

void markAsFinished(string $batchId)

Отметить пакет с заданным ID как завершенный.

Параметры

строка

$batchId

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

void

void cancel(string $batchId)

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

Параметры

string

$batchId

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

void

void delete(string $batchId)

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

Параметры

string

$batchId

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

void

mixed transaction(Closure $callback)

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

Параметры

Closure

$callback

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

mixed

void rollBack()

Отменить последнюю базу данных транзакцию для подключения.

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

void

protected Batch toBatch(object $batch)

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

Параметры

object

$batch

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

Batch

void createAwsDynamoTable()

Создать базу данных DynamoDB.

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

void

void deleteAwsDynamoTable()

Удалить базу данных DynamoDB.

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

void

protected string|null getExpiryTime()

Получить время истечения срока действия на основе настроенного времени жизни.

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

string|null

protected array ttlExpressionAttributeName()

Получить имя атрибута выражения для атрибута времени жизни.

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

array

protected string serialize(mixed $value)

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

Параметры

mixed

$value

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

string

protected mixed unserialize(string $serialized)

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

Параметры

string

$serialized

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

mixed

DynamoDbClient getDynamoClient()

Получить экземпляр подчинённого клиента DynamoDB.

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

DynamoDbClient

string getTable()

Имя таблицы, содержащей записи пакетной обработки.

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

string

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