org.graylog2.indexer.ranges

Class MongoIndexRangeService

java.lang.Object

org.graylog2.database.PersistedServiceImpl

org.graylog2.indexer.ranges.MongoIndexRangeService

All Implemented Interfaces:

IndexRangeService, PersistedService

public class MongoIndexRangeService
extends PersistedServiceImpl
implements IndexRangeService

Field Summary

Fields inherited from class org.graylog2.database.PersistedServiceImpl

mongoConnection

Constructor Summary

Constructors

Constructor and Description
MongoIndexRangeService(MongoConnection mongoConnection)

Method Summary

Methods

Modifier and Type	Method and Description
IndexRange	calculateRange(String index)
SortedSet<IndexRange>	find(org.joda.time.DateTime begin, org.joda.time.DateTime end)
SortedSet<IndexRange>	findAll()
IndexRange	get(String index)
boolean	isMigrated(String index)
boolean	markAsMigrated(String index)
void	save(IndexRange indexRange)

Methods inherited from class org.graylog2.database.PersistedServiceImpl

collection, collection, count, count, cursorToList, destroy, destroy, destroyAll, destroyAll, destroyAll, embed, findOne, findOne, findOne, findOne, get, get, get, query, query, query, query, query, removeEmbedded, removeEmbedded, save, saveWithoutValidation, totalCount, totalCount, validate, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoIndexRangeService

@Inject
public MongoIndexRangeService(MongoConnection mongoConnection)

Method Detail

get

public IndexRange get(String index)
               throws NotFoundException

Specified by:

get in interface IndexRangeService

Throws:

NotFoundException

find

public SortedSet<IndexRange> find(org.joda.time.DateTime begin,
                         org.joda.time.DateTime end)

Specified by:

find in interface IndexRangeService

findAll

public SortedSet<IndexRange> findAll()

Specified by:

findAll in interface IndexRangeService

save

public void save(IndexRange indexRange)

Specified by:

save in interface IndexRangeService

calculateRange

public IndexRange calculateRange(String index)

Specified by:

calculateRange in interface IndexRangeService

markAsMigrated

public boolean markAsMigrated(String index)

isMigrated

public boolean isMigrated(String index)