net.bluemind.backend.cyrus.replication.client

Class SyncClient

java.lang.Object

net.bluemind.backend.cyrus.replication.client.SyncClient

public class SyncClient
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SyncClient(java.lang.String host, int port)
SyncClient(io.vertx.core.Vertx vertx, java.lang.String host, int port)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<UnparsedResponse>	applyAnnotation(java.lang.String mbox, java.lang.String entry, java.lang.String userId, java.lang.String value)
java.util.concurrent.CompletableFuture<UnparsedResponse>	applyMessage(java.lang.String partition, java.lang.String guid, java.io.InputStream data)
java.util.concurrent.CompletableFuture<UnparsedResponse>	applyMessages(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream)
java.util.concurrent.CompletionStage<UnparsedResponse>	applyReserve(java.lang.String partition, java.util.List<java.lang.String> mailboxes, java.util.List<java.lang.String> guids)
java.util.concurrent.CompletionStage<UnparsedResponse>	applyUnmailbox(java.lang.String mbox)
java.util.concurrent.CompletableFuture<java.lang.Void>	authenticate(java.lang.String login, java.lang.String password)
static java.lang.String	authToken(java.lang.String login, java.lang.String password)
java.util.concurrent.CompletableFuture<java.lang.Void>	connect()
java.util.concurrent.CompletableFuture<java.lang.Void>	disconnect()
java.util.concurrent.CompletableFuture<UnparsedResponse>	fetch(java.lang.String partition, java.lang.String mbox, java.lang.String uniqueId, java.lang.String bodyGuid, long imapUid) GET FETCH %(MBOXNAME fws.fr!user.dani PARTITION bm-master__fws_fr UNIQUEID k3j4ly1rzg13gtex5nwmo3r5 GUID 3935e077b8a883b05105e1984166542c3ab2cdab UID 13238)
java.util.concurrent.CompletableFuture<UnparsedResponse>	getFullMailbox(java.lang.String mbox)
java.util.concurrent.CompletableFuture<UnparsedResponse>	getMailboxes(java.lang.String... mboxes)
java.util.concurrent.CompletableFuture<UnparsedResponse>	getMeta(java.lang.String loginAtDomain)
java.util.concurrent.CompletableFuture<UnparsedResponse>	getUser(java.lang.String loginAtDomain)
java.util.concurrent.CompletableFuture<UnparsedResponse>	rawCommand(java.lang.String cmd)
java.util.concurrent.CompletableFuture<java.lang.Void>	startTLS()

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncClient

public SyncClient(java.lang.String host,
                  int port)

SyncClient

public SyncClient(io.vertx.core.Vertx vertx,
                  java.lang.String host,
                  int port)

Method Detail

connect

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

startTLS

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

authenticate

public java.util.concurrent.CompletableFuture<java.lang.Void> authenticate(java.lang.String login,
                                                                           java.lang.String password)

authToken

public static java.lang.String authToken(java.lang.String login,
                                         java.lang.String password)

getUser

public java.util.concurrent.CompletableFuture<UnparsedResponse> getUser(java.lang.String loginAtDomain)

applyMessages

public java.util.concurrent.CompletableFuture<UnparsedResponse> applyMessages(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream)

applyMessage

public java.util.concurrent.CompletableFuture<UnparsedResponse> applyMessage(java.lang.String partition,
                                                                             java.lang.String guid,
                                                                             java.io.InputStream data)

rawCommand

public java.util.concurrent.CompletableFuture<UnparsedResponse> rawCommand(java.lang.String cmd)

applyAnnotation

public java.util.concurrent.CompletableFuture<UnparsedResponse> applyAnnotation(java.lang.String mbox,
                                                                                java.lang.String entry,
                                                                                java.lang.String userId,
                                                                                java.lang.String value)

getMeta

public java.util.concurrent.CompletableFuture<UnparsedResponse> getMeta(java.lang.String loginAtDomain)

getMailboxes

public java.util.concurrent.CompletableFuture<UnparsedResponse> getMailboxes(java.lang.String... mboxes)

getFullMailbox

public java.util.concurrent.CompletableFuture<UnparsedResponse> getFullMailbox(java.lang.String mbox)

fetch

public java.util.concurrent.CompletableFuture<UnparsedResponse> fetch(java.lang.String partition,
                                                                      java.lang.String mbox,
                                                                      java.lang.String uniqueId,
                                                                      java.lang.String bodyGuid,
                                                                      long imapUid)

GET FETCH %(MBOXNAME fws.fr!user.dani PARTITION bm-master__fws_fr UNIQUEID k3j4ly1rzg13gtex5nwmo3r5 GUID 3935e077b8a883b05105e1984166542c3ab2cdab UID 13238)

Parameters:

partition -

mbox -

uniqueId -

guid -

imapUid -

Returns:

disconnect

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

applyReserve

public java.util.concurrent.CompletionStage<UnparsedResponse> applyReserve(java.lang.String partition,
                                                                           java.util.List<java.lang.String> mailboxes,
                                                                           java.util.List<java.lang.String> guids)

applyUnmailbox

public java.util.concurrent.CompletionStage<UnparsedResponse> applyUnmailbox(java.lang.String mbox)