|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of Node in org.jumpmind.symmetric.db |
|---|
| Methods in org.jumpmind.symmetric.db with parameters of type Node | |
|---|---|
java.lang.String |
SqlTemplate.createInitalLoadSql(Node node,
IDbDialect dialect,
Trigger trig,
org.apache.ddlutils.model.Table metaData)
|
java.lang.String |
IDbDialect.createInitalLoadSqlFor(Node node,
Trigger trigger)
|
java.lang.String |
AbstractDbDialect.createInitalLoadSqlFor(Node node,
Trigger trigger)
|
java.lang.String |
SqlTemplate.createPurgeSql(Node node,
IDbDialect dialect,
Trigger trig,
TriggerHistory hist)
|
java.lang.String |
IDbDialect.createPurgeSqlFor(Node node,
Trigger trigger,
TriggerHistory history)
|
java.lang.String |
AbstractDbDialect.createPurgeSqlFor(Node node,
Trigger trigger,
TriggerHistory hist)
|
| Uses of Node in org.jumpmind.symmetric.db.hsqldb |
|---|
| Methods in org.jumpmind.symmetric.db.hsqldb that return types with arguments of type Node | |
|---|---|
protected java.util.List<Node> |
HsqlDbTrigger.findTargetNodes(java.lang.Object[] oldRow,
java.lang.Object[] newRow)
|
| Uses of Node in org.jumpmind.symmetric.load |
|---|
| Methods in org.jumpmind.symmetric.load with parameters of type Node | |
|---|---|
void |
IReloadListener.afterReload(Node node)
|
void |
IReloadListener.beforeReload(Node node)
|
| Uses of Node in org.jumpmind.symmetric.model |
|---|
| Constructors in org.jumpmind.symmetric.model with parameters of type Node | |
|---|---|
OutgoingBatch(Node node,
java.lang.String channelId,
BatchType batchType)
|
|
| Uses of Node in org.jumpmind.symmetric.service |
|---|
| Methods in org.jumpmind.symmetric.service that return Node | |
|---|---|
Node |
INodeService.findIdentity()
|
Node |
INodeService.findIdentity(boolean useCache)
|
Node |
INodeService.findNode(java.lang.String nodeId)
|
Node |
INodeService.findNodeByExternalId(java.lang.String nodeGroupId,
java.lang.String externalId)
|
| Methods in org.jumpmind.symmetric.service that return types with arguments of type Node | |
|---|---|
java.util.List<Node> |
INodeService.findNodesToPull()
|
java.util.List<Node> |
INodeService.findNodesToPushTo()
|
java.util.List<Node> |
INodeService.findSourceNodesFor(DataEventAction eventAction)
|
java.util.List<Node> |
INodeService.findTargetNodesFor(DataEventAction eventAction)
|
| Methods in org.jumpmind.symmetric.service with parameters of type Node | |
|---|---|
boolean |
IDataExtractorService.extract(Node node,
IExtractListener handler)
|
boolean |
IDataExtractorService.extract(Node node,
IOutgoingTransport transport)
|
void |
IDataExtractorService.extractConfiguration(Node node,
java.io.BufferedWriter writer,
DataExtractorContext ctx)
|
void |
IDataExtractorService.extractConfigurationStandalone(Node node,
java.io.BufferedWriter out)
|
void |
IDataExtractorService.extractConfigurationStandalone(Node node,
java.io.OutputStream out)
|
OutgoingBatch |
IDataExtractorService.extractInitialLoadFor(Node node,
Trigger config,
java.io.BufferedWriter writer)
|
void |
IDataExtractorService.extractInitialLoadWithinBatchFor(Node node,
Trigger trigger,
java.io.BufferedWriter writer,
DataExtractorContext ctx)
|
void |
IClusterService.initLockTableForNode(Node node)
|
void |
IDataService.insertCreateEvent(Node targetNode,
Trigger trigger,
java.lang.String xml)
|
void |
IDataService.insertHeartbeatEvent(Node node)
|
void |
IDataService.insertPurgeEvent(Node targetNode,
Trigger trigger)
|
void |
IDataService.insertReloadEvent(Node targetNode)
|
void |
IDataService.insertReloadEvent(Node targetNode,
Trigger trigger)
|
void |
IDataService.insertResendConfigEvent(Node targetNode)
|
void |
IDataService.insertSqlEvent(Node targetNode,
java.lang.String sql)
|
void |
IDataService.insertSqlEvent(Node targetNode,
Trigger trigger,
java.lang.String sql)
|
boolean |
IDataLoaderService.loadData(Node remote,
Node local)
|
boolean |
IClusterService.lock(LockAction action,
Node node)
|
boolean |
IRegistrationService.registerNode(Node node,
java.io.OutputStream out,
boolean isRequestedRegistration)
|
void |
IClusterService.unlock(LockAction action,
Node node)
|
boolean |
INodeService.updateNode(Node node)
|
| Method parameters in org.jumpmind.symmetric.service with type arguments of type Node | |
|---|---|
void |
IDataService.insertDataEvent(Data data,
java.lang.String channelId,
java.util.List<Node> nodes)
|
void |
IDataService.insertDataEvent(Data data,
java.lang.String channelId,
java.lang.String transactionId,
java.util.List<Node> nodes)
|
| Uses of Node in org.jumpmind.symmetric.service.impl |
|---|
| Methods in org.jumpmind.symmetric.service.impl that return Node | |
|---|---|
Node |
NodeService.findIdentity()
|
Node |
NodeService.findIdentity(boolean useCache)
|
Node |
NodeService.findNode(java.lang.String id)
Lookup a node in the database, which contains information for syncing with it. |
Node |
NodeService.findNodeByExternalId(java.lang.String nodeGroupId,
java.lang.String externalId)
|
| Methods in org.jumpmind.symmetric.service.impl that return types with arguments of type Node | |
|---|---|
java.util.List<Node> |
NodeService.findNodesToPull()
|
java.util.List<Node> |
NodeService.findNodesToPushTo()
|
java.util.List<Node> |
NodeService.findSourceNodesFor(DataEventAction eventAction)
|
java.util.List<Node> |
NodeService.findTargetNodesFor(DataEventAction eventAction)
|
| Methods in org.jumpmind.symmetric.service.impl with parameters of type Node | |
|---|---|
boolean |
DataExtractorService.extract(Node node,
IExtractListener handler)
Allow a handler callback to do the work so we can route the extracted data to other types of handlers for processing. |
boolean |
DataExtractorService.extract(Node node,
IOutgoingTransport transport)
|
void |
DataExtractorService.extractConfiguration(Node node,
java.io.BufferedWriter writer,
DataExtractorContext ctx)
|
void |
DataExtractorService.extractConfigurationStandalone(Node node,
java.io.BufferedWriter writer)
Extract the SymmetricDS configuration for the passed in Node. |
void |
DataExtractorService.extractConfigurationStandalone(Node node,
java.io.OutputStream out)
|
OutgoingBatch |
DataExtractorService.extractInitialLoadFor(Node node,
Trigger trigger,
java.io.BufferedWriter writer)
|
void |
DataExtractorService.extractInitialLoadWithinBatchFor(Node node,
Trigger trigger,
java.io.BufferedWriter writer,
DataExtractorContext ctx)
|
void |
ClusterService.initLockTableForNode(Node node)
|
void |
DataService.insertCreateEvent(Node targetNode,
Trigger trigger,
java.lang.String xml)
|
void |
DataService.insertHeartbeatEvent(Node node)
Because we can't add a trigger on the _node table, we are artificially generating heartbeat events. |
void |
DataService.insertPurgeEvent(Node targetNode,
Trigger trigger)
|
void |
DataService.insertReloadEvent(Node targetNode)
|
void |
DataService.insertReloadEvent(Node targetNode,
Trigger trigger)
|
void |
DataService.insertReloadEvent(Node targetNode,
Trigger trigger,
java.lang.String overrideInitialLoadSelect)
|
void |
DataService.insertResendConfigEvent(Node targetNode)
|
void |
DataService.insertSqlEvent(Node targetNode,
java.lang.String sql)
|
void |
DataService.insertSqlEvent(Node targetNode,
Trigger trigger,
java.lang.String sql)
|
boolean |
DataLoaderService.loadData(Node remote,
Node local)
Connect to the remote node and pull data. |
boolean |
ClusterService.lock(LockAction action,
Node node)
|
boolean |
RegistrationService.registerNode(Node node,
java.io.OutputStream out,
boolean isRequestedRegistration)
Register a node for the given domain name and domain ID if the registration is open. |
void |
ClusterService.unlock(LockAction action,
Node node)
|
boolean |
NodeService.updateNode(Node node)
|
protected boolean |
RegistrationService.writeConfiguration(Node node,
java.io.OutputStream out)
Deprecated. |
protected void |
DataExtractorService.writeInitialLoad(Node node,
Trigger trigger,
java.io.BufferedWriter writer,
OutgoingBatch batch,
DataExtractorContext ctx)
|
protected void |
DataExtractorService.writeInitialLoad(Node node,
Trigger trigger,
TriggerHistory hist,
java.io.BufferedWriter writer,
OutgoingBatch batch,
DataExtractorContext ctx)
|
| Method parameters in org.jumpmind.symmetric.service.impl with type arguments of type Node | |
|---|---|
void |
DataService.insertDataEvent(Data data,
java.lang.String channelId,
java.util.List<Node> nodes)
|
void |
DataService.insertDataEvent(Data data,
java.lang.String channelId,
java.lang.String transactionId,
java.util.List<Node> nodes)
|
| Uses of Node in org.jumpmind.symmetric.transport |
|---|
| Methods in org.jumpmind.symmetric.transport with parameters of type Node | |
|---|---|
IIncomingTransport |
ITransportManager.getPullTransport(Node remote,
Node local)
|
IOutgoingWithResponseTransport |
ITransportManager.getPushTransport(Node remote,
Node local)
|
IIncomingTransport |
ITransportManager.getRegisterTransport(Node node)
|
boolean |
ITransportManager.sendAcknowledgement(Node remote,
java.util.List<IncomingBatchHistory> list,
Node local)
|
| Uses of Node in org.jumpmind.symmetric.transport.handler |
|---|
| Methods in org.jumpmind.symmetric.transport.handler with parameters of type Node | |
|---|---|
boolean |
RegistrationResourceHandler.registerNode(Node node,
java.io.OutputStream outputStream)
|
| Uses of Node in org.jumpmind.symmetric.transport.http |
|---|
| Methods in org.jumpmind.symmetric.transport.http with parameters of type Node | |
|---|---|
protected java.lang.String |
HttpTransportManager.buildURL(java.lang.String action,
Node remote,
Node local)
Build a url for an action. |
IIncomingTransport |
HttpTransportManager.getPullTransport(Node remote,
Node local)
|
IOutgoingWithResponseTransport |
HttpTransportManager.getPushTransport(Node remote,
Node local)
|
IIncomingTransport |
HttpTransportManager.getRegisterTransport(Node node)
|
boolean |
HttpTransportManager.sendAcknowledgement(Node remote,
java.util.List<IncomingBatchHistory> list,
Node local)
|
boolean |
HttpTransportManager.sendMessage(java.lang.String action,
Node remote,
Node local,
java.lang.String data)
|
| Uses of Node in org.jumpmind.symmetric.transport.internal |
|---|
| Methods in org.jumpmind.symmetric.transport.internal with parameters of type Node | |
|---|---|
IIncomingTransport |
InternalTransportManager.getPullTransport(Node remote,
Node local)
|
IOutgoingWithResponseTransport |
InternalTransportManager.getPushTransport(Node remote,
Node local)
|
IIncomingTransport |
InternalTransportManager.getRegisterTransport(Node client)
|
boolean |
InternalTransportManager.sendAcknowledgement(Node remote,
java.util.List<IncomingBatchHistory> list,
Node local)
|
| Uses of Node in org.jumpmind.symmetric.upgrade |
|---|
| Methods in org.jumpmind.symmetric.upgrade with parameters of type Node | |
|---|---|
protected java.lang.String |
AbstractSqlUpgradeTask.prepareSql(Node node,
java.lang.String sql)
|
void |
SqlUpgradeTask.upgrade(Node node,
int[] fromVersion)
|
void |
SqlDrivenUpgradeTask.upgrade(Node node,
int[] fromVersion)
|
void |
IUpgradeTask.upgrade(Node node,
int[] fromVersion)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||