From 44638176067df5231bf0be30801e36863391cd1f Mon Sep 17 00:00:00 2001
From: Tim Laszlo <tim.laszlo@gmail.com>
Date: Mon, 8 Oct 2012 10:38:02 -0500
Subject: Reporting: Merge new reporting data

Move reporting data to a new schema
Use south for django migrations
Add bcfg2-report-collector daemon

Conflicts:
	doc/development/index.txt
	doc/server/plugins/connectors/properties.txt
	doc/server/plugins/generators/packages.txt
	setup.py
	src/lib/Bcfg2/Client/Tools/SELinux.py
	src/lib/Bcfg2/Compat.py
	src/lib/Bcfg2/Encryption.py
	src/lib/Bcfg2/Options.py
	src/lib/Bcfg2/Server/Admin/Init.py
	src/lib/Bcfg2/Server/Admin/Reports.py
	src/lib/Bcfg2/Server/BuiltinCore.py
	src/lib/Bcfg2/Server/Core.py
	src/lib/Bcfg2/Server/FileMonitor/Inotify.py
	src/lib/Bcfg2/Server/Plugin/base.py
	src/lib/Bcfg2/Server/Plugin/interfaces.py
	src/lib/Bcfg2/Server/Plugins/Cfg/CfgEncryptedGenerator.py
	src/lib/Bcfg2/Server/Plugins/FileProbes.py
	src/lib/Bcfg2/Server/Plugins/Ohai.py
	src/lib/Bcfg2/Server/Plugins/Packages/Collection.py
	src/lib/Bcfg2/Server/Plugins/Packages/Source.py
	src/lib/Bcfg2/Server/Plugins/Packages/Yum.py
	src/lib/Bcfg2/Server/Plugins/Packages/__init__.py
	src/lib/Bcfg2/Server/Plugins/Probes.py
	src/lib/Bcfg2/Server/Plugins/Properties.py
	src/lib/Bcfg2/Server/Reports/backends.py
	src/lib/Bcfg2/Server/Reports/manage.py
	src/lib/Bcfg2/Server/Reports/nisauth.py
	src/lib/Bcfg2/settings.py
	src/sbin/bcfg2-crypt
	src/sbin/bcfg2-yum-helper
	testsuite/Testsrc/Testlib/TestServer/TestPlugins/TestProbes.py
	testsuite/Testsrc/Testlib/TestServer/TestPlugins/TestSEModules.py
---
 src/lib/Bcfg2/Reporting/Transport/base.py | 45 +++++++++++++++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 src/lib/Bcfg2/Reporting/Transport/base.py

(limited to 'src/lib/Bcfg2/Reporting/Transport/base.py')

diff --git a/src/lib/Bcfg2/Reporting/Transport/base.py b/src/lib/Bcfg2/Reporting/Transport/base.py
new file mode 100644
index 000000000..8488d0e46
--- /dev/null
+++ b/src/lib/Bcfg2/Reporting/Transport/base.py
@@ -0,0 +1,45 @@
+"""
+The base for all server -> collector Transports
+"""
+
+import os.path
+import logging 
+
+class TransportError(Exception):
+    """Generic TransportError"""
+    pass
+
+class TransportImportError(TransportError):
+    """Raised when a transport fails to import"""
+    pass
+
+class TransportBase(object):
+    """The base for all transports"""
+
+    def __init__(self, setup):
+        """Do something here"""
+        clsname = self.__class__.__name__
+        self.logger = logging.getLogger(clsname)
+        self.logger.debug("Loading %s transport" % clsname)
+        self.data = os.path.join(setup['repo'], clsname.split()[-1])
+        self.setup = setup
+        self.timeout = 2
+
+    def start_monitor(self, collector):
+        """Called to start monitoring"""
+        raise NotImplementedError
+
+    def store(self, hostname, payload):
+        raise NotImplementedError
+
+    def fetch(self):
+        raise NotImplementedError
+
+    def shutdown(self):
+        """Called at program exit"""
+        pass
+
+    def rpc(self, method, *args, **kwargs):
+        """Send a request for data to the collector"""
+        raise NotImplementedError
+
-- 
cgit v1.2.3-1-g7c22