honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

iterates over index and executes correct policy

This commit is contained in:
Colin Goodheart-Smithe 2017-11-22 10:30:21 +00:00
parent eba5afefb7
commit a26a5969dd
2 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
x-pack/plugin/src/main/java/org/elasticsearch/xpack/indexlifecycle/IndexLifecycleInitialisationService.java
View File

@ -5,6 +5,8 @@
*/
package org.elasticsearch.xpack.indexlifecycle;
import com.google.common.base.Strings;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.util.SetOnce;
import org.elasticsearch.cluster.ClusterChangedEvent;
@ -26,6 +28,7 @@ import org.elasticsearch.xpack.watcher.trigger.schedule.IntervalSchedule.Interva
import java.io.Closeable;
import java.io.IOException;
import java.time.Clock;
import java.util.SortedMap;
import static org.elasticsearch.xpack.indexlifecycle.IndexLifecycle.NAME;
@ -61,14 +64,16 @@ public class IndexLifecycleInitialisationService extends AbstractComponent
public void triggered(SchedulerEngine.Event event) {
if (event.getJobName().equals(NAME)) {
logger.error("Job triggered: " + event.getJobName() + ", " + event.getScheduledTime() + ", " + event.getTriggeredTime());
// clusterService.state().getMetaData().getIndices().valuesIt()
// .forEachRemaining((idxMeta) -> {
// if (LIFECYCLE_TIMESERIES_NAME_SETTING.get(idxMeta.getSettings())
// != null) {
// // get policy by name
// // idxMeta.getIndex(), idxMeta.getCreationDate(),client
// }
// });
IndexLifecycleMetadata indexLifecycleMetadata = clusterService.state().metaData().custom(IndexLifecycleMetadata.TYPE);
SortedMap<String, LifecyclePolicy> policies = indexLifecycleMetadata.getPolicies();
clusterService.state().getMetaData().getIndices().valuesIt().forEachRemaining((idxMeta) -> {
String policyName = IndexLifecycle.LIFECYCLE_TIMESERIES_NAME_SETTING.get(idxMeta.getSettings());
if (Strings.isNullOrEmpty(policyName) == false) {
logger.error("Checking index for next action: " + idxMeta.getIndex().getName() + " (" + policyName + ")");
LifecyclePolicy policy = policies.get(policyName);
policy.execute(idxMeta, client);
}
});
}
}

5
x-pack/plugin/src/main/java/org/elasticsearch/xpack/indexlifecycle/LifecyclePolicy.java
View File

@ -6,6 +6,7 @@
package org.elasticsearch.xpack.indexlifecycle;
import org.elasticsearch.cluster.AbstractDiffable;
import org.elasticsearch.cluster.metadata.IndexMetaData;
import org.elasticsearch.common.ParseField;
import org.elasticsearch.common.collect.Tuple;
import org.elasticsearch.common.io.stream.StreamInput;
@ -16,6 +17,7 @@ import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.ToXContentObject;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.xpack.security.InternalClient;
import java.io.IOException;
import java.util.List;
@ -78,4 +80,7 @@ public class LifecyclePolicy extends AbstractDiffable<LifecyclePolicy> implement
builder.endObject();
return builder;
}
public void execute(IndexMetaData idxMeta, InternalClient client) {
}
}