net.bluemind.index.mail

Class MailIndexService

java.lang.Object

net.bluemind.index.mail.MailIndexService

All Implemented Interfaces:

IMailIndexService

public class MailIndexService
extends java.lang.Object
implements IMailIndexService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MailIndexService.InternalMessageSearchResult

Nested classes/interfaces inherited from interface net.bluemind.backend.mail.replica.indexing.IMailIndexService

IMailIndexService.BulkOperation

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CHILD_TYPE
static java.lang.String	JOIN_FIELD
static java.lang.String	PARENT_TYPE
static int	SIZE

Constructor Summary

Constructors

Constructor and Description
MailIndexService()

Method Summary

Modifier and Type	Method and Description
boolean	checkMailbox(java.lang.String entityId)
void	cleanupFolder(ItemValue<Mailbox> box, ItemValue<MailboxFolder> f, java.util.Set<java.lang.Integer> set)
void	createMailbox(java.lang.String mailboxUid)
void	deleteBodyEntries(java.util.List<java.lang.String> bodyIds)
void	deleteBox(ItemValue<Mailbox> box, java.lang.String folderUid)
void	deleteMailbox(java.lang.String entityId)
void	expunge(ItemValue<Mailbox> box, ItemValue<MailboxFolder> f, IDSet set)
java.util.List<MailSummary>	fetchSummary(ItemValue<Mailbox> box, ItemValue<MailboxFolder> f, IDSet set)
double	getArchivedMailSum(java.lang.String userEntityId)
java.util.Set<java.lang.String>	getFolders(java.lang.String entityId)
java.lang.String	getIndexAliasName(java.lang.String entityId)
static org.elasticsearch.client.Client	getIndexClient()
java.util.List<SimpleShardStats>	getLiteStats()
java.util.List<ShardStats>	getStats()
void	moveMailbox(java.lang.String mailboxUid, java.lang.String indexName, boolean deleteSource)
void	repairMailbox(java.lang.String entityId, IServerTaskMonitor monitor) check if alias exists, if not create it.
long	resetMailboxIndex(java.lang.String mailboxUid)
SearchResult	searchItems(java.lang.String dirEntryUid, MailboxFolderSearchQuery searchQuery)
IMailIndexService.BulkOperation	startBulk()
java.util.Map<java.lang.String,java.lang.Object>	storeBody(IndexedMessageBody body)
void	storeMessage(java.lang.String mailboxUniqueId, ItemValue<MailboxRecord> item, java.lang.String user, java.util.Optional<IMailIndexService.BulkOperation> bulk)
void	syncFlags(ItemValue<Mailbox> box, ItemValue<MailboxFolder> f, java.util.List<MailSummary> mails)

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.mail.replica.indexing.IMailIndexService

moveMailbox, storeMessage

Field Detail

SIZE

public static final int SIZE

See Also:

Constant Field Values

JOIN_FIELD

public static final java.lang.String JOIN_FIELD

See Also:

Constant Field Values

PARENT_TYPE

public static final java.lang.String PARENT_TYPE

See Also:

Constant Field Values

CHILD_TYPE

public static final java.lang.String CHILD_TYPE

See Also:

Constant Field Values

Constructor Detail

MailIndexService

public MailIndexService()

Method Detail

getIndexAliasName

public java.lang.String getIndexAliasName(java.lang.String entityId)

storeBody

public java.util.Map<java.lang.String,java.lang.Object> storeBody(IndexedMessageBody body)

Specified by:

storeBody in interface IMailIndexService

deleteBodyEntries

public void deleteBodyEntries(java.util.List<java.lang.String> bodyIds)

Specified by:

deleteBodyEntries in interface IMailIndexService

resetMailboxIndex

public long resetMailboxIndex(java.lang.String mailboxUid)

Specified by:

resetMailboxIndex in interface IMailIndexService

startBulk

public IMailIndexService.BulkOperation startBulk()

Specified by:

startBulk in interface IMailIndexService

storeMessage

public void storeMessage(java.lang.String mailboxUniqueId,
                         ItemValue<MailboxRecord> item,
                         java.lang.String user,
                         java.util.Optional<IMailIndexService.BulkOperation> bulk)

Specified by:

storeMessage in interface IMailIndexService

deleteBox

public void deleteBox(ItemValue<Mailbox> box,
                      java.lang.String folderUid)

Specified by:

deleteBox in interface IMailIndexService

expunge

public void expunge(ItemValue<Mailbox> box,
                    ItemValue<MailboxFolder> f,
                    IDSet set)

Specified by:

expunge in interface IMailIndexService

cleanupFolder

public void cleanupFolder(ItemValue<Mailbox> box,
                          ItemValue<MailboxFolder> f,
                          java.util.Set<java.lang.Integer> set)

Specified by:

cleanupFolder in interface IMailIndexService

getIndexClient

public static org.elasticsearch.client.Client getIndexClient()

fetchSummary

public java.util.List<MailSummary> fetchSummary(ItemValue<Mailbox> box,
                                                ItemValue<MailboxFolder> f,
                                                IDSet set)

Specified by:

fetchSummary in interface IMailIndexService

syncFlags

public void syncFlags(ItemValue<Mailbox> box,
                      ItemValue<MailboxFolder> f,
                      java.util.List<MailSummary> mails)

Specified by:

syncFlags in interface IMailIndexService

getArchivedMailSum

public double getArchivedMailSum(java.lang.String userEntityId)

Specified by:

getArchivedMailSum in interface IMailIndexService

createMailbox

public void createMailbox(java.lang.String mailboxUid)

Specified by:

createMailbox in interface IMailIndexService

getFolders

public java.util.Set<java.lang.String> getFolders(java.lang.String entityId)

Specified by:

getFolders in interface IMailIndexService

deleteMailbox

public void deleteMailbox(java.lang.String entityId)

Specified by:

deleteMailbox in interface IMailIndexService

repairMailbox

public void repairMailbox(java.lang.String entityId,
                          IServerTaskMonitor monitor)

Description copied from interface: IMailIndexService

check if alias exists, if not create it. If alias is an index, delete alias/index and create alias to mailspool

Specified by:

repairMailbox in interface IMailIndexService

checkMailbox

public boolean checkMailbox(java.lang.String entityId)

Specified by:

checkMailbox in interface IMailIndexService

moveMailbox

public void moveMailbox(java.lang.String mailboxUid,
                        java.lang.String indexName,
                        boolean deleteSource)

Specified by:

moveMailbox in interface IMailIndexService

getStats

public java.util.List<ShardStats> getStats()

Specified by:

getStats in interface IMailIndexService

getLiteStats

public java.util.List<SimpleShardStats> getLiteStats()

Specified by:

getLiteStats in interface IMailIndexService

searchItems

public SearchResult searchItems(java.lang.String dirEntryUid,
                                MailboxFolderSearchQuery searchQuery)

Specified by:

searchItems in interface IMailIndexService