Class StorageStatisticRepository

java.lang.Object

com.cotani.statistics.storage.StorageStatisticRepository

All Implemented Interfaces:

StatisticRepository

public final class StorageStatisticRepository
extends Object
implements StatisticRepository

SQL-backed repository for atomic, idempotent, non-negative player statistics.

Constructor Summary

Constructors

Constructor	Description
StorageStatisticRepository(com.cotani.storage.api.CotaniStorage storage)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Optional<StatisticEntry>>	findAsync(UUID playerId, StatisticId statisticId)	Loads one statistic; absence means the player has not recorded it yet.
CompletionStage<StatisticUpdate>	incrementAsync(UUID playerId, StatisticId statisticId, long amount, Instant updatedAt)	Atomically increments a statistic and returns the exact previous and current values.
CompletionStage<StatisticUpdate>	incrementIdempotentlyAsync(UUID playerId, StatisticId statisticId, long amount, Instant updatedAt, StatisticOperationId operationId)	Atomically increments a statistic with a durable idempotency key.
static List<com.cotani.storage.migration.Migration>	migrations()
CompletionStage<List<StatisticRankEntry>>	topAsync(StatisticId statisticId, int limit)	Returns a deterministic, value-descending ranking limited by the caller.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StorageStatisticRepository

public StorageStatisticRepository(com.cotani.storage.api.CotaniStorage storage)

Method Details

findAsync

public CompletionStage<Optional<StatisticEntry>> findAsync(UUID playerId,
 StatisticId statisticId)

Description copied from interface: StatisticRepository

Loads one statistic; absence means the player has not recorded it yet.

Specified by:

findAsync in interface StatisticRepository

incrementAsync

public CompletionStage<StatisticUpdate> incrementAsync(UUID playerId,
 StatisticId statisticId,
 long amount,
 Instant updatedAt)

Description copied from interface: StatisticRepository

Atomically increments a statistic and returns the exact previous and current values.

Specified by:

incrementAsync in interface StatisticRepository

incrementIdempotentlyAsync

public CompletionStage<StatisticUpdate> incrementIdempotentlyAsync(UUID playerId,
 StatisticId statisticId,
 long amount,
 Instant updatedAt,
 StatisticOperationId operationId)

Description copied from interface: StatisticRepository

Atomically increments a statistic with a durable idempotency key.

Implementations must persist the idempotency result with the increment and return StatisticUpdate.newlyApplied() as false when the same logical operation is replayed. Repositories without idempotency support must reject this operation.

Specified by:

incrementIdempotentlyAsync in interface StatisticRepository

topAsync

public CompletionStage<List<StatisticRankEntry>> topAsync(StatisticId statisticId,
 int limit)

Description copied from interface: StatisticRepository

Returns a deterministic, value-descending ranking limited by the caller.

Specified by:

topAsync in interface StatisticRepository

migrations

public static List<com.cotani.storage.migration.Migration> migrations()