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

Class ReplicationState

java.lang.Object

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

public class ReplicationState
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ReplicationState(io.vertx.core.Vertx vertx, StorageApiLink storage)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	addMessage(MailboxMessage msg)
java.util.concurrent.CompletableFuture<java.lang.Void>	annotate(MailboxAnnotation sub)
java.util.concurrent.CompletableFuture<java.util.List<MailboxAnnotation>>	annotationsByMailbox(java.lang.String mbox)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	checkCredentials(java.lang.String login, java.lang.String secret)
java.util.concurrent.CompletableFuture<java.lang.Void>	delete(java.lang.String toDel)
java.util.concurrent.CompletableFuture<java.lang.Void>	expunge(java.lang.String mbox, java.util.List<java.lang.Long> uid)
java.util.concurrent.CompletableFuture<MailboxFolder>	folderByName(java.lang.String name)
java.util.concurrent.CompletableFuture<java.util.List<MailboxFolder>>	foldersByName(java.util.List<java.lang.String> names)
java.util.concurrent.CompletableFuture<java.util.List<MailboxFolder>>	foldersByUser(java.lang.String userName)
java.util.concurrent.CompletableFuture<MessageBody>	messageByGuid(java.lang.String partition, java.lang.String guid)
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	missingGuids(java.lang.String partition, java.util.List<java.lang.String> guid)
java.util.concurrent.CompletableFuture<java.lang.Void>	quota(QuotaRoot sub)
java.util.concurrent.CompletableFuture<java.util.List<QuotaRoot>>	quotaByUser(java.lang.String userName)
java.util.concurrent.CompletableFuture<java.util.Optional<io.vertx.core.buffer.Buffer>>	record(MailboxFolder folder, java.lang.String bodyGuid, long imapUid)
java.util.concurrent.CompletableFuture<java.util.List<MboxRecord>>	records(MailboxFolder known)
java.util.concurrent.CompletableFuture<java.lang.Void>	registerFolder(MailboxFolder folder)
java.util.concurrent.CompletableFuture<java.lang.Void>	rename(java.lang.String from, java.lang.String to)
java.util.concurrent.CompletableFuture<java.lang.Void>	seenOverlay(SeenOverlay seen)
java.util.concurrent.CompletableFuture<java.util.List<SeenOverlay>>	seenOverlayByUser(java.lang.String userName)
java.util.concurrent.CompletableFuture<java.lang.Void>	sieve(SieveData sd)
java.util.concurrent.CompletableFuture<java.util.List<SieveScript>>	sieveByUser(java.lang.String userName)
java.util.concurrent.CompletableFuture<java.lang.Void>	sub(MailboxSub sub)
java.util.concurrent.CompletableFuture<java.util.List<MailboxSub>>	subByUser(java.lang.String userName)
java.util.concurrent.CompletableFuture<java.lang.Void>	unsieve(SieveData sd)
java.util.concurrent.CompletableFuture<java.lang.Void>	unsub(MailboxSub sub)
java.util.concurrent.CompletableFuture<java.lang.Void>	updateRecords(java.lang.String boxUniqueId, java.util.List<MailboxRecord> mboxState)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationState

public ReplicationState(io.vertx.core.Vertx vertx,
                        StorageApiLink storage)

Method Detail

addMessage

public java.util.concurrent.CompletableFuture<java.lang.Void> addMessage(MailboxMessage msg)

messageByGuid

public java.util.concurrent.CompletableFuture<MessageBody> messageByGuid(java.lang.String partition,
                                                                         java.lang.String guid)

missingGuids

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> missingGuids(java.lang.String partition,
                                                                                             java.util.List<java.lang.String> guid)

folderByName

public java.util.concurrent.CompletableFuture<MailboxFolder> folderByName(java.lang.String name)

foldersByName

public java.util.concurrent.CompletableFuture<java.util.List<MailboxFolder>> foldersByName(java.util.List<java.lang.String> names)

record

public java.util.concurrent.CompletableFuture<java.util.Optional<io.vertx.core.buffer.Buffer>> record(MailboxFolder folder,
                                                                                                      java.lang.String bodyGuid,
                                                                                                      long imapUid)

foldersByUser

public java.util.concurrent.CompletableFuture<java.util.List<MailboxFolder>> foldersByUser(java.lang.String userName)

quota

public java.util.concurrent.CompletableFuture<java.lang.Void> quota(QuotaRoot sub)

annotate

public java.util.concurrent.CompletableFuture<java.lang.Void> annotate(MailboxAnnotation sub)

quotaByUser

public java.util.concurrent.CompletableFuture<java.util.List<QuotaRoot>> quotaByUser(java.lang.String userName)

annotationsByMailbox

public java.util.concurrent.CompletableFuture<java.util.List<MailboxAnnotation>> annotationsByMailbox(java.lang.String mbox)

sub

public java.util.concurrent.CompletableFuture<java.lang.Void> sub(MailboxSub sub)

unsub

public java.util.concurrent.CompletableFuture<java.lang.Void> unsub(MailboxSub sub)

subByUser

public java.util.concurrent.CompletableFuture<java.util.List<MailboxSub>> subByUser(java.lang.String userName)

registerFolder

public java.util.concurrent.CompletableFuture<java.lang.Void> registerFolder(MailboxFolder folder)

sieve

public java.util.concurrent.CompletableFuture<java.lang.Void> sieve(SieveData sd)

unsieve

public java.util.concurrent.CompletableFuture<java.lang.Void> unsieve(SieveData sd)

sieveByUser

public java.util.concurrent.CompletableFuture<java.util.List<SieveScript>> sieveByUser(java.lang.String userName)

seenOverlay

public java.util.concurrent.CompletableFuture<java.lang.Void> seenOverlay(SeenOverlay seen)

seenOverlayByUser

public java.util.concurrent.CompletableFuture<java.util.List<SeenOverlay>> seenOverlayByUser(java.lang.String userName)

updateRecords

public java.util.concurrent.CompletableFuture<java.lang.Void> updateRecords(java.lang.String boxUniqueId,
                                                                            java.util.List<MailboxRecord> mboxState)

rename

public java.util.concurrent.CompletableFuture<java.lang.Void> rename(java.lang.String from,
                                                                     java.lang.String to)

delete

public java.util.concurrent.CompletableFuture<java.lang.Void> delete(java.lang.String toDel)

records

public java.util.concurrent.CompletableFuture<java.util.List<MboxRecord>> records(MailboxFolder known)

expunge

public java.util.concurrent.CompletableFuture<java.lang.Void> expunge(java.lang.String mbox,
                                                                      java.util.List<java.lang.Long> uid)

checkCredentials

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