net.bluemind.backend.cyrus.replication.server.state

Interface StorageApiLink

All Known Implementing Classes:

CoreStorageBackend, MockReplicationStorage

public interface StorageApiLink

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StorageApiLink.ApiDesc

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<IDbMessageBodiesPromise>	bodies(java.lang.String partition)
java.util.concurrent.CompletableFuture<IMailConversationPromise>	conversations(CyrusBoxes.ReplicatedBox userFrom)
static java.util.concurrent.CompletableFuture<StorageApiLink>	create(io.vertx.core.Vertx vertx, HttpClientProvider http, java.lang.String remoteIp)
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)

Field Detail

logger

static final org.slf4j.Logger logger

Method Detail

remoteIp

java.lang.String remoteIp()

release

void release()

create

static java.util.concurrent.CompletableFuture<StorageApiLink> create(io.vertx.core.Vertx vertx,
                                                                     HttpClientProvider http,
                                                                     java.lang.String remoteIp)

stream

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

bodies

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

replicatedMailboxes

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

mailboxRecords

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

replicatedMailboxes

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

Returns the API object suitable to manipulate the given mailbox.

Parameters:

box - can't be null

Returns:

access to db hierarchy api

cyrusArtifacts

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

cyrusAnnotations

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

validate

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

resolveNames

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

conversations

java.util.concurrent.CompletableFuture<IMailConversationPromise> conversations(CyrusBoxes.ReplicatedBox userFrom)