inputexec

README

gogstash input exec

Synopsis

{
	"input": [
		{
			"type": "exec",

			// (required)
			"command": "",

			// (optional), default: []
			"args": [""],

			// (optional), in seconds, default: 60
			"interval": 60
		}
	]
}

Details

• type
  • Must be "exec"
• command
  • Command to run. For example, “uptime”
• args
  • String array
  • Arguments of command
• interval
  • Interval to run the command. Value is in seconds.

Documentation

Index

• Constants
• func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeInputConfig, err error)
• func IsMsgType(s string) bool
• type InputConfig
  • func DefaultInputConfig() InputConfig
  • func (self *InputConfig) Exec(inchan config.InChan, logger *logrus.Logger)
  • func (self *InputConfig) Start()
• type MsgType
  • func ParseMsgType(s string) MsgType
  • func (t MsgType) MarshalJSON() ([]byte, error)
  • func (t *MsgType) Scan(value interface{}) (err error)
  • func (t MsgType) String() string
  • func (t *MsgType) UnmarshalJSON(b []byte) (err error)
  • func (t MsgType) Value() (v driver.Value, err error)

Constants

const (
	ModuleName = "exec"
)

Functions

func InitHandler

func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeInputConfig, err error)

func IsMsgType

func IsMsgType(s string) bool

Types

type InputConfig

type InputConfig struct {
	config.InputConfig
	Command   string   `json:"command"`                  // Command to run. e.g. “uptime”
	Args      []string `json:"args,omitempty"`           // Arguments of command
	Interval  int      `json:"interval,omitempty"`       // Second, default: 60
	MsgTrim   string   `json:"message_trim,omitempty"`   // default: " \t\r\n"
	MsgPrefix string   `json:"message_prefix,omitempty"` // only in text type, e.g. "%{@timestamp} [uptime] "
	MsgType   MsgType  `json:"message_type,omitempty"`   // default: "text"
	// contains filtered or unexported fields
}

func DefaultInputConfig

func DefaultInputConfig() InputConfig

func (*InputConfig) Exec

func (self *InputConfig) Exec(inchan config.InChan, logger *logrus.Logger)

func (*InputConfig) Start

func (self *InputConfig) Start()

type MsgType

type MsgType int8

const (
	MsgTypeText MsgType = 1 + iota
	MsgTypeJson
)

func ParseMsgType

func ParseMsgType(s string) MsgType

func (MsgType) MarshalJSON

func (t MsgType) MarshalJSON() ([]byte, error)

func (*MsgType) Scan

func (t *MsgType) Scan(value interface{}) (err error)

func (MsgType) String

func (t MsgType) String() string

func (*MsgType) UnmarshalJSON

func (t *MsgType) UnmarshalJSON(b []byte) (err error)

func (MsgType) Value

func (t MsgType) Value() (v driver.Value, err error)