set_time

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 to put the time.
	Field string `json:"field" required:"true" default:"time"` // *

	// > @3@4@5@6
	// >
	// > Date format to parse a field. This could be one of
	// `unixtime|timestampmilli|timestampmicro|timestampnano|ansic|unixdate|rubydate|rfc822|rfc822z|rfc850|rfc1123|rfc1123z|rfc3339|rfc3339nano|kitchen|stamp|stampmilli|stampmicro|stampnano`
	// or custom time format.
	// See: https://pkg.go.dev/time#Parse
	Format  string `json:"format" default:"rfc3339nano" required:"true"` // *
	Format_ string

	// > @3@4@5@6
	// >
	// > Override field if exists.
	Override bool `json:"override" default:"true"` // *
}

! config-params ^ config-params

type Plugin

type Plugin struct {
	plugin.NoMetricsPlugin
	// 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()