org.graylog2.indexer.ranges

Class EsIndexRangeService

java.lang.Object

org.graylog2.indexer.ranges.EsIndexRangeService

All Implemented Interfaces:

IndexRangeService

@Singleton
public class EsIndexRangeService
extends Object
implements IndexRangeService

Constructor Summary

Constructors

Constructor and Description
EsIndexRangeService(org.elasticsearch.client.Client client, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Indices indices, Deflector deflector, com.google.common.eventbus.EventBus eventBus, com.google.common.eventbus.EventBus clusterEventBus, com.codahale.metrics.MetricRegistry metricRegistry)

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)
void	handleIndexDeletion(IndicesDeletedEvent event)
void	handleIndexRangeUpdate(IndexRangeUpdatedEvent event)
void	save(IndexRange indexRange)
protected TimestampStats	timestampStatsOfIndex(String index) Calculate stats (min, max, avg) about the message timestamps in the given index.

Methods inherited from class java.lang.Object

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

Constructor Detail

EsIndexRangeService

@Inject
public EsIndexRangeService(org.elasticsearch.client.Client client,
                          com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                          Indices indices,
                          Deflector deflector,
                          com.google.common.eventbus.EventBus eventBus,
                          com.google.common.eventbus.EventBus clusterEventBus,
                          com.codahale.metrics.MetricRegistry metricRegistry)

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

calculateRange

public IndexRange calculateRange(String index)

Specified by:

calculateRange in interface IndexRangeService

timestampStatsOfIndex

protected TimestampStats timestampStatsOfIndex(String index)

Calculate stats (min, max, avg) about the message timestamps in the given index.

Parameters:

index - Name of the index to query.

Returns:

the timestamp stats in the given index, or null if they couldn't be calculated.

See Also:

Stats

save

public void save(IndexRange indexRange)

Specified by:

save in interface IndexRangeService

handleIndexDeletion

public void handleIndexDeletion(IndicesDeletedEvent event)

handleIndexRangeUpdate

public void handleIndexRangeUpdate(IndexRangeUpdatedEvent event)