org.openspaces.admin.internal.pipelines

Class CR8Impl

java.lang.Object

org.openspaces.admin.internal.pipelines.CR8Impl

All Implemented Interfaces:

SmartExternalizable, Externalizable, Serializable, Connector

public class CR8Impl
extends Object
implements Connector, SmartExternalizable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CR8Impl()
CR8Impl(String host, String port)

Method Summary

Modifier and Type	Method and Description
HTTPResponse	deleteConnector(String pipelineName)
HTTPResponse	getFullSyncStatus(String pipelineName)
HTTPResponse	getStatusConnector(String pipelineName)
HTTPResponse	getTableMetadata(String pipeline, String db, String schema, String table)
void	readExternal(ObjectInput in)
HTTPResponse	startConnector(String pipelineName)
HTTPResponse	startFullSync(String pipelineName)
HTTPResponse	stopConnector(String pipelineName)
HTTPResponse	stopFullSync(String pipelineName)
HTTPResponse	validateConnection(String pipelineName, String jsonConfiguration)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

CR8Impl

public CR8Impl()

CR8Impl

public CR8Impl(String host,
               String port)

Method Detail

startFullSync

public HTTPResponse startFullSync(String pipelineName)

Specified by:

startFullSync in interface Connector

stopFullSync

public HTTPResponse stopFullSync(String pipelineName)

Specified by:

stopFullSync in interface Connector

startConnector

public HTTPResponse startConnector(String pipelineName)

Specified by:

startConnector in interface Connector

stopConnector

public HTTPResponse stopConnector(String pipelineName)

Specified by:

stopConnector in interface Connector

getStatusConnector

public HTTPResponse getStatusConnector(String pipelineName)

Specified by:

getStatusConnector in interface Connector

deleteConnector

public HTTPResponse deleteConnector(String pipelineName)

Specified by:

deleteConnector in interface Connector

getFullSyncStatus

public HTTPResponse getFullSyncStatus(String pipelineName)

Specified by:

getFullSyncStatus in interface Connector

getTableMetadata

public HTTPResponse getTableMetadata(String pipeline,
                                     String db,
                                     String schema,
                                     String table)

Specified by:

getTableMetadata in interface Connector

validateConnection

public HTTPResponse validateConnection(String pipelineName,
                                       String jsonConfiguration)

Specified by:

validateConnection in interface Connector

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException