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

addlow to add node allocation ot the module

This commit is contained in:
kimchy 2010-08-22 12:35:59 +03:00
parent 664f28492d
commit 36ad3b246a
2 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.idea/dictionaries/kimchy.xml
View File

@ -81,6 +81,7 @@
<w>millis</w>
<w>mmap</w>
<w>multi</w>
<w>multibinder</w>
<w>multicast</w>
<w>multiline</w>
<w>mvel</w>

20
modules/elasticsearch/src/main/java/org/elasticsearch/cluster/routing/allocation/ShardAllocationModule.java
View File

@ -19,26 +19,38 @@
package org.elasticsearch.cluster.routing.allocation;
import org.elasticsearch.common.collect.Lists;
import org.elasticsearch.common.inject.AbstractModule;
import org.elasticsearch.common.inject.multibindings.Multibinder;
import org.elasticsearch.common.settings.Settings;
import java.util.List;
/**
* @author kimchy (shay.banon)
*/
public class ShardAllocationModule extends AbstractModule {
private List<Class<? extends NodeAllocation>> allocations = Lists.newArrayList();
public ShardAllocationModule(Settings settings) {
}
public void addNodeAllocation(Class<? extends NodeAllocation> nodeAllocation) {
allocations.add(nodeAllocation);
}
@Override protected void configure() {
bind(ShardsAllocation.class).asEagerSingleton();
bind(PreferUnallocatedStrategy.class).to(PreferUnallocatedShardUnassignedStrategy.class).asEagerSingleton();
Multibinder<NodeAllocation> decidersBinder = Multibinder.newSetBinder(binder(), NodeAllocation.class);
decidersBinder.addBinding().to(SameShardNodeAllocation.class);
decidersBinder.addBinding().to(ReplicaAfterPrimaryActiveNodeAllocation.class);
decidersBinder.addBinding().to(ThrottlingNodeAllocation.class);
Multibinder<NodeAllocation> allocationMultibinder = Multibinder.newSetBinder(binder(), NodeAllocation.class);
allocationMultibinder.addBinding().to(SameShardNodeAllocation.class);
allocationMultibinder.addBinding().to(ReplicaAfterPrimaryActiveNodeAllocation.class);
allocationMultibinder.addBinding().to(ThrottlingNodeAllocation.class);
for (Class<? extends NodeAllocation> allocation : allocations) {
allocationMultibinder.addBinding().to(allocation);
}
bind(NodeAllocations.class).asEagerSingleton();
}