Package io.clonecloudstore.accessor.server.application

Class LocalReplicatorService

java.lang.Object

io.clonecloudstore.accessor.server.application.LocalReplicatorService

@ApplicationScoped
public class LocalReplicatorService
extends Object

Interface of Replicator Client and Broker

Constructor Summary

Constructors

Constructor	Description
LocalReplicatorService(LocalBrokerService localBrokerService, LocalReplicatorApiClientFactory localReplicatorApiClientFactory, LocalReplicatorOrderEmitter localReplicatorOrderEmitter)

Method Summary

Modifier and Type	Method	Description
void	create(String bucketName, String clientId)	Through Broker, asks to replicate this Bucket
void	create(String bucketName, String objectName, String clientId, long size, String hash)	Through Broker, asks to replicate this Object
void	delete(String bucketName, String clientId)	Through Broker, asks to delete this Bucket
void	delete(String bucketName, String objectName, String clientId)	Through Broker, asks to delete this Object
void	generateLocalReplicationOrder(ReplicatorOrder replicatorOrder)	Local Replication order as self repairing
ReplicatorResponse<StorageType>	remoteCheckBucket(String bucketName, String clientId, String opId)	Through API Client, asks if this Bucket exists in remote
ReplicatorResponse<StorageType>	remoteCheckObject(String bucketName, String objectName, String clientId, String opId)	Through API Client, asks if this Object exists in remote
ReplicatorResponse<AccessorBucket>	remoteGetBucket(String bucketName, String clientId, String opId)	Through API Client, asks if this Bucket exists in remote
InputStreamBusinessOut<AccessorObject>	remoteReadObject(String bucketName, String objectName, String clientId, String targetId, String opId)	Through API Client, Get this Object and Content from remote

Methods inherited from class java.lang.Object

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

Constructor Details

LocalReplicatorService

public LocalReplicatorService(LocalBrokerService localBrokerService,
 LocalReplicatorApiClientFactory localReplicatorApiClientFactory,
 LocalReplicatorOrderEmitter localReplicatorOrderEmitter)

Method Details

create

public void create(String bucketName,
 String clientId)
            throws CcsOperationException

Through Broker, asks to replicate this Bucket

Throws:

CcsOperationException

delete

public void delete(String bucketName,
 String clientId)
            throws CcsOperationException

Through Broker, asks to delete this Bucket

Throws:

CcsOperationException

delete

public void delete(String bucketName,
 String objectName,
 String clientId)
            throws CcsOperationException

Through Broker, asks to delete this Object

Throws:

CcsOperationException

create

public void create(String bucketName,
 String objectName,
 String clientId,
 long size,
 String hash)
            throws CcsOperationException

Through Broker, asks to replicate this Object

Throws:

CcsOperationException

remoteCheckBucket

public ReplicatorResponse<StorageType> remoteCheckBucket(String bucketName,
 String clientId,
 String opId)
                                                  throws CcsOperationException

Through API Client, asks if this Bucket exists in remote

Throws:

CcsOperationException

remoteGetBucket

public ReplicatorResponse<AccessorBucket> remoteGetBucket(String bucketName,
 String clientId,
 String opId)
                                                   throws CcsOperationException

Through API Client, asks if this Bucket exists in remote

Throws:

CcsOperationException

remoteCheckObject

public ReplicatorResponse<StorageType> remoteCheckObject(String bucketName,
 String objectName,
 String clientId,
 String opId)
                                                  throws CcsOperationException

Through API Client, asks if this Object exists in remote

Throws:

CcsOperationException

remoteReadObject

public InputStreamBusinessOut<AccessorObject> remoteReadObject(String bucketName,
 String objectName,
 String clientId,
 String targetId,
 String opId)
                                                        throws CcsOperationException

Through API Client, Get this Object and Content from remote

Throws:

CcsOperationException

generateLocalReplicationOrder

public void generateLocalReplicationOrder(ReplicatorOrder replicatorOrder)

Local Replication order as self repairing