honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

add prepare methods to the rest of the groovy APIs

Browse Source
This commit is contained in:
kimchy 2010-06-20 09:31:22 +03:00
parent abde45bb82
commit 41e570d89d
2 changed files with 95 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
plugins/client/groovy/src/main/groovy/org/elasticsearch/groovy/client/GClusterAdminClient.groovy
View File

@ -33,6 +33,12 @@ import org.elasticsearch.action.admin.cluster.node.stats.NodesStatsResponse
import org.elasticsearch.action.admin.cluster.state.ClusterStateRequest
import org.elasticsearch.action.admin.cluster.state.ClusterStateResponse
import org.elasticsearch.client.ClusterAdminClient
import org.elasticsearch.client.action.admin.cluster.health.ClusterHealthRequestBuilder
import org.elasticsearch.client.action.admin.cluster.node.info.NodesInfoRequestBuilder
import org.elasticsearch.client.action.admin.cluster.node.restart.NodesRestartRequestBuilder
import org.elasticsearch.client.action.admin.cluster.node.shutdown.NodesShutdownRequestBuilder
import org.elasticsearch.client.action.admin.cluster.node.stats.NodesStatsRequestBuilder
import org.elasticsearch.client.action.admin.cluster.state.ClusterStateRequestBuilder
import org.elasticsearch.client.internal.InternalClient
import org.elasticsearch.groovy.client.action.GActionFuture
@ -55,6 +61,10 @@ class GClusterAdminClient {
// HEALTH
ClusterHealthRequestBuilder prepareHealth(String... indices) {
clusterAdminClient.prepareHealth(indices)
}
GActionFuture<ClusterHealthResponse> health(Closure c) {
ClusterHealthRequest request = new ClusterHealthRequest()
c.setDelegate request
@ -75,6 +85,10 @@ class GClusterAdminClient {
// STATE
ClusterStateRequestBuilder prepareState() {
clusterAdminClient.prepareState()
}
GActionFuture<ClusterStateResponse> state(Closure c) {
ClusterStateRequest request = new ClusterStateRequest()
c.setDelegate request
@ -95,6 +109,10 @@ class GClusterAdminClient {
// NODES INFO
NodesInfoRequestBuilder prepareNodesInfo(String... nodesIds) {
clusterAdminClient.prepareNodesInfo(nodesIds)
}
GActionFuture<NodesInfoResponse> nodesInfo(Closure c) {
NodesInfoRequest request = new NodesInfoRequest()
c.setDelegate request
@ -115,6 +133,10 @@ class GClusterAdminClient {
// NODES STATS
NodesStatsRequestBuilder prepareNodesStats(String... nodesIds) {
clusterAdminClient.prepareNodesStats(nodesIds)
}
GActionFuture<NodesStatsResponse> nodesStats(Closure c) {
NodesStatsRequest request = new NodesStatsRequest()
c.setDelegate request
@ -135,6 +157,10 @@ class GClusterAdminClient {
// NODES SHUTDOWN
NodesShutdownRequestBuilder prepareNodesShutdown(String... nodesIds) {
clusterAdminClient.prepareNodesShutdown(nodesIds)
}
GActionFuture<NodesShutdownResponse> nodesShutdown(Closure c) {
NodesShutdownRequest request = new NodesShutdownRequest()
c.setDelegate request
@ -155,6 +181,10 @@ class GClusterAdminClient {
// NODES RESTART
NodesRestartRequestBuilder prepareNodesRestart(String... nodesIds) {
clusterAdminClient.prepareNodesRestart(nodesIds)
}
GActionFuture<NodesRestartResponse> nodesRestart(Closure c) {
NodesRestartRequest request = new NodesRestartRequest()
c.setDelegate request

65
plugins/client/groovy/src/main/groovy/org/elasticsearch/groovy/client/GIndicesAdminClient.groovy
View File

@ -41,6 +41,16 @@ import org.elasticsearch.action.admin.indices.refresh.RefreshResponse
import org.elasticsearch.action.admin.indices.status.IndicesStatusRequest
import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse
import org.elasticsearch.client.IndicesAdminClient
import org.elasticsearch.client.action.admin.indices.alias.IndicesAliasesRequestBuilder
import org.elasticsearch.client.action.admin.indices.cache.clear.ClearIndicesCacheRequestBuilder
import org.elasticsearch.client.action.admin.indices.create.CreateIndexRequestBuilder
import org.elasticsearch.client.action.admin.indices.delete.DeleteIndexRequestBuilder
import org.elasticsearch.client.action.admin.indices.flush.FlushRequestBuilder
import org.elasticsearch.client.action.admin.indices.gateway.snapshot.GatewaySnapshotRequestBuilder
import org.elasticsearch.client.action.admin.indices.mapping.put.PutMappingRequestBuilder
import org.elasticsearch.client.action.admin.indices.optimize.OptimizeRequestBuilder
import org.elasticsearch.client.action.admin.indices.refresh.RefreshRequestBuilder
import org.elasticsearch.client.action.admin.indices.status.IndicesStatusRequestBuilder
import org.elasticsearch.client.internal.InternalClient
import org.elasticsearch.groovy.client.action.GActionFuture
import org.elasticsearch.groovy.common.xcontent.GXContentBuilder
@ -63,6 +73,15 @@ class GIndicesAdminClient {
CreateIndexRequest.metaClass.setMapping = {String type, Closure c ->
delegate.mapping(type, new GXContentBuilder().buildAsString(c))
}
CreateIndexRequestBuilder.metaClass.setSettings = {Closure c ->
delegate.setSettings(new GXContentBuilder().buildAsString(c))
}
CreateIndexRequestBuilder.metaClass.settings = {Closure c ->
delegate.setSettings(new GXContentBuilder().buildAsString(c))
}
CreateIndexRequestBuilder.metaClass.addMapping = {String type, Closure c ->
delegate.addMapping(type, new GXContentBuilder().buildAsString(c))
}
PutMappingRequest.metaClass.setSource = {Closure c ->
delegate.source(new GXContentBuilder().buildAsString(c))
@ -70,6 +89,12 @@ class GIndicesAdminClient {
PutMappingRequest.metaClass.source = {Closure c ->
delegate.source(new GXContentBuilder().buildAsString(c))
}
PutMappingRequestBuilder.metaClass.setSource = {Closure c ->
delegate.setSource(new GXContentBuilder().buildAsString(c))
}
PutMappingRequestBuilder.metaClass.source = {Closure c ->
delegate.setSource(new GXContentBuilder().buildAsString(c))
}
}
private final GClient gClient
@ -86,6 +111,10 @@ class GIndicesAdminClient {
// STATUS
IndicesStatusRequestBuilder prepareStatus(String... indices) {
indicesAdminClient.prepareStatus(indices)
}
GActionFuture<IndicesStatusResponse> status(Closure c) {
IndicesStatusRequest request = new IndicesStatusRequest()
c.setDelegate request
@ -106,6 +135,10 @@ class GIndicesAdminClient {
// CREATE
CreateIndexRequestBuilder prepareCreate(String index) {
indicesAdminClient.prepareCreate(index)
}
GActionFuture<CreateIndexResponse> create(Closure c) {
CreateIndexRequest request = new CreateIndexRequest()
c.setDelegate request
@ -126,6 +159,10 @@ class GIndicesAdminClient {
// DELETE
DeleteIndexRequestBuilder prepareDelete(String index) {
indicesAdminClient.prepareDelete(index)
}
GActionFuture<DeleteIndexResponse> delete(Closure c) {
DeleteIndexRequest request = new DeleteIndexRequest()
c.setDelegate request
@ -146,6 +183,10 @@ class GIndicesAdminClient {
// REFRESH
RefreshRequestBuilder prepareRefresh(String... indices) {
indicesAdminClient.prepareRefresh(indices)
}
GActionFuture<RefreshResponse> refresh(Closure c) {
RefreshRequest request = new RefreshRequest()
c.setDelegate request
@ -166,6 +207,10 @@ class GIndicesAdminClient {
// FLUSH
FlushRequestBuilder prepareFlush(String... indices) {
indicesAdminClient.prepareFlush(indices)
}
GActionFuture<FlushResponse> flush(Closure c) {
FlushRequest request = new FlushRequest()
c.setDelegate request
@ -186,6 +231,10 @@ class GIndicesAdminClient {
// OPTIMIZE
OptimizeRequestBuilder prepareOptimize(String... indices) {
indicesAdminClient.prepareOptimize(indices)
}
GActionFuture<OptimizeResponse> optimize(Closure c) {
OptimizeRequest request = new OptimizeRequest()
c.setDelegate request
@ -206,6 +255,10 @@ class GIndicesAdminClient {
// PUT MAPPING
PutMappingRequestBuilder preparePutMapping(String... indices) {
indicesAdminClient.preparePutMapping(indices)
}
GActionFuture<PutMappingResponse> putMapping(Closure c) {
PutMappingRequest request = new PutMappingRequest()
c.setDelegate request
@ -226,6 +279,10 @@ class GIndicesAdminClient {
// GATEWAY SNAPSHOT
GatewaySnapshotRequestBuilder prepareGatewaySnapshot(String... indices) {
indicesAdminClient.prepareGatewaySnapshot(indices)
}
GActionFuture<GatewaySnapshotResponse> gatewaySnapshot(Closure c) {
GatewaySnapshotRequest request = new GatewaySnapshotRequest()
c.setDelegate request
@ -246,6 +303,10 @@ class GIndicesAdminClient {
// Aliases
IndicesAliasesRequestBuilder prepareAliases() {
indicesAdminClient.prepareAliases()
}
GActionFuture<IndicesAliasesResponse> aliases(Closure c) {
IndicesAliasesRequest request = new IndicesAliasesRequest()
c.setDelegate request
@ -266,6 +327,10 @@ class GIndicesAdminClient {
// CLEAR CACHE
ClearIndicesCacheRequestBuilder prepareClearCache(String... indices) {
indicesAdminClient.prepareClearCache(indices)
}
GActionFuture<ClearIndicesCacheResponse> clearCache(Closure c) {
ClearIndicesCacheRequest request = new ClearIndicesCacheRequest()
c.setDelegate request