net.bluemind.backend.cyrus.replication.storage.mock

Class MockReplicationStorage

java.lang.Object

net.bluemind.backend.cyrus.replication.storage.mock.MockReplicationStorage

All Implemented Interfaces:

StorageApiLink

public class MockReplicationStorage
extends java.lang.Object
implements StorageApiLink

Nested Class Summary

Nested classes/interfaces inherited from interface net.bluemind.backend.cyrus.replication.server.state.StorageApiLink

StorageApiLink.ApiDesc

Constructor Summary

Constructors

Constructor and Description
MockReplicationStorage(io.vertx.core.Vertx vertx, HttpClientProvider http, java.lang.String remoteIp)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<IDbMessageBodiesPromise>	bodies(java.lang.String partition)
java.util.concurrent.CompletableFuture<ICyrusReplicationAnnotationsPromise>	cyrusAnnotations()
java.util.concurrent.CompletableFuture<ICyrusReplicationArtifactsPromise>	cyrusArtifacts(java.lang.String userId)
java.util.concurrent.CompletableFuture<IDbMailboxRecordsPromise>	mailboxRecords(java.lang.String mboxUniqueId)
void	release()
java.lang.String	remoteIp()
java.util.concurrent.CompletableFuture<StorageApiLink.ApiDesc>	replicatedMailboxes(CyrusBoxes.ReplicatedBox box) Returns the API object suitable to manipulate the given mailbox.
java.util.concurrent.CompletableFuture<IDbReplicatedMailboxesPromise>	replicatedMailboxes(java.lang.String partition, MailboxReplicaRootDescriptor root)
java.util.concurrent.CompletableFuture<java.util.List<ResolvedMailbox>>	resolveNames(java.util.List<java.lang.String> names)
Stream	stream(java.nio.file.Path p)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	validate(java.lang.String login, java.lang.String secret)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.bluemind.backend.cyrus.replication.server.state.StorageApiLink

create

Constructor Detail

MockReplicationStorage

public MockReplicationStorage(io.vertx.core.Vertx vertx,
                              HttpClientProvider http,
                              java.lang.String remoteIp)

Method Detail

remoteIp

public java.lang.String remoteIp()

Specified by:

remoteIp in interface StorageApiLink

release

public void release()

Specified by:

release in interface StorageApiLink

replicatedMailboxes

public java.util.concurrent.CompletableFuture<StorageApiLink.ApiDesc> replicatedMailboxes(CyrusBoxes.ReplicatedBox box)

Description copied from interface: StorageApiLink

Returns the API object suitable to manipulate the given mailbox.

Specified by:

replicatedMailboxes in interface StorageApiLink

Parameters:

box - can't be null

Returns:

access to db hierarchy api

validate

public java.util.concurrent.CompletableFuture<java.lang.Boolean> validate(java.lang.String login,
                                                                          java.lang.String secret)

Specified by:

validate in interface StorageApiLink

bodies

public java.util.concurrent.CompletableFuture<IDbMessageBodiesPromise> bodies(java.lang.String partition)

Specified by:

bodies in interface StorageApiLink

replicatedMailboxes

public java.util.concurrent.CompletableFuture<IDbReplicatedMailboxesPromise> replicatedMailboxes(java.lang.String partition,
                                                                                                 MailboxReplicaRootDescriptor root)

Specified by:

replicatedMailboxes in interface StorageApiLink

mailboxRecords

public java.util.concurrent.CompletableFuture<IDbMailboxRecordsPromise> mailboxRecords(java.lang.String mboxUniqueId)

Specified by:

mailboxRecords in interface StorageApiLink

cyrusArtifacts

public java.util.concurrent.CompletableFuture<ICyrusReplicationArtifactsPromise> cyrusArtifacts(java.lang.String userId)

Specified by:

cyrusArtifacts in interface StorageApiLink

cyrusAnnotations

public java.util.concurrent.CompletableFuture<ICyrusReplicationAnnotationsPromise> cyrusAnnotations()

Specified by:

cyrusAnnotations in interface StorageApiLink

stream

public Stream stream(java.nio.file.Path p)

Specified by:

stream in interface StorageApiLink

resolveNames

public java.util.concurrent.CompletableFuture<java.util.List<ResolvedMailbox>> resolveNames(java.util.List<java.lang.String> names)

Specified by:

resolveNames in interface StorageApiLink