Added demo pollster

ceilometerdemo/pollster/first.py

@@ -0,0 +1,31 @@
+from ceilometer.agent import plugin_base
+from ceilometer import sample
+from oslo_log import log
+from oslo_utils import timeutils
+
+LOG = log.getLogger(__name__)
+
+
+class MyFirstPollster(plugin_base.PollsterBase):
+    @property
+    def default_discovery(self):
+        return "demo.discoverer"
+
+    def get_samples(self, manager, cache, resources):
+        for res in resources:
+            LOG.info('Generating sample for resource %s', res)
+            yield sample.Sample(name='demo.pollstermeter',
+                                type=sample.TYPE_GAUGE,
+                                unit='B',
+                                volume=0.5,
+                                user_id=None,
+                                project_id=None,
+                                resource_id=str(res),
+                                timestamp=timeutils.utcnow().isoformat(),
+                                resource_metadata=None,
+                                source='demo')
+
+
+class MyFirstDiscoverer(plugin_base.DiscoveryBase):
+    def discover(self, manager, param=None):
+        return ['demo://fake_resource']

etc/demo_pipeline.yaml

@@ -0,0 +1,18 @@
+---
+sources:
+    - name: demo
+      interval: 60
+      resources:
+          - demo://static_res1
+          - demo://static_res2
+      discovery:
+          - demo.discoverer
+      meters:
+          - "demo.pollstermeter"
+      sinks:
+          - file_sink
+sinks:
+    - name: file_sink
+      transformers:
+      publishers:
+          - file:///tmp/demo.pollstermeter

requirements.txt

@@ -3,3 +3,5 @@
 # process, which may cause wedges in the gate later.
 
 pbr>=1.6
+oslo.log
+oslo.utils

setup.cfg

@@ -23,6 +23,13 @@ classifier =
 packages =
     ceilometerdemo
 
+[entry_points]
+ceilometer.poll.central = 
+    demo.pollstermeter = ceilometerdemo.pollster.first:MyFirstPollster
+
+ceilometer.discover =
+    demo.discoverer = ceilometerdemo.pollster.first:MyFirstDiscoverer
+
 [build_sphinx]
 source-dir = doc/source
 build-dir = doc/build