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.

target_format string default=timestamp

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`.
	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:"timestamp"` //*
	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
}

{ introduction It converts field date/time data to different format. }

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()