Package de.dlr.proseo.api.auxipmon

Class AuxipMonitor

java.lang.Object

java.lang.Thread

de.dlr.proseo.api.basemon.BaseMonitor

de.dlr.proseo.api.auxipmon.AuxipMonitor

All Implemented Interfaces:

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)

Author:

Dr. Thomas Bassler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AuxipMonitor.TransferProduct	Class describing a download session

Nested classes/interfaces inherited from class de.dlr.proseo.api.basemon.BaseMonitor

BaseMonitor.TransferControl

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final int	AUXIP_WAIT
(package private) Map<String,Boolean>	copySuccess	Indicator for parallel copying processes
(package private) static final String	MSG_COPY_FILE_FAILED
(package private) static final int	MSG_ID_COPY_FILE_FAILED

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
AuxipMonitor()

Method Summary

Modifier and Type	Method	Description
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 private) 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)

Methods inherited from class de.dlr.proseo.api.basemon.BaseMonitor

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

Methods inherited from class 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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

copySuccess

Map<String,Boolean> copySuccess

Indicator for parallel copying processes

MSG_ID_COPY_FILE_FAILED

static final int MSG_ID_COPY_FILE_FAILED

See Also:

• Constant Field Values

MSG_COPY_FILE_FAILED

static final String MSG_COPY_FILE_FAILED

See Also:

• Constant Field Values

AUXIP_WAIT

public static final int AUXIP_WAIT

See Also:

• Constant Field Values

Constructor Details

AuxipMonitor

public AuxipMonitor()

Method Details

getLastCopyPerformance

public Double getLastCopyPerformance()

Gets the last copy performance for monitoring purposes

Returns:

the last copy performance in MiB/s

setLastCopyPerformance

void setLastCopyPerformance(Double copyPerformance)

Records the last copy performance for monitoring purposes

Parameters:

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

Specified by:

checkAvailableDownloads in class BaseMonitor

Parameters:

referenceTimeStamp - the reference timestamp to apply for pickup point lookups

Returns:

a list of available transfer objects

transferToTargetDir

protected boolean transferToTargetDir(TransferObject object)

Transfer the products found to disk for later ingestion

Specified by:

transferToTargetDir in class BaseMonitor

triggerFollowOnAction

protected boolean triggerFollowOnAction(TransferObject transferObject)

Specified by:

triggerFollowOnAction in class BaseMonitor