Interface MoverInterface

All Superinterfaces:

ClientInterface, Remote

All Known Implementing Classes:

MoverServer

public interface MoverInterface
extends ClientInterface

The Interface MoverInterface.

Method Summary

Modifier and Type	Method	Description
void	check(long ticket)	Check.
boolean	close(DataTransfer transfer)	Close.
void	closeAllIncomingConnections()	Close all incoming connections.
boolean	closeIncomingConnection(String id)	Close incoming connection.
boolean	del(DataFile dataFile)	Del.
void	del(DataTransfer transfer, String fileName)	Del.
boolean	del(Host proxyHost, DataFile dataFile)	Del.
void	del(Host host, String source)	Del.
DataFile	download(DataFile dataFile, Host hostForSource)	Download.
RemoteInputStream	execute(String script)	Execute.
DataFile	filter(DataFile dataFile, boolean remove)	Filter.
ProxySocket	get(DataFile dataFile, Host[] hostForSource, long remotePosn, long length)	Gets the.
ProxySocket	get(DataFile dataFile, Host hostForSource, long remotePosn)	Gets the.
ProxySocket	get(Host host, String source, long remotePosn, boolean removeOriginal)	Gets the.
String	getECproxyAddressAndPort()	Gets the ECproxy plugging listen address and port.
String	getHostReport(Host proxyHost, Host host)	Gets the host report.
String[]	getIncomingConnectionIds()	Gets the incoming connection ids.
List<IncomingConnection>	getIncomingConnections()	Gets the incoming connections.
String	getMoverReport(Host proxyHost)	Gets the mover report.
int	getMQTTClientsCount()	Get the number of client connected to the MQTT broker.
String	getReport()	Gets the report.
String	getReport(Host host)	Gets the report.
RemoteInputStream	listAsByteArray(Host host, String directory, String pattern, boolean synchronous)	List2.
String[]	listAsStringArray(Host host, String source, String pattern)	List.
void	mkdir(Host host, String dir)	Mkdir.
void	move(Host host, String source, String target)	Move.
void	publishToMQTTBroker(String topic, int qos, long expiryInterval, String contentType, String clientId, String payload, boolean retain)	Publish a notification to the MQTT service.
void	purge(Host proxyHost, List<ExistingStorageDirectory> directories)	Purge.
void	purge(List<ExistingStorageDirectory> directories)	Purge.
DataTransfer	put(Host[] hostsForSource, DataTransfer transfer, String fileName, long localPosn, long remotePosn)	Puts the.
ProxySocket	put(Host host, String target, long remotePosn, long size)	Puts the.
void	removeFromMQTTBroker(String topic)	Remove a retained notification from the MQTT broker.
DataFile	replicate(DataFile dataFile, Host targetHost, Host[] hostsForSource)	Replicate.
void	rmdir(Host host, String dir)	Rmdir.
void	shutdown(boolean graceful, boolean restart)	Shutdown.
long	size(DataTransfer transfer, String fileName)	Size.
long	size(Host host, String source)	Size.

Methods inherited from interface ecmwf.common.ecaccess.ClientInterface

getPassword, getRoot, getService

Method Details

size

long size(DataTransfer transfer,
 String fileName)
   throws ECtransException,
IOException

Size.

Parameters:

transfer - the transfer

fileName - the file name

Returns:

the long

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

del

void del(DataTransfer transfer,
 String fileName)
  throws ECtransException,
IOException

Del.

Parameters:

transfer - the transfer

fileName - the file name

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

del

boolean del(Host proxyHost,
 DataFile dataFile)
     throws ECtransException,
IOException

Del.

Parameters:

proxyHost - the proxy host

dataFile - the data file

Returns:

true, if successful

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

purge

void purge(List<ExistingStorageDirectory> directories)
    throws RemoteException

Purge.

Parameters:

directories - the directories

Throws:

RemoteException - the remote exception

purge

void purge(Host proxyHost,
 List<ExistingStorageDirectory> directories)
    throws RemoteException

Purge.

Parameters:

proxyHost - the proxy host

directories - the directories

Throws:

RemoteException - the remote exception

put

DataTransfer put(Host[] hostsForSource,
 DataTransfer transfer,
 String fileName,
 long localPosn,
 long remotePosn)
          throws ECtransException,
SourceNotAvailableException,
IOException

Puts the.

Parameters:

hostsForSource - the hosts for source

transfer - the transfer

fileName - the file name

localPosn - the local posn

remotePosn - the remote posn

Returns:

the data transfer

Throws:

ECtransException - the ectrans exception

SourceNotAvailableException - the source not available exception

IOException - Signals that an I/O exception has occurred.

put

ProxySocket put(Host host,
 String target,
 long remotePosn,
 long size)
         throws ECtransException,
IOException

Puts the.

Parameters:

host - the host

target - the target

remotePosn - the remote posn

size - the size

Returns:

the proxy socket

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

get

ProxySocket get(Host host,
 String source,
 long remotePosn,
 boolean removeOriginal)
         throws ECtransException,
IOException

Gets the.

Parameters:

host - the host

source - the source

remotePosn - the remote posn

removeOriginal - the remove original

Returns:

the proxy socket

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

get

ProxySocket get(DataFile dataFile,
 Host hostForSource,
 long remotePosn)
         throws SourceNotAvailableException,
IOException

Gets the.

Parameters:

dataFile - the data file

hostForSource - the host for source

remotePosn - the remote posn

Returns:

the proxy socket

Throws:

SourceNotAvailableException - the source not available exception

IOException - Signals that an I/O exception has occurred.

get

ProxySocket get(DataFile dataFile,
 Host[] hostForSource,
 long remotePosn,
 long length)
         throws SourceNotAvailableException,
IOException

Gets the.

Parameters:

dataFile - the data file

hostForSource - the host for source

remotePosn - the remote posn

length - the length

Returns:

the proxy socket

Throws:

SourceNotAvailableException - the source not available exception

IOException - Signals that an I/O exception has occurred.

size

long size(Host host,
 String source)
   throws ECtransException,
IOException

Size.

Parameters:

host - the host

source - the source

Returns:

the long

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

del

void del(Host host,
 String source)
  throws ECtransException,
IOException

Del.

Parameters:

host - the host

source - the source

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

mkdir

void mkdir(Host host,
 String dir)
    throws ECtransException,
IOException

Mkdir.

Parameters:

host - the host

dir - the dir

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

rmdir

void rmdir(Host host,
 String dir)
    throws ECtransException,
IOException

Rmdir.

Parameters:

host - the host

dir - the dir

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

listAsStringArray

String[] listAsStringArray(Host host,
 String source,
 String pattern)
                    throws ECtransException,
IOException

List.

Parameters:

host - the host

source - the source

pattern - the pattern

Returns:

the string[]

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

listAsByteArray

RemoteInputStream listAsByteArray(Host host,
 String directory,
 String pattern,
 boolean synchronous)
                           throws ECtransException,
IOException

List2.

Parameters:

host - the host

directory - the directory

pattern - the pattern

synchronous - the synchronous

Returns:

the remote input stream

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

execute

RemoteInputStream execute(String script)
                   throws ScriptException,
IOException

Execute.

Parameters:

script - the script

Returns:

the remote input stream

Throws:

ScriptException - the script exception

IOException - Signals that an I/O exception has occurred.

move

void move(Host host,
 String source,
 String target)
   throws ECtransException,
IOException

Move.

Parameters:

host - the host

source - the source

target - the target

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

close

boolean close(DataTransfer transfer)
       throws ECtransException,
IOException

Close.

Parameters:

transfer - the transfer

Returns:

true, if successful

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

replicate

DataFile replicate(DataFile dataFile,
 Host targetHost,
 Host[] hostsForSource)
            throws ECtransException,
SourceNotAvailableException,
IOException

Replicate.

Parameters:

dataFile - the data file

targetHost - the target host

hostsForSource - the hosts for source

Returns:

the data file

Throws:

ECtransException - the ectrans exception

SourceNotAvailableException - the source not available exception

IOException - Signals that an I/O exception has occurred.

download

DataFile download(DataFile dataFile,
 Host hostForSource)
           throws SourceNotAvailableException,
IOException

Download.

Parameters:

dataFile - the data file

hostForSource - the host for source

Returns:

the data file

Throws:

SourceNotAvailableException - the source not available exception

IOException - Signals that an I/O exception has occurred.

filter

DataFile filter(DataFile dataFile,
 boolean remove)
         throws IOException

Filter.

Parameters:

dataFile - the data file

remove - the remove

Returns:

the data file

Throws:

IOException - Signals that an I/O exception has occurred.

del

boolean del(DataFile dataFile)
     throws ECtransException,
IOException

Del.

Parameters:

dataFile - the data file

Returns:

true, if successful

Throws:

ECtransException - the ectrans exception

IOException - Signals that an I/O exception has occurred.

check

void check(long ticket)
    throws IOException

Check.

Parameters:

ticket - the ticket

Throws:

IOException - Signals that an I/O exception has occurred.

getMoverReport

String getMoverReport(Host proxyHost)
               throws IOException

Gets the mover report.

Parameters:

proxyHost - the proxy host

Returns:

the mover report

Throws:

IOException - Signals that an I/O exception has occurred.

getHostReport

String getHostReport(Host proxyHost,
 Host host)
              throws IOException

Gets the host report.

Parameters:

proxyHost - the proxy host

host - the host

Returns:

the host report

Throws:

IOException - Signals that an I/O exception has occurred.

getReport

String getReport()
          throws IOException

Gets the report.

Returns:

the report

Throws:

IOException - Signals that an I/O exception has occurred.

getReport

String getReport(Host host)
          throws IOException

Gets the report.

Parameters:

host - the host

Returns:

the report

Throws:

IOException - Signals that an I/O exception has occurred.

getIncomingConnectionIds

String[] getIncomingConnectionIds()
                           throws IOException

Gets the incoming connection ids.

Returns:

the incoming connection ids

Throws:

IOException - Signals that an I/O exception has occurred.

getIncomingConnections

List<IncomingConnection> getIncomingConnections()
                                         throws IOException

Gets the incoming connections.

Returns:

the incoming connections

Throws:

IOException - Signals that an I/O exception has occurred.

closeIncomingConnection

boolean closeIncomingConnection(String id)
                         throws IOException

Close incoming connection.

Parameters:

id - the id

Returns:

true, if successful

Throws:

IOException - Signals that an I/O exception has occurred.

closeAllIncomingConnections

void closeAllIncomingConnections()
                          throws IOException

Close all incoming connections.

Throws:

IOException - Signals that an I/O exception has occurred.

publishToMQTTBroker

void publishToMQTTBroker(String topic,
 int qos,
 long expiryInterval,
 String contentType,
 String clientId,
 String payload,
 boolean retain)
                  throws RemoteException

Publish a notification to the MQTT service.

Parameters:

topic - the topic

qos - the qos

expiryInterval - the expiry interval

contentType - the content type

clientId - the client id

payload - the payload

retain - the retain

Throws:

RemoteException - the remote exception

removeFromMQTTBroker

void removeFromMQTTBroker(String topic)
                   throws RemoteException

Remove a retained notification from the MQTT broker.

Parameters:

topic - the topic

Throws:

RemoteException - the remote exception

getMQTTClientsCount

int getMQTTClientsCount()
                 throws RemoteException

Get the number of client connected to the MQTT broker.

Returns:

the MQTT clients count

Throws:

RemoteException - the remote exception

shutdown

void shutdown(boolean graceful,
 boolean restart)
       throws IOException

Shutdown.

Parameters:

graceful - the graceful

restart - the restart

Throws:

IOException - Signals that an I/O exception has occurred.

getECproxyAddressAndPort

String getECproxyAddressAndPort()
                         throws RemoteException

Gets the ECproxy plugging listen address and port. This is used by the Master Server to update the "TransferServer" entry in the database when the Mover subscribe. This address and port are used when the Master Server send the address of the allocated Mover to the ecpds command.

Returns:

the ECproxyPlugin address and port

Throws:

RemoteException - the remote exception