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)

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

void

cancel(string $batchId)

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

void

delete(string $batchId)

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

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)

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

Parameters

BatchFactory	$factory
DynamoDbClient	$dynamoDbClient
string	$applicationName
string	$table
int\|null	$ttl
string\|null	$ttlAttribute

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

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

Parameters

int	$limit
mixed	$before

Return Value

Batch[]

Batch|null find(string $batchId)

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

Parameters

string

$batchId

Return Value

Batch|null

Batch store(PendingBatch $batch)

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

Parameters

PendingBatch

$batch

Return Value

Batch

void incrementTotalJobs(string $batchId, int $amount)

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

Parameters

string	$batchId
int	$amount

Return Value

void

UpdatedBatchJobCounts decrementPendingJobs(string $batchId, string $jobId)

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

Parameters

string	$batchId
string	$jobId

Return Value

UpdatedBatchJobCounts

UpdatedBatchJobCounts incrementFailedJobs(string $batchId, string $jobId)

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

Parameters

string	$batchId
string	$jobId

Return Value

UpdatedBatchJobCounts

void markAsFinished(string $batchId)

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

Parameters

string

$batchId

Return Value

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/11.x/Illuminate/Bus/DynamoBatchRepository.html