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	INDEX_PENDING
static java.lang.String	INDEX_PENDING_ALIAS
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)
void	repairMailbox(java.lang.String entityId, IServerTaskMonitor monitor) check if alias exists, if not create it.
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

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

INDEX_PENDING

public static final java.lang.String INDEX_PENDING

See Also:

Constant Field Values

INDEX_PENDING_ALIAS

public static final java.lang.String INDEX_PENDING_ALIAS

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

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)

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