Class StorageLifecycleStore

java.lang.Object

ecmwf.common.database.StorageLifecycleStore

public final class StorageLifecycleStore
extends Object

Bounded, fresh JDBC snapshots; lifecycle decisions must not use Hibernate's entity cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	StorageLifecycleStore.Snapshot
static final record	StorageLifecycleStore.Transfer

Constructor Summary

Constructors

Constructor	Description
StorageLifecycleStore()

Method Summary

Modifier and Type	Method	Description
void	checkSchema()
void	error(long id, String message, long now)
List<Long>	files(long after, long ceiling, int limit)
static int	instance(DataFile file)
Map<String, Map<String,String>>	metrics()
void	pin(DataFile file, long until, String reason, String user)
void	removed(DataFile file, Set<String> policies, long bytes, long now)
void	resetReplication(long fileId)
void	save(DataFile file, String state, String message, Set<String> policies, long eligibleAt, long guaranteedUntil, long reclaimable, long now)
long	scanCeiling()
StorageLifecycleStore.Snapshot	snapshot(long id, int maxTransfers)
Map<String,String>	state(long id)

Methods inherited from class Object

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

Constructor Details

StorageLifecycleStore

public StorageLifecycleStore()

Method Details

checkSchema

public void checkSchema()

scanCeiling

public long scanCeiling()

files

public List<Long> files(long after,
 long ceiling,
 int limit)

error

public void error(long id,
 String message,
 long now)

resetReplication

public void resetReplication(long fileId)

snapshot

public StorageLifecycleStore.Snapshot snapshot(long id,
 int maxTransfers)

state

public Map<String,String> state(long id)

save

public void save(DataFile file,
 String state,
 String message,
 Set<String> policies,
 long eligibleAt,
 long guaranteedUntil,
 long reclaimable,
 long now)

pin

public void pin(DataFile file,
 long until,
 String reason,
 String user)

removed

public void removed(DataFile file,
 Set<String> policies,
 long bytes,
 long now)

metrics

public Map<String, Map<String,String>> metrics()

instance

public static int instance(DataFile file)