Package de.dlr.proseo.api.auxipmon

Klasse AuxipMonitor

java.lang.Object

java.lang.Thread

de.dlr.proseo.api.basemon.BaseMonitor

de.dlr.proseo.api.auxipmon.AuxipMonitor

Alle implementierten Schnittstellen:

Runnable

@Component
@Scope("singleton")
public class AuxipMonitor
extends BaseMonitor

Monitor for Auxiliary Data Interface Points (AUXIP) For specification details see "Auxiliary Data Interface Delivery Point Specification" (ESA-EOPG-EOPGC-IF-10, issue 1.3)

Autor:

Dr. Thomas Bassler

Verschachtelte Klassen - Übersicht

Verschachtelte Klassen

Modifizierer und Typ	Klasse	Beschreibung
static class	AuxipMonitor.TransferProduct	Class describing a download session

Von Klasse geerbte verschachtelte Klassen/Schnittstellen de.dlr.proseo.api.basemon.BaseMonitor

BaseMonitor.TransferControl

Von Klasse geerbte verschachtelte Klassen/Schnittstellen java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Feldübersicht

Felder

Modifizierer und Typ	Feld	Beschreibung
(Package privat) Map<String,Boolean>	copySuccess	Indicator for parallel copying processes
(Package privat) static final String	MSG_COPY_FILE_FAILED
(Package privat) static final int	MSG_ID_COPY_FILE_FAILED

Von Klasse geerbte Felder java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Konstruktorübersicht

Konstruktoren

Konstruktor	Beschreibung
AuxipMonitor()

Methodenübersicht

Modifizierer und Typ	Methode	Beschreibung
protected BaseMonitor.TransferControl	checkAvailableDownloads(Instant referenceTimeStamp)	Check the configured AUXIP for new files of the configured product types, whose publication date is after the reference time stamp: If token-based authentication is required, login to AUXIP and request token For all configured product types: Retrieve all products of the given type with publication time after reference time stamp (authenticating with either Basic Auth or Bearer Token) Convert JSON product entries into transfer objects Return the combined list of transfer objects
Double	getLastCopyPerformance()	Gets the last copy performance for monitoring purposes
(Package privat) void	setLastCopyPerformance(Double copyPerformance)	Records the last copy performance for monitoring purposes
protected boolean	transferToTargetDir(TransferObject object)	Transfer the products found to disk for later ingestion
protected boolean	triggerFollowOnAction(TransferObject transferObject)

Von Klasse geerbte Methoden de.dlr.proseo.api.basemon.BaseMonitor

getCheckInterval, getHistoryRetentionDuration, getMaxDownloadThreads, getMaxWaitCycles, getTaskWaitInterval, getTransferHistoryFile, getTruncateInterval, run, run, setCheckInterval, setHistoryRetentionDuration, setMaxDownloadThreads, setMaxWaitCycles, setTaskWaitInterval, setTransferHistoryFile, setTruncateInterval

Von Klasse geerbte Methoden java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Von Klasse geerbte Methoden java.lang.Object

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

Felddetails

copySuccess

Map<String,Boolean> copySuccess

Indicator for parallel copying processes

MSG_ID_COPY_FILE_FAILED

static final int MSG_ID_COPY_FILE_FAILED

Siehe auch:

• Konstantenfeldwerte

MSG_COPY_FILE_FAILED

static final String MSG_COPY_FILE_FAILED

Siehe auch:

• Konstantenfeldwerte

Konstruktordetails

AuxipMonitor

public AuxipMonitor()

Methodendetails

getLastCopyPerformance

public Double getLastCopyPerformance()

Gets the last copy performance for monitoring purposes

Gibt zurück:

the last copy performance in MiB/s

setLastCopyPerformance

void setLastCopyPerformance(Double copyPerformance)

Records the last copy performance for monitoring purposes

Parameter:

copyPerformance - the copy performance in MiB/s

checkAvailableDownloads

protected BaseMonitor.TransferControl checkAvailableDownloads(Instant referenceTimeStamp)

Check the configured AUXIP for new files of the configured product types, whose publication date is after the reference time stamp:

1. If token-based authentication is required, login to AUXIP and request token
2. For all configured product types:
   1. Retrieve all products of the given type with publication time after reference time stamp (authenticating with either Basic Auth or Bearer Token)
   2. Convert JSON product entries into transfer objects
3. Return the combined list of transfer objects

Angegeben von:

checkAvailableDownloads in Klasse BaseMonitor

Parameter:

referenceTimeStamp - the reference timestamp to apply for pickup point lookups

Gibt zurück:

a list of available transfer objects

transferToTargetDir

protected boolean transferToTargetDir(TransferObject object)

Transfer the products found to disk for later ingestion

Angegeben von:

transferToTargetDir in Klasse BaseMonitor

triggerFollowOnAction

protected boolean triggerFollowOnAction(TransferObject transferObject)

Angegeben von:

triggerFollowOnAction in Klasse BaseMonitor