Class LiveTransferSample

java.lang.Object
ecmwf.ecpds.master.LiveTransferSample
All Implemented Interfaces:
Serializable
public final class LiveTransferSample extends Object implements Serializable
The Class LiveTransferSample. Lightweight, generic snapshot of an in-progress (or just-finished) data transfer, pushed periodically from a DataMover to the MasterServer so that it can be broadcast to "Live ECPDS Earth" globe visualisation clients. This is intentionally decoupled from ECPDS's internal transfer machinery: it only carries the information the visualisation needs (who/what/where/how-fast/how-much), not full DataTransfer/Host objects.
See Also:

  • Field Details

    • STATUS_ACTIVE

      public static final String STATUS_ACTIVE
      Status: transfer is currently in progress.
      See Also:

    • STATUS_DONE

      public static final String STATUS_DONE
      Status: transfer completed successfully.
      See Also:

    • STATUS_FAILED

      public static final String STATUS_FAILED
      Status: transfer failed/was retried.
      See Also:

    • DIRECTION_DISSEMINATION

      public static final String DIRECTION_DISSEMINATION
      Direction: data pushed out to a Dissemination Host.
      See Also:

    • DIRECTION_ACQUISITION

      public static final String DIRECTION_ACQUISITION
      Direction: data pulled in from an Acquisition Host.
      See Also:

  • Constructor Details

    • LiveTransferSample

      public LiveTransferSample(long transferId, String moverName, String destinationName, String hostName, String hostNickname, String hostAddress, String protocol, long fileSize, long byteSent, long duration, double rateBitsPerSecond, String status, String direction)
      Instantiates a new live transfer sample.
      Parameters:
      transferId - the transfer id
      moverName - the mover name
      destinationName - the destination name
      hostName - the host name
      hostNickname - the host nickname (display name, falls back to hostName when blank)
      hostAddress - the host's actual network address (hostname or IP), used for GeoIP resolution
      protocol - the protocol
      fileSize - the file size
      byteSent - the byte sent
      duration - the duration
      rateBitsPerSecond - the rate bits per second
      status - the status
      direction - one of DIRECTION_DISSEMINATION or DIRECTION_ACQUISITION; defaults to DIRECTION_DISSEMINATION if null

  • Method Details

    • getTransferId

      public long getTransferId()

    • getMoverName

      public String getMoverName()

    • getDestinationName

      public String getDestinationName()

    • getHostName

      public String getHostName()

    • getHostNickname

      public String getHostNickname()

    • getHostAddress

      public String getHostAddress()

    • getProtocol

      public String getProtocol()

    • getFileSize

      public long getFileSize()

    • getByteSent

      public long getByteSent()

    • getDuration

      public long getDuration()

    • getRateBitsPerSecond

      public double getRateBitsPerSecond()

    • getStatus

      public String getStatus()

    • getDirection

      public String getDirection()

    • getTimestamp

      public long getTimestamp()

    • isTerminal

      public boolean isTerminal()

    • toString

      public String toString()
      To string.
      Overrides:
      toString in class Object