From 2be99b28595ffab1d503354db832f981ded2671f Mon Sep 17 00:00:00 2001

From: Aravinda VK <avishwan@redhat.com>

Date: Thu, 5 May 2016 18:34:41 +0530

Subject: [PATCH 29/79] eventsapi: Gluster Eventing Feature implementation

[Depends on http://review.gluster.org/14627]

Design is available in `glusterfs-specs`, A change from the design

is support of webhook instead of Websockets as discussed in the design

http://review.gluster.org/13115

Since Websocket support depends on REST APIs, I will add Websocket support

once REST APIs patch gets merged

Usage:

Run following command to start/stop Eventsapi server in all Peers,

which will collect the notifications from any Gluster daemon and emits

to configured client.

    gluster-eventsapi start|stop|restart|reload

Status of running services can be checked using,

    gluster-eventsapi status

Events listener is a HTTP(S) server which listens to events emited by

the Gluster. Create a HTTP Server to listen on POST and register that

URL using,

    gluster-eventsapi webhook-add <URL> [--bearer-token <TOKEN>]

For example, if HTTP Server running in `http://192.168.122.188:9000`

then add that URL using,

    gluster-eventsapi webhook-add http://192.168.122.188:9000

If it expects a Token then specify it using `--bearer-token` or `-t`

We can also test Webhook if all peer nodes can send message or not

using,

    gluster-eventsapi webhook-test <URL> [--bearer-token <TOKEN>]

Configurations can be viewed/updated using,

    gluster-eventsapi config-get [--name]

    gluster-eventsapi config-set <NAME> <VALUE>

    gluster-eventsapi config-reset <NAME|all>

If any one peer node was down during config-set/reset or webhook

modifications, Run sync command from good node when a peer node comes

back. Automatic update is not yet implemented.

    gluster-eventsapi sync

Basic Events Client(HTTP Server) is included with the code, Start

running the client with required port and start listening to the

events.

    /usr/share/glusterfs/scripts/eventsdash.py --port 8080

Default port is 9000, if no port is specified, once it started running

then configure gluster-eventsapi to send events to that client.

Eventsapi Client can be outside of the Cluster, it can be run event on

Windows. But only requirement is the client URL should be accessible

by all peer nodes.(Or ngrok(https://ngrok.com) like tools can be used)

Events implemented with this patch,

- Volume Create

- Volume Start

- Volume Stop

- Volume Delete

- Peer Attach

- Peer Detach

It is easy to add/support more events, since it touches Gluster cmd

code and to avoid merge conflicts I will add support for more events

once this patch merges.

> Reviewed-on: http://review.gluster.org/14248

> Smoke: Gluster Build System <jenkins@build.gluster.org>

> NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>

> CentOS-regression: Gluster Build System <jenkins@build.gluster.org>

> Reviewed-by: Jeff Darcy <jdarcy@redhat.com>

BUG: 1351589

Change-Id: I316827ac9dd1443454df7deffe4f54835f7f6a08

Signed-off-by: Aravinda VK <avishwan@redhat.com>

Reviewed-on: https://code.engineering.redhat.com/gerrit/84620

Reviewed-by: Milind Changire <mchangir@redhat.com>

Reviewed-by: Atin Mukherjee <amukherj@redhat.com>

---

 Makefile.am                              |    2 +-

 cli/src/cli-cmd-peer.c                   |   12 +

 cli/src/cli-cmd-volume.c                 |   24 ++-

 configure.ac                             |   49 +++

 events/Makefile.am                       |    6 +

 events/eventskeygen.py                   |   65 ++++

 events/src/Makefile.am                   |   24 ++

 events/src/__init__.py                   |   10 +

 events/src/eventsapiconf.py.in           |   22 ++

 events/src/eventsconfig.json             |    3 +

 events/src/eventtypes.py                 |    9 +

 events/src/glustereventsd.py             |  151 +++++++++

 events/src/handlers.py                   |   21 ++

 events/src/peer_eventsapi.py             |  521 ++++++++++++++++++++++++++++++

 events/src/utils.py                      |  150 +++++++++

 events/tools/Makefile.am                 |    3 +

 events/tools/eventsdash.py               |   74 +++++

 extras/systemd/Makefile.am               |    8 +-

 extras/systemd/glustereventsd.service.in |   12 +

 glusterfs.spec.in                        |   59 ++++-

 libglusterfs/src/Makefile.am             |    6 +

 libglusterfs/src/events.c                |   83 +++++

 libglusterfs/src/events.h.in             |   23 ++

 libglusterfs/src/eventtypes.h            |   22 ++

 libglusterfs/src/glusterfs.h             |    4 +

 27 files changed, 1378 insertions(+), 5 deletions(-)

 create mode 100644 events/Makefile.am

 create mode 100644 events/eventskeygen.py

 create mode 100644 events/src/Makefile.am

 create mode 100644 events/src/__init__.py

 create mode 100644 events/src/eventsapiconf.py.in

 create mode 100644 events/src/eventsconfig.json

 create mode 100644 events/src/eventtypes.py

 create mode 100644 events/src/glustereventsd.py

 create mode 100644 events/src/handlers.py

 create mode 100644 events/src/peer_eventsapi.py

 create mode 100644 events/src/utils.py

 create mode 100644 events/tools/Makefile.am

 create mode 100644 events/tools/eventsdash.py

 create mode 100644 extras/systemd/glustereventsd.service.in

 create mode 100644 libglusterfs/src/events.c

 create mode 100644 libglusterfs/src/events.h.in

 create mode 100644 libglusterfs/src/eventtypes.h

diff --git a/Makefile.am b/Makefile.am

index d36f530..37cbb86 100644

--- a/Makefile.am

+++ b/Makefile.am

@@ -12,7 +12,7 @@ EXTRA_DIST = autogen.sh \

 SUBDIRS = $(ARGP_STANDALONE_DIR) libglusterfs rpc api xlators glusterfsd \

 	$(FUSERMOUNT_SUBDIR) doc extras cli heal @SYNCDAEMON_SUBDIR@ \

-	@UMOUNTD_SUBDIR@ tools

+	@UMOUNTD_SUBDIR@ tools @EVENTS_SUBDIR@

 pkgconfigdir = @pkgconfigdir@

 pkgconfig_DATA = glusterfs-api.pc libgfchangelog.pc

diff --git a/cli/src/cli-cmd-peer.c b/cli/src/cli-cmd-peer.c

index d6b4ab1..36c328a 100644

--- a/cli/src/cli-cmd-peer.c

+++ b/cli/src/cli-cmd-peer.c

@@ -90,6 +90,12 @@ out:

         CLI_STACK_DESTROY (frame);

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_PEER_ATTACH, "host=%s", (char *)words[2]);

+        }

+#endif

+

         return ret;

 }

@@ -160,6 +166,12 @@ out:

         CLI_STACK_DESTROY (frame);

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_PEER_DETACH, "host=%s", (char *)words[2]);

+        }

+#endif

+

         return ret;

 }

diff --git a/cli/src/cli-cmd-volume.c b/cli/src/cli-cmd-volume.c

index 129d9b9..5296093 100644

--- a/cli/src/cli-cmd-volume.c

+++ b/cli/src/cli-cmd-volume.c

@@ -243,7 +243,11 @@ out:

         }

         CLI_STACK_DESTROY (frame);

-

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_VOLUME_CREATE, "name=%s", (char *)words[2]);

+        }

+#endif

         return ret;

 }

@@ -318,6 +322,12 @@ out:

         CLI_STACK_DESTROY (frame);

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_VOLUME_DELETE, "name=%s", (char *)words[2]);

+        }

+#endif

+

         return ret;

 }

@@ -392,6 +402,12 @@ out:

         CLI_STACK_DESTROY (frame);

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_VOLUME_START, "name=%s", (char *)words[2]);

+        }

+#endif

+

         return ret;

 }

@@ -524,6 +540,12 @@ out:

         CLI_STACK_DESTROY (frame);

+#if (USE_EVENTS)

+        if (ret == 0) {

+                gf_event (EVENT_VOLUME_STOP, "name=%s", (char *)words[2]);

+        }

+#endif

+

         return ret;

 }

diff --git a/configure.ac b/configure.ac

index 9025114..2e0323d 100644

--- a/configure.ac

+++ b/configure.ac

@@ -38,6 +38,7 @@ AC_CONFIG_HEADERS([config.h])

 AC_CONFIG_FILES([Makefile

                 libglusterfs/Makefile

                 libglusterfs/src/Makefile

+                libglusterfs/src/events.h

                 libglusterfs/src/gfdb/Makefile

                 geo-replication/src/peer_gsec_create

                 geo-replication/src/peer_mountbroker

@@ -206,6 +207,7 @@ AC_CONFIG_FILES([Makefile

                 extras/ganesha/ocf/Makefile

                 extras/systemd/Makefile

                 extras/systemd/glusterd.service

+                extras/systemd/glustereventsd.service

                 extras/run-gluster.tmpfiles

                 extras/benchmarking/Makefile

                 extras/hook-scripts/Makefile

@@ -229,6 +231,10 @@ AC_CONFIG_FILES([Makefile

                 extras/hook-scripts/reset/post/Makefile

                 extras/hook-scripts/reset/pre/Makefile

                 extras/snap_scheduler/Makefile

+                events/Makefile

+                events/src/Makefile

+                events/src/eventsapiconf.py

+                events/tools/Makefile

                 contrib/fuse-util/Makefile

                 contrib/umountd/Makefile

                 contrib/uuid/uuid_types.h

@@ -700,6 +706,43 @@ fi

 AC_SUBST(GEOREP_EXTRAS_SUBDIR)

 AM_CONDITIONAL(USE_GEOREP, test "x$enable_georeplication" != "xno")

+# Events section

+AC_ARG_ENABLE([events],

+              AC_HELP_STRING([--disable-events],

+                             [Do not install Events components]))

+

+BUILD_EVENTS=no

+EVENTS_ENABLED=0

+EVENTS_SUBDIR=

+have_python2=no

+if test "x$enable_events" != "xno"; then

+  EVENTS_SUBDIR=events

+  EVENTS_ENABLED=1

+

+  BUILD_EVENTS="yes"

+  AM_PATH_PYTHON()

+  dnl Check if version matches that we require

+  if echo $PYTHON_VERSION | grep ^2; then

+     have_python2=yes

+  fi

+

+  if test "x$have_python2" = "xno"; then

+     if test "x$enable_events" = "xyes"; then

+        AC_MSG_ERROR([python 2.x packages required. exiting..])

+     fi

+     AC_MSG_WARN([python 2.x not found, disabling events])

+     EVENTS_SUBDIR=

+     EVENTS_ENABLED=0

+     BUILD_EVENTS="no"

+  else

+    AC_DEFINE(USE_EVENTS, 1, [define if events enabled])

+  fi

+fi

+AC_SUBST(EVENTS_ENABLED)

+AC_SUBST(EVENTS_SUBDIR)

+AM_CONDITIONAL([BUILD_EVENTS], [test x$BUILD_EVENTS = xyes])

+# end Events section

+

 # CDC xlator - check if libz is present if so enable HAVE_LIB_Z

 BUILD_CDC=yes

 PKG_CHECK_MODULES([ZLIB], [zlib >= 1.2.0],,

@@ -1079,10 +1122,15 @@ eval sbintemp=\"${sbintemp}\"

 eval sbintemp=\"${sbintemp}\"

 SBIN_DIR=${sbintemp}

+sysconfdirtemp="${sysconfdir}"

+eval sysconfdirtemp=\"${sysconfdirtemp}\"

+SYSCONF_DIR=${sysconfdirtemp}

+

 prefix=$prefix_temp

 exec_prefix=$exec_prefix_temp

 AC_SUBST(SBIN_DIR)

+AC_SUBST(SYSCONF_DIR)

 # lazy umount emulation

 UMOUNTD_SUBDIR=""

@@ -1359,4 +1407,5 @@ echo "POSIX ACLs           : $BUILD_POSIX_ACLS"

 echo "Data Classification  : $BUILD_GFDB"

 echo "firewalld-config     : $BUILD_FIREWALLD"

 echo "Experimental xlators : $BUILD_EXPERIMENTAL"

+echo "Events               : $BUILD_EVENTS"

 echo

diff --git a/events/Makefile.am b/events/Makefile.am

new file mode 100644

index 0000000..04a74ef

--- /dev/null

+++ b/events/Makefile.am

@@ -0,0 +1,6 @@

+SUBDIRS = src tools

+

+noinst_PYTHON = eventskeygen.py

+

+install-data-hook:

+	$(INSTALL) -d -m 755 $(DESTDIR)@GLUSTERD_WORKDIR@/events

diff --git a/events/eventskeygen.py b/events/eventskeygen.py

new file mode 100644

index 0000000..656a7dc

--- /dev/null

+++ b/events/eventskeygen.py

@@ -0,0 +1,65 @@

+#!/usr/bin/env python

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

+

+import os

+

+GLUSTER_SRC_ROOT = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))

+eventtypes_h = os.path.join(GLUSTER_SRC_ROOT, "libglusterfs/src/eventtypes.h")

+eventtypes_py = os.path.join(GLUSTER_SRC_ROOT, "events/src/eventtypes.py")

+

+# When adding new keys add it to the END

+keys = (

+    "EVENT_PEER_ATTACH",

+    "EVENT_PEER_DETACH",

+

+    "EVENT_VOLUME_CREATE",

+    "EVENT_VOLUME_START",

+    "EVENT_VOLUME_STOP",

+    "EVENT_VOLUME_DELETE",

+)

+

+LAST_EVENT = "EVENT_LAST"

+

+ERRORS = (

+    "EVENT_SEND_OK",

+    "EVENT_ERROR_INVALID_INPUTS",

+    "EVENT_ERROR_SOCKET",

+    "EVENT_ERROR_CONNECT",

+    "EVENT_ERROR_SEND"

+)

+

+# Generate eventtypes.h

+with open(eventtypes_h, "w") as f:

+    f.write("#ifndef __EVENTTYPES_H__\n")

+    f.write("#define __EVENTTYPES_H__\n\n")

+    f.write("typedef enum {\n")

+    for k in ERRORS:

+        f.write("    {0},\n".format(k))

+    f.write("} event_errors_t;\n")

+

+    f.write("\n")

+

+    f.write("typedef enum {\n")

+    for k in keys:

+        f.write("    {0},\n".format(k))

+

+    f.write("    {0}\n".format(LAST_EVENT))

+    f.write("} eventtypes_t;\n")

+    f.write("\n#endif /* __EVENTTYPES_H__ */\n")

+

+# Generate eventtypes.py

+with open(eventtypes_py, "w") as f:

+    f.write("# -*- coding: utf-8 -*-\n")

+    f.write("all_events = [\n")

+    for ev in keys:

+        f.write('    "{0}",\n'.format(ev))

+    f.write("]\n")

diff --git a/events/src/Makefile.am b/events/src/Makefile.am

new file mode 100644

index 0000000..528f020

--- /dev/null

+++ b/events/src/Makefile.am

@@ -0,0 +1,24 @@

+EXTRA_DIST = glustereventsd.py __init__.py  eventsapiconf.py.in eventtypes.py \

+	handlers.py utils.py peer_eventsapi.py eventsconfig.json

+

+eventsdir = $(libexecdir)/glusterfs/events

+eventspeerscriptdir = $(libexecdir)/glusterfs

+eventsconfdir = $(sysconfdir)/glusterfs

+eventsconf_DATA = eventsconfig.json

+

+events_PYTHON = __init__.py eventsapiconf.py eventtypes.py handlers.py utils.py

+events_SCRIPTS = glustereventsd.py

+eventspeerscript_SCRIPTS = peer_eventsapi.py

+

+install-exec-hook:

+	$(mkdir_p) $(DESTDIR)$(sbindir)

+	rm -f $(DESTDIR)$(sbindir)/glustereventsd

+	ln -s $(libexecdir)/glusterfs/events/glustereventsd.py \

+		$(DESTDIR)$(sbindir)/glustereventsd

+	rm -f $(DESTDIR)$(sbindir)/gluster-eventing

+	ln -s $(libexecdir)/glusterfs/peer_eventsapi.py \

+		$(DESTDIR)$(sbindir)/gluster-eventsapi

+

+uninstall-hook:

+	rm -f $(DESTDIR)$(sbindir)/glustereventsd

+	rm -f $(DESTDIR)$(sbindir)/gluster-eventsapi

diff --git a/events/src/__init__.py b/events/src/__init__.py

new file mode 100644

index 0000000..f27c53a

--- /dev/null

+++ b/events/src/__init__.py

@@ -0,0 +1,10 @@

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

diff --git a/events/src/eventsapiconf.py.in b/events/src/eventsapiconf.py.in

new file mode 100644

index 0000000..702e1d2

--- /dev/null

+++ b/events/src/eventsapiconf.py.in

@@ -0,0 +1,22 @@

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

+

+SERVER_ADDRESS = "@localstatedir@/run/gluster/events.sock"

+DEFAULT_CONFIG_FILE = "@SYSCONF_DIR@/glusterfs/eventsconfig.json"

+CUSTOM_CONFIG_FILE_TO_SYNC = "/events/config.json"

+CUSTOM_CONFIG_FILE = "@GLUSTERD_WORKDIR@" + CUSTOM_CONFIG_FILE_TO_SYNC

+WEBHOOKS_FILE_TO_SYNC = "/events/webhooks.json"

+WEBHOOKS_FILE = "@GLUSTERD_WORKDIR@" + WEBHOOKS_FILE_TO_SYNC

+LOG_FILE = "@localstatedir@/log/glusterfs/events.log"

+EVENTSD = "glustereventsd"

+CONFIG_KEYS = ["log_level"]

+BOOL_CONFIGS = []

+RESTART_CONFIGS = []

diff --git a/events/src/eventsconfig.json b/events/src/eventsconfig.json

new file mode 100644

index 0000000..ce2c775

--- /dev/null

+++ b/events/src/eventsconfig.json

@@ -0,0 +1,3 @@

+{

+    "log_level": "INFO"

+}

diff --git a/events/src/eventtypes.py b/events/src/eventtypes.py

new file mode 100644

index 0000000..4812e65

--- /dev/null

+++ b/events/src/eventtypes.py

@@ -0,0 +1,9 @@

+# -*- coding: utf-8 -*-

+all_events = [

+    "EVENT_PEER_ATTACH",

+    "EVENT_PEER_DETACH",

+    "EVENT_VOLUME_CREATE",

+    "EVENT_VOLUME_START",

+    "EVENT_VOLUME_STOP",

+    "EVENT_VOLUME_DELETE",

+]

diff --git a/events/src/glustereventsd.py b/events/src/glustereventsd.py

new file mode 100644

index 0000000..3fa5768

--- /dev/null

+++ b/events/src/glustereventsd.py

@@ -0,0 +1,151 @@

+#!/usr/bin/env python

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

+

+from __future__ import print_function

+import asyncore

+import socket

+import os

+from multiprocessing import Process, Queue

+import sys

+import signal

+

+from eventtypes import all_events

+import handlers

+import utils

+from eventsapiconf import SERVER_ADDRESS

+from utils import logger

+

+# Global Queue, EventsHandler will add items to the queue

+# and process_event will gets each item and handles it

+events_queue = Queue()

+events_server_pid = None

+

+

+def process_event():

+    """

+    Seperate process which handles all the incoming events from Gluster

+    processes.

+    """

+    while True:

+        data = events_queue.get()

+        logger.debug("EVENT: {0}".format(repr(data)))

+        try:

+            # Event Format <TIMESTAMP> <TYPE> <DETAIL>

+            ts, key, value = data.split(" ", 2)

+        except ValueError:

+            logger.warn("Invalid Event Format {0}".format(data))

+            continue

+

+        data_dict = {}

+        try:

+            # Format key=value;key=value

+            data_dict = dict(x.split('=') for x in value.split(';'))

+        except ValueError:

+            logger.warn("Unable to parse Event {0}".format(data))

+            continue

+

+        try:

+            # Event Type to Function Map, Recieved event data will be in

+            # the form <TIMESTAMP> <TYPE> <DETAIL>, Get Event name for the

+            # recieved Type/Key and construct a function name starting with

+            # handle_ For example: handle_event_volume_create

+            func_name = "handle_" + all_events[int(key)].lower()

+        except IndexError:

+            # This type of Event is not handled?

+            logger.warn("Unhandled Event: {0}".format(key))

+            func_name = None

+

+        if func_name is not None:

+            # Get function from handlers module

+            func = getattr(handlers, func_name, None)

+            # If func is None, then handler unimplemented for that event.

+            if func is not None:

+                func(ts, int(key), data_dict)

+            else:

+                # Generic handler, broadcast whatever received

+                handlers.generic_handler(ts, int(key), data_dict)

+

+

+def process_event_wrapper():

+    try:

+        process_event()

+    except KeyboardInterrupt:

+        return

+

+

+class GlusterEventsHandler(asyncore.dispatcher_with_send):

+

+    def handle_read(self):

+        data = self.recv(8192)

+        if data:

+            events_queue.put(data)

+            self.send(data)

+

+

+class GlusterEventsServer(asyncore.dispatcher):

+

+    def __init__(self):

+        global events_server_pid

+        asyncore.dispatcher.__init__(self)

+        # Start the Events listener process which listens to

+        # the global queue

+        p = Process(target=process_event_wrapper)

+        p.start()

+        events_server_pid = p.pid

+

+        # Create UNIX Domain Socket, bind to path

+        self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)

+        self.bind(SERVER_ADDRESS)

+        self.listen(5)

+

+    def handle_accept(self):

+        pair = self.accept()

+        if pair is not None:

+            sock, addr = pair

+            GlusterEventsHandler(sock)

+

+

+def signal_handler_sigusr2(sig, frame):

+    if events_server_pid is not None:

+        os.kill(events_server_pid, signal.SIGUSR2)

+    utils.load_all()

+

+

+def init_event_server():

+    utils.setup_logger()

+

+    # Delete Socket file if Exists

+    try:

+        os.unlink(SERVER_ADDRESS)

+    except OSError:

+        if os.path.exists(SERVER_ADDRESS):

+            print ("Failed to cleanup socket file {0}".format(SERVER_ADDRESS),

+                   file=sys.stderr)

+            sys.exit(1)

+

+    utils.load_all()

+

+    # Start the Eventing Server, UNIX DOMAIN SOCKET Server

+    GlusterEventsServer()

+    asyncore.loop()

+

+

+def main():

+    try:

+        init_event_server()

+    except KeyboardInterrupt:

+        sys.exit(1)

+

+

+if __name__ == "__main__":

+    signal.signal(signal.SIGUSR2, signal_handler_sigusr2)

+    main()

diff --git a/events/src/handlers.py b/events/src/handlers.py

new file mode 100644

index 0000000..9b756a9

--- /dev/null

+++ b/events/src/handlers.py

@@ -0,0 +1,21 @@

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

+

+import utils

+

+

+def generic_handler(ts, key, data):

+    """

+    Generic handler to broadcast message to all peers, custom handlers

+    can be created by func name handler_<event_name>

+    Ex: handle_event_volume_create(ts, key, data)

+    """

+    utils.publish(ts, key, data)

diff --git a/events/src/peer_eventsapi.py b/events/src/peer_eventsapi.py

new file mode 100644

index 0000000..7887d77

--- /dev/null

+++ b/events/src/peer_eventsapi.py

@@ -0,0 +1,521 @@

+#!/usr/bin/env python

+# -*- coding: utf-8 -*-

+#

+#  Copyright (c) 2016 Red Hat, Inc. <http://www.redhat.com>

+#  This file is part of GlusterFS.

+#

+#  This file is licensed to you under your choice of the GNU Lesser

+#  General Public License, version 3 or any later version (LGPLv3 or

+#  later), or the GNU General Public License, version 2 (GPLv2), in all

+#  cases as published by the Free Software Foundation.

+#

+