docs: def start(host, port=5959, tag='salt/engine/logstash', proto='udp'):
      '''
      Listen to salt events and forward them to logstash
      '''
  
      if proto == 'tcp':
          logstashHandler = logstash.TCPLogstashHandler
      elif proto == 'udp':
          logstashHandler = logstash.UDPLogstashHandler
  
      logstash_logger = logging.getLogger('python-logstash-logger')
      logstash_logger.setLevel(logging.INFO)
      logstash_logger.addHandler(logstashHandler(host, port, version=1))
  
      if __opts__.get('id').endswith('_master'):
          event_bus = salt.utils.event.get_master_event(
                  __opts__,
                  __opts__['sock_dir'],
                  listen=True)
      else:
          event_bus = salt.utils.event.get_event(
              'minion',
              transport=__opts__['transport'],
              opts=__opts__,
              sock_dir=__opts__['sock_dir'],
              listen=True)
          log.debug('Logstash engine started')
  
      while True:
          event = event_bus.get_event()
          if event:
              logstash_logger.info(tag, extra=event)