streaminput

README

stream-input

a dbus Input plugin that can integrate with external system.

Usage

stream-input is an implementation of dbus Input interface. You only need to import the plugin.

import _ "github.com/dbus-plugin/stream-input"

Configurattion

• cmd

Example:

cmd: ["tail", "-F', "/var/log/messages"]

A complete example

{
    plugins: [
        {
            name: "StreamInput"
            cmd: ["cat", "/var/log/mail.log"]
        }

        {
            name:   "MockOutput"
            blackhole: false
            match:  ["StreamInput", ]
        }
    ]
}

Documentation

Overview

Package streaminput provides a dbus Input plugin that can integrate with external system

Index

• type StreamInput
  • func (this *StreamInput) Ack(pack *engine.Packet) error
  • func (this *StreamInput) End(r engine.InputRunner)
  • func (this *StreamInput) Init(config *conf.Conf)
  • func (this *StreamInput) Run(r engine.InputRunner, h engine.PluginHelper) error
  • func (this *StreamInput) SampleConfig() string

Types

type StreamInput

type StreamInput struct {
	// contains filtered or unexported fields
}

StreamInput is a dbus Input plugin that can integrate with external system.

func (*StreamInput) Ack

func (this *StreamInput) Ack(pack *engine.Packet) error

func (*StreamInput) End

func (this *StreamInput) End(r engine.InputRunner)

func (*StreamInput) Init

func (this *StreamInput) Init(config *conf.Conf)

func (*StreamInput) Run

func (this *StreamInput) Run(r engine.InputRunner, h engine.PluginHelper) error

func (*StreamInput) SampleConfig

func (this *StreamInput) SampleConfig() string