Rename package name from marvel.collector to marvel.agent. Also r…

…enamed `CollectorService` to `AgentService` Closes elastic#37
spalger · Jan 22, 2014 · 524f407 · 524f407
1 parent 5ecff51
commit 524f407
Show file tree

Hide file tree

Showing 18 changed files with 137 additions and 97 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,15 +1,15 @@
 /work
-/exporter/logs
 .idea
-/exporter/data
-/exporter/target
+/agent/logs
+/agent/data
+/agent/target
+/agent/.project
+/agent/.classpath
+/agent/.settings
+/agent/config
+/agent/lib
 .DS_Store
 *.iml
-/exporter/.project
-/exporter/.classpath
-/exporter/.settings
-/exporter/config
-/exporter/lib
 /kibana/vendor/kibana
 /node_modules
 /build

diff --git a/exporter/pom.xml → agent/pom.xml b/exporter/pom.xml → agent/pom.xml
diff --git a/exporter/src/main/assemblies/plugin.xml → agent/src/main/assemblies/plugin.xml b/exporter/src/main/assemblies/plugin.xml → agent/src/main/assemblies/plugin.xml
diff --git a/...ch/marvel/collector/CollectorService.java → ...sticsearch/marvel/agent/AgentService.java b/...ch/marvel/collector/CollectorService.java → ...sticsearch/marvel/agent/AgentService.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector;
+package org.elasticsearch.marvel.agent;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -53,9 +53,9 @@
 import org.elasticsearch.indices.IndicesLifecycle;
 import org.elasticsearch.indices.IndicesService;
 import org.elasticsearch.indices.InternalIndicesService;
-import org.elasticsearch.marvel.collector.event.*;
-import org.elasticsearch.marvel.collector.exporter.ESExporter;
-import org.elasticsearch.marvel.collector.exporter.Exporter;
+import org.elasticsearch.marvel.agent.event.*;
+import org.elasticsearch.marvel.agent.exporter.ESExporter;
+import org.elasticsearch.marvel.agent.exporter.Exporter;
 import org.elasticsearch.node.service.NodeService;
 
 import java.util.ArrayList;
@@ -65,7 +65,7 @@
 
 import static org.elasticsearch.common.collect.Lists.newArrayList;
 
-public class CollectorService extends AbstractLifecycleComponent<CollectorService> {
+public class AgentService extends AbstractLifecycleComponent<AgentService> {
 
     private final InternalIndicesService indicesService;
     private final NodeService nodeService;
@@ -87,10 +87,10 @@ public class CollectorService extends AbstractLifecycleComponent<CollectorServic
     private final BlockingQueue<Event> pendingEventsQueue;
 
     @Inject
-    public CollectorService(Settings settings, IndicesService indicesService,
-                            NodeService nodeService, ClusterService clusterService,
-                            Client client, Discovery discovery, ClusterName clusterName,
-                            Environment environment, Plugin marvelPlugin) {
+    public AgentService(Settings settings, IndicesService indicesService,
+                        NodeService nodeService, ClusterService clusterService,
+                        Client client, Discovery discovery, ClusterName clusterName,
+                        Environment environment, Plugin marvelPlugin) {
         super(settings);
         this.indicesService = (InternalIndicesService) indicesService;
         this.clusterService = clusterService;
@@ -122,7 +122,7 @@ protected void doStart() {
             e.start();
 
         this.exp = new ExportingWorker();
-        this.thread = new Thread(exp, EsExecutors.threadName(settings, "collector"));
+        this.thread = new Thread(exp, EsExecutors.threadName(settings, "marvel.exporters"));
         this.thread.setDaemon(true);
         this.thread.start();
 
@@ -213,13 +213,13 @@ private void exportClusterStats() {
                 try {
                     e.exportClusterStats(stats);
                 } catch (Throwable t) {
-                    logger.error("Exporter [{}] has thrown an exception:", t, e.name());
+                    logger.error("exporter [{}] has thrown an exception:", t, e.name());
                 }
             }
         }
 
         private void exportEvents() {
-            logger.debug("Exporting events");
+            logger.debug("exporting events");
             ArrayList<Event> eventList = new ArrayList<Event>(pendingEventsQueue.size());
             pendingEventsQueue.drainTo(eventList);
             Event[] events = new Event[eventList.size()];
@@ -229,7 +229,7 @@ private void exportEvents() {
                 try {
                     e.exportEvents(events);
                 } catch (Throwable t) {
-                    logger.error("Exporter [{}] has thrown an exception:", t, e.name());
+                    logger.error("exporter [{}] has thrown an exception:", t, e.name());
                 }
             }
         }

diff --git a/...lasticsearch/marvel/collector/Plugin.java → ...rg/elasticsearch/marvel/agent/Plugin.java b/...lasticsearch/marvel/collector/Plugin.java → ...rg/elasticsearch/marvel/agent/Plugin.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.marvel.collector;
+package org.elasticsearch.marvel.agent;
 
 import org.elasticsearch.Version;
 import org.elasticsearch.common.collect.ImmutableList;
@@ -69,7 +69,7 @@ public Collection<Module> modules(Settings settings) {
 
             @Override
             protected void configure() {
-                bind(CollectorService.class).asEagerSingleton();
+                bind(AgentService.class).asEagerSingleton();
             }
         };
         return ImmutableList.of(m);
@@ -79,7 +79,7 @@ protected void configure() {
     public Collection<Class<? extends LifecycleComponent>> services() {
         Collection<Class<? extends LifecycleComponent>> l = new ArrayList<Class<? extends LifecycleComponent>>();
         if (enabled) {
-            l.add(CollectorService.class);
+            l.add(AgentService.class);
         }
         return l;
     }

diff --git a/...elasticsearch/marvel/collector/Utils.java → ...org/elasticsearch/marvel/agent/Utils.java b/...elasticsearch/marvel/collector/Utils.java → ...org/elasticsearch/marvel/agent/Utils.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector;
+package org.elasticsearch.marvel.agent;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file

diff --git a/.../marvel/collector/event/ClusterEvent.java → ...arch/marvel/agent/event/ClusterEvent.java b/.../marvel/collector/event/ClusterEvent.java → ...arch/marvel/agent/event/ClusterEvent.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file

diff --git a/...csearch/marvel/collector/event/Event.java → ...asticsearch/marvel/agent/event/Event.java b/...csearch/marvel/collector/event/Event.java → ...asticsearch/marvel/agent/event/Event.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file

diff --git a/...ch/marvel/collector/event/IndexEvent.java → ...search/marvel/agent/event/IndexEvent.java b/...ch/marvel/collector/event/IndexEvent.java → ...search/marvel/agent/event/IndexEvent.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file

diff --git a/...rch/marvel/collector/event/NodeEvent.java → ...csearch/marvel/agent/event/NodeEvent.java b/...rch/marvel/collector/event/NodeEvent.java → ...csearch/marvel/agent/event/NodeEvent.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -22,7 +22,7 @@
 import org.elasticsearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.common.xcontent.ToXContent;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.marvel.collector.Utils;
+import org.elasticsearch.marvel.agent.Utils;
 
 import java.io.IOException;
 

diff --git a/.../marvel/collector/event/RoutingEvent.java → ...arch/marvel/agent/event/RoutingEvent.java b/.../marvel/collector/event/RoutingEvent.java → ...arch/marvel/agent/event/RoutingEvent.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -23,7 +23,7 @@
 import org.elasticsearch.cluster.routing.ShardRouting;
 import org.elasticsearch.common.xcontent.ToXContent;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.marvel.collector.Utils;
+import org.elasticsearch.marvel.agent.Utils;
 
 import java.io.IOException;
 

diff --git a/...ch/marvel/collector/event/ShardEvent.java → ...search/marvel/agent/event/ShardEvent.java b/...ch/marvel/collector/event/ShardEvent.java → ...search/marvel/agent/event/ShardEvent.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.event;
+package org.elasticsearch.marvel.agent.event;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -25,7 +25,7 @@
 import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.index.shard.IndexShardState;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.marvel.collector.Utils;
+import org.elasticsearch.marvel.agent.Utils;
 
 import java.io.IOException;
 import java.util.Locale;

diff --git a/...marvel/collector/exporter/ESExporter.java → ...rch/marvel/agent/exporter/ESExporter.java b/...marvel/collector/exporter/ESExporter.java → ...rch/marvel/agent/exporter/ESExporter.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.exporter;
+package org.elasticsearch.marvel.agent.exporter;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -41,9 +41,9 @@
 import org.elasticsearch.common.xcontent.smile.SmileXContent;
 import org.elasticsearch.discovery.Discovery;
 import org.elasticsearch.env.Environment;
-import org.elasticsearch.marvel.collector.Plugin;
-import org.elasticsearch.marvel.collector.Utils;
-import org.elasticsearch.marvel.collector.event.Event;
+import org.elasticsearch.marvel.agent.Plugin;
+import org.elasticsearch.marvel.agent.Utils;
+import org.elasticsearch.marvel.agent.event.Event;
 
 import java.io.*;
 import java.net.HttpURLConnection;

diff --git a/...h/marvel/collector/exporter/Exporter.java → ...earch/marvel/agent/exporter/Exporter.java b/...h/marvel/collector/exporter/Exporter.java → ...earch/marvel/agent/exporter/Exporter.java
@@ -1,4 +1,4 @@
-package org.elasticsearch.marvel.collector.exporter;
+package org.elasticsearch.marvel.agent.exporter;
 /*
  * Licensed to ElasticSearch under one
  * or more contributor license agreements.  See the NOTICE file
@@ -24,7 +24,7 @@
 import org.elasticsearch.action.admin.indices.stats.IndicesStatsResponse;
 import org.elasticsearch.action.admin.indices.stats.ShardStats;
 import org.elasticsearch.common.component.LifecycleComponent;
-import org.elasticsearch.marvel.collector.event.Event;
+import org.elasticsearch.marvel.agent.event.Event;
 
 public interface Exporter<T> extends LifecycleComponent<T> {
 

diff --git a/agent/src/main/resources/es-plugin.properties b/agent/src/main/resources/es-plugin.properties
@@ -0,0 +1 @@
+plugin=org.elasticsearch.marvel.agent.Plugin
diff --git a/agent/src/main/resources/marvel_index_template.json b/agent/src/main/resources/marvel_index_template.json
@@ -0,0 +1,96 @@
+{
+    "template": ".marvel*",
+    "settings": {
+        "number_of_shards": 1,
+        "number_of_replicas": 1,
+        "analysis": {
+            "analyzer": {
+                "default": {
+                    "type": "standard",
+                    "stopwords": "_none_"
+                }
+            }
+        }
+    },
+    "mappings": {
+        "_default_": {
+            "dynamic_templates": [
+                {
+                    "string_fields": {
+                        "match": "*",
+                        "match_mapping_type": "string",
+                        "mapping": {
+                            "type": "multi_field",
+                            "fields": {
+                                "{name}": {
+                                    "type": "string",
+                                    "index": "analyzed",
+                                    "omit_norms": true
+                                },
+                                "raw": {
+                                    "type": "string",
+                                    "index": "not_analyzed",
+                                    "ignore_above": 256
+                                }
+                            }
+                        }
+                    }
+                }
+            ]
+        },
+        "node_stats": {
+            "properties": {
+                "indices.percolate.size_in_bytes": {
+                    "type": "long"
+                },
+                "jvm.buffer_pools.direct.used_in_bytes": {
+                    "type": "long"
+                },
+                "jvm.buffer_pools.mapped.used_in_bytes": {
+                    "type": "long"
+                },
+                "jvm.gc.collectors.young.collection_count": {
+                    "type": "long"
+                },
+                "jvm.gc.collectors.young.collection_time_in_millis": {
+                    "type": "long"
+                },
+                "jvm.gc.collectors.old.collection_count": {
+                    "type": "long"
+                },
+                "jvm.gc.collectors.old.collection_time_in_millis": {
+                    "type": "long"
+                },
+                "indices.percolate.total": {
+                    "type": "long"
+                },
+                "indices.percolate.time_in_millis": {
+                    "type": "long"
+                },
+                "indices.percolate.queries": {
+                    "type": "long"
+                },
+                "indices.percolate.memory_size_in_bytes": {
+                    "type": "long"
+                }
+            }
+        },
+        "index_stats": {
+            "properties": {
+                "total.percolate.memory_size_in_bytes": {
+                    "type": "long"
+                },
+                "total.percolate.time_in_millis": {
+                    "type": "long"
+                },
+                "total.percolate.queries": {
+                    "type": "long"
+                },
+                "total.percolate.total": {
+                    "type": "long"
+                }
+            }
+        }
+
+    }
+}
diff --git a/exporter/src/main/resources/es-plugin.properties b/exporter/src/main/resources/es-plugin.properties
diff --git a/exporter/src/main/resources/marvel_index_template.json b/exporter/src/main/resources/marvel_index_template.json