public interface IDataLoaderService
| Modifier and Type | Method and Description |
|---|---|
void |
clearCache() |
void |
delete(DataLoaderService.ConflictNodeGroupLink settings) |
void |
deleteAllConflicts() |
java.util.List<java.lang.String> |
getAvailableDataLoaderFactories() |
java.util.List<DataLoaderService.ConflictNodeGroupLink> |
getConflictSettingsNodeGroupLinks() |
java.util.List<DataLoaderService.ConflictNodeGroupLink> |
getConflictSettingsNodeGroupLinks(NodeGroupLink link,
boolean refreshCache) |
IncomingError |
getCurrentIncomingError(long batchId,
java.lang.String nodeId) |
java.util.List<IncomingError> |
getIncomingErrors(long batchId,
java.lang.String nodeId) |
void |
insertIncomingError(IncomingError incomingError) |
void |
insertIncomingError(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingError incomingError) |
java.util.List<IncomingBatch> |
loadDataBatch(java.lang.String batchData) |
void |
loadDataFromConfig(Node remote,
RemoteNodeStatus status,
boolean force) |
java.util.List<IncomingBatch> |
loadDataFromOfflineTransport(Node remote,
RemoteNodeStatus status,
IIncomingTransport transport) |
void |
loadDataFromPull(Node sourceNode,
RemoteNodeStatus status) |
RemoteNodeStatus |
loadDataFromPull(Node remote,
java.lang.String channelId) |
void |
loadDataFromPush(Node sourceNode,
java.io.InputStream in,
java.io.OutputStream out) |
void |
loadDataFromPush(Node sourceNode,
java.lang.String channelId,
java.io.InputStream in,
java.io.OutputStream out) |
boolean |
refreshFromDatabase() |
void |
save(DataLoaderService.ConflictNodeGroupLink settings) |
void |
updateIncomingError(IncomingError incomingError) |
boolean refreshFromDatabase()
RemoteNodeStatus loadDataFromPull(Node remote, java.lang.String channelId) throws java.io.IOException
java.io.IOExceptionvoid loadDataFromPull(Node sourceNode, RemoteNodeStatus status) throws java.io.IOException
java.io.IOExceptionvoid loadDataFromPush(Node sourceNode, java.io.InputStream in, java.io.OutputStream out) throws java.io.IOException
java.io.IOExceptionvoid loadDataFromPush(Node sourceNode, java.lang.String channelId, java.io.InputStream in, java.io.OutputStream out) throws java.io.IOException
java.io.IOExceptionjava.util.List<IncomingBatch> loadDataFromOfflineTransport(Node remote, RemoteNodeStatus status, IIncomingTransport transport) throws java.io.IOException
java.io.IOExceptionvoid loadDataFromConfig(Node remote, RemoteNodeStatus status, boolean force) throws java.io.IOException
java.io.IOExceptionjava.util.List<java.lang.String> getAvailableDataLoaderFactories()
java.util.List<IncomingBatch> loadDataBatch(java.lang.String batchData)
java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks(NodeGroupLink link, boolean refreshCache)
java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks()
void delete(DataLoaderService.ConflictNodeGroupLink settings)
void deleteAllConflicts()
void save(DataLoaderService.ConflictNodeGroupLink settings)
void clearCache()
java.util.List<IncomingError> getIncomingErrors(long batchId, java.lang.String nodeId)
IncomingError getCurrentIncomingError(long batchId, java.lang.String nodeId)
void insertIncomingError(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingError incomingError)
void insertIncomingError(IncomingError incomingError)
void updateIncomingError(IncomingError incomingError)