a simple plugin system

Author: roveo

streamz/__init__.py

@@ -3,6 +3,10 @@
 from .core import *
 from .graph import *
 from .sources import *
+from .plugins import load_plugins
+
+load_plugins()
+
 try:
     from .dask import DaskStream, scatter
 except ImportError:

streamz/plugins.py

@@ -0,0 +1,6 @@
+import pkg_resources
+
+
+def load_plugins():
+    for entry_point in pkg_resources.iter_entry_points("streamz.plugins"):
+        entry_point.load()