Package gov.nasa.jpl.aerie.merlin.server.remotes.postgres

Class PostgresResultsCellRepository

java.lang.Object

gov.nasa.jpl.aerie.merlin.server.remotes.postgres.PostgresResultsCellRepository

All Implemented Interfaces:

ResultsCellRepository

public final class PostgresResultsCellRepository
extends Object
implements ResultsCellRepository

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PostgresResultsCellRepository.PostgresResultsCell
static class	PostgresResultsCellRepository.PostgresSimulationResultsHandle

Constructor Summary

Constructors

Constructor	Description
PostgresResultsCellRepository(DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
ResultsProtocol.OwnerRole	allocate(PlanId planId, String requestedBy)
Optional<ResultsProtocol.OwnerRole>	claim(PlanId planId, Long datasetId)	Claim a simulation
ResultsProtocol.OwnerRole	forceAllocate(PlanId planId, String requestedBy)	Forcibly allocate a simulation by updating the Simulation Configuration's revision
Optional<ResultsProtocol.ReaderRole>	lookup(PlanId planId)
Optional<ResultsProtocol.ReaderRole>	lookup(PlanId planId, SimulationDatasetId simulationDatasetId)

Methods inherited from class java.lang.Object

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

Constructor Details

PostgresResultsCellRepository

public PostgresResultsCellRepository(DataSource dataSource)

Method Details

allocate

public ResultsProtocol.OwnerRole allocate(PlanId planId,
 String requestedBy)

Specified by:

allocate in interface ResultsCellRepository

forceAllocate

public ResultsProtocol.OwnerRole forceAllocate(PlanId planId,
 String requestedBy)

Forcibly allocate a simulation by updating the Simulation Configuration's revision

Specified by:

forceAllocate in interface ResultsCellRepository

claim

public Optional<ResultsProtocol.OwnerRole> claim(PlanId planId,
 Long datasetId)

Claim a simulation

For the case where the return value is empty, the simulation is already claimed. All other exceptions are unexpected and result in an Error being raised.

Specified by:

claim in interface ResultsCellRepository

Parameters:

planId - a plan identifier

datasetId - the identifier of a dataset record

Returns:

cell (handle) ResultsProtocol.OwnerRole to the claimed simulation wrapped in Optional

lookup

public Optional<ResultsProtocol.ReaderRole> lookup(PlanId planId)

Specified by:

lookup in interface ResultsCellRepository

lookup

public Optional<ResultsProtocol.ReaderRole> lookup(PlanId planId,
 SimulationDatasetId simulationDatasetId)
                                            throws SimulationDatasetMismatchException

Specified by:

lookup in interface ResultsCellRepository

Throws:

SimulationDatasetMismatchException