From 22459ee17a3ba0b4487f975b6ebe630cab2d9feb Mon Sep 17 00:00:00 2001 From: George Goldberg Date: Thu, 17 Aug 2017 15:05:17 +0100 Subject: PLT-7302: Aggregate Elasticsearch indexes over a certain age. (#7224) * PLT-7302: Aggregate Elasticsearch indexes over a certain age. This is done by a scheduled daily job, in order to keep the shard count to a sensible level in Elasticsearch. * Use map[string]string instead of StringMap --- einterfaces/jobs/elasticsearch.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) (limited to 'einterfaces') diff --git a/einterfaces/jobs/elasticsearch.go b/einterfaces/jobs/elasticsearch.go index 6d6dbe893..ca05b2ef3 100644 --- a/einterfaces/jobs/elasticsearch.go +++ b/einterfaces/jobs/elasticsearch.go @@ -20,3 +20,18 @@ func RegisterElasticsearchIndexerInterface(newInterface ElasticsearchIndexerInte func GetElasticsearchIndexerInterface() ElasticsearchIndexerInterface { return theElasticsearchIndexerInterface } + +type ElasticsearchAggregatorInterface interface { + MakeWorker() model.Worker + MakeScheduler() model.Scheduler +} + +var theElasticsearchAggregatorInterface ElasticsearchAggregatorInterface + +func RegisterElasticsearchAggregatorInterface(newInterface ElasticsearchAggregatorInterface) { + theElasticsearchAggregatorInterface = newInterface +} + +func GetElasticsearchAggregatorInterface() ElasticsearchAggregatorInterface { + return theElasticsearchAggregatorInterface +} -- cgit v1.2.3-1-g7c22