diff options
Diffstat (limited to 'events/src')
| -rw-r--r-- | events/src/Makefile.am | 5 | ||||
| -rw-r--r-- | events/src/gf_event.py | 48 |
2 files changed, 51 insertions, 2 deletions
diff --git a/events/src/Makefile.am b/events/src/Makefile.am index 8b2150e3aa9..423bc8891fb 100644 --- a/events/src/Makefile.am +++ b/events/src/Makefile.am @@ -1,6 +1,6 @@ noinst_PYTHON = $(top_srcdir)/events/eventskeygen.py EXTRA_DIST = glustereventsd.py __init__.py eventsapiconf.py.in \ - handlers.py utils.py peer_eventsapi.py eventsconfig.json + handlers.py utils.py peer_eventsapi.py eventsconfig.json gf_event.py BUILT_SOURCES = eventtypes.py CLEANFILES = eventtypes.py @@ -10,7 +10,8 @@ eventspeerscriptdir = $(libexecdir)/glusterfs eventsconfdir = $(sysconfdir)/glusterfs eventsconf_DATA = eventsconfig.json -events_PYTHON = __init__.py eventsapiconf.py eventtypes.py handlers.py utils.py +events_PYTHON = __init__.py eventsapiconf.py eventtypes.py handlers.py \ + utils.py gf_event.py events_SCRIPTS = glustereventsd.py eventspeerscript_SCRIPTS = peer_eventsapi.py diff --git a/events/src/gf_event.py b/events/src/gf_event.py new file mode 100644 index 00000000000..0924a65dddb --- /dev/null +++ b/events/src/gf_event.py @@ -0,0 +1,48 @@ +#!/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 socket +import time + +from eventsapiconf import SERVER_ADDRESS +from eventtypes import all_events + +from utils import logger, setup_logger + +# Run this when this lib loads +setup_logger() + + +def gf_event(event_type, **kwargs): + if not isinstance(event_type, int) or event_type >= len(all_events): + logger.error("Invalid Event Type: {0}".format(event_type)) + return + + try: + client = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) + client.connect(SERVER_ADDRESS) + except socket.error as e: + logger.error("Unable to connect to events.sock: {0}".format(e)) + return + + # Convert key value args into KEY1=VALUE1;KEY2=VALUE2;.. + msg = "" + for k, v in kwargs.items(): + msg += "{0}={1};".format(k, v) + + # <TIMESTAMP> <EVENT_TYPE> <MSG> + msg = "{0} {1} {2}".format(int(time.time()), event_type, msg.strip(";")) + + try: + client.sendall(msg) + except socket.error as e: + logger.error("Unable to Send message: {0}".format(e)) |