convert_date

README

Date convert plugin

It converts field date/time data to different format.

Config params

field cfg.FieldSelector default=time

The event field name which contains date information.

source_formats []string default=rfc3339nano,rfc3339

List of date formats to parse a field. Available list items should be one of ansic|unixdate|rubydate|rfc822|rfc822z|rfc850|rfc1123|rfc1123z|rfc3339|rfc3339nano|kitchen|stamp|stampmilli|stampmicro|stampnano|unixtime|nginx_errorlog.

target_format string default=unixtime

Date format to convert to.

remove_on_fail bool default=false

Remove field if conversion fails.

Generated using insane-doc

Documentation

Index

• type Config
• type Plugin
  • func (p *Plugin) Do(event *pipeline.Event) pipeline.ActionResult
  • func (p *Plugin) Start(config pipeline.AnyConfig, _ *pipeline.ActionPluginParams)
  • func (p *Plugin) Stop()

Types

type Config

type Config struct {
	// > @3@4@5@6
	// >
	// > The event field name which contains date information.
	Field  cfg.FieldSelector `json:"field" parse:"selector" required:"false" default:"time"` // *
	Field_ []string

	// > @3@4@5@6
	// >
	// > List of date formats to parse a field. Available list items should be one of `ansic|unixdate|rubydate|rfc822|rfc822z|rfc850|rfc1123|rfc1123z|rfc3339|rfc3339nano|kitchen|stamp|stampmilli|stampmicro|stampnano|unixtime|nginx_errorlog`.
	SourceFormats  []string `json:"source_formats" default:"rfc3339nano,rfc3339"` // *
	SourceFormats_ []string

	// > @3@4@5@6
	// >
	// > Date format to convert to.
	TargetFormat  string `json:"target_format" default:"unixtime"` // *
	TargetFormat_ string

	// > @3@4@5@6
	// >
	// > Remove field if conversion fails.
	RemoveOnFail bool `json:"remove_on_fail" default:"false"` // *
}

! config-params ^ config-params

type Plugin

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

func (*Plugin) Do

func (p *Plugin) Do(event *pipeline.Event) pipeline.ActionResult

func (*Plugin) Start

func (p *Plugin) Start(config pipeline.AnyConfig, _ *pipeline.ActionPluginParams)

func (*Plugin) Stop

func (p *Plugin) Stop()