action

Documentation

Index

• Constants
• Variables
• func RegisterAction(name string, f Factory)
• type Action
• type Add
  • func NewAdd(args []string) (*Add, error)
• type Config
  • func (c *Config) ToActionCfg() (*ConfigAction, error)
  • func (c *Config) Validate() error
• type ConfigAction
• type Copy
  • func NewCopy(args []string) (*Copy, error)
• type Del
  • func NewDel(args []string) (*Del, error)
• type DropEvent
  • func NewDropEvent(args []string) (*DropEvent, error)
• type Factory
• type Fmt
  • func NewFmt(args []string, extra cfg.CommonCfg) (*Fmt, error)
• type FmtKey
  • func NewFmtKey(args []string, extra cfg.CommonCfg) (*FmtKey, error)
• type FmtKeyExtra
• type Instance
  • func GetAction(c Config) (*Instance, error)
  • func (a *Instance) Exec(e api.Event) error
• type JsonDecode
  • func NewJsonDecode(args []string) (*JsonDecode, error)
• type Move
  • func NewMove(args []string) (*Move, error)
• type Print
  • func NewPrint(args []string) (*Print, error)
• type Regex
  • func NewRegex(args []string, extra cfg.CommonCfg) (*Regex, error)
• type Return
  • func NewReturn(args []string) (*Return, error)
• type Set
  • func NewSet(args []string) (*Set, error)
• type StrConvert
  • func NewStrConvert(args []string) (*StrConvert, error)
• type Timestamp
  • func NewTimestamp(args []string, extra cfg.CommonCfg) (*Timestamp, error)
• type UnderRoot
  • func NewUnderRoot(args []string) (*UnderRoot, error)

Constants

const (
	AddName     = "add"
	AddUsageMsg = "usage: add(key, value)"
)

const (
	CopyName     = "copy"
	CopyUsageMsg = "usage: copy(from, to)"
)

const (
	DelName     = "del"
	DelUsageMsg = "usage: del(key1, key2...)"
)

const (
	DropEventName     = "dropEvent"
	DropEventUsageMsg = "usage: dropEvent()"
)

const (
	FmtName     = "fmt"
	FmtUsageMsg = "usage: fmt(key)"
)

const (
	FmtKeyName     = "fmtKey"
	FmtKeyUsageMsg = "usage: fmtKey()"
)

const (
	JsonDecodeName     = "jsonDecode"
	JsonDecodeUsageMsg = "usage: jsonDecode(key) or jsonDecode(key, to)"
)

const (
	MoveName     = "move"
	MoveUsageMsg = "usage: move(from, to)"
)

const (
	PrintName     = "print"
	PrintUsageMsg = "usage: print()"
)

const (
	RegexName     = "regex"
	RegexUsageMsg = "usage: regex(key) or regex(key, to)"
)

const (
	ReturnName     = "return"
	ReturnUsageMsg = "usage: return()"
)

const (
	SetName     = "set"
	SetUsageMsg = "usage: set(key, value)"
)

const (
	StrConvertName     = "strconv"
	StrConvertUsageMsg = "usage: strconv(key, type)"
)

const (
	TimestampName     = "timestamp"
	TimestampUsageMsg = "usage: timestamp(key)"

	LayoutUnix   = "unix"
	LayoutUnixMs = "unix_ms"
)

const (
	UnderRootName     = "underRoot"
	UnderRootUsageMsg = "usage: underRoot(key)"
)

const (
	HeaderRoot = "_root"
)

Variables

var ErrorDropEvent = errors.New("DROP_EVENT")

var ErrorReturn = errors.New("RETURN")

Functions

func RegisterAction

func RegisterAction(name string, f Factory)

Types

type Action

type Action interface {
	// contains filtered or unexported methods
}

type Add

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

func NewAdd

func NewAdd(args []string) (*Add, error)

type Config

type Config cfg.CommonCfg

func (*Config) ToActionCfg

func (c *Config) ToActionCfg() (*ConfigAction, error)

func (*Config) Validate

func (c *Config) Validate() error

type ConfigAction

type ConfigAction struct {
	Expression  string        `yaml:"action,omitempty"`
	IgnoreError bool          `yaml:"ignoreError,omitempty"`
	Extra       cfg.CommonCfg `yaml:",inline,omitempty"`
}

type Copy

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

func NewCopy

func NewCopy(args []string) (*Copy, error)

type Del

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

func NewDel

func NewDel(args []string) (*Del, error)

type DropEvent

type DropEvent struct {
}

func NewDropEvent

func NewDropEvent(args []string) (*DropEvent, error)

type Factory

type Factory func(args []string, extra cfg.CommonCfg) (Action, error)

type Fmt

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

func NewFmt

func NewFmt(args []string, extra cfg.CommonCfg) (*Fmt, error)

type FmtKey

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

func NewFmtKey

func NewFmtKey(args []string, extra cfg.CommonCfg) (*FmtKey, error)

type FmtKeyExtra

type FmtKeyExtra struct {
	Regex   string `yaml:"regex,omitempty" validate:"required"`
	Replace string `yaml:"replace,omitempty" validate:"required"`
}

type Instance

type Instance struct {
	Name string
	Action
	Config ConfigAction
}

func GetAction

func GetAction(c Config) (*Instance, error)

GetAction ..

func (*Instance) Exec

func (a *Instance) Exec(e api.Event) error

type JsonDecode

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

func NewJsonDecode

func NewJsonDecode(args []string) (*JsonDecode, error)

type Move

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

func NewMove

func NewMove(args []string) (*Move, error)

type Print

type Print struct {
}

func NewPrint

func NewPrint(args []string) (*Print, error)

type Regex

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

func NewRegex

func NewRegex(args []string, extra cfg.CommonCfg) (*Regex, error)

type Return

type Return struct {
}

func NewReturn

func NewReturn(args []string) (*Return, error)

type Set

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

Set is same with Add

func NewSet

func NewSet(args []string) (*Set, error)

type StrConvert

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

func NewStrConvert

func NewStrConvert(args []string) (*StrConvert, error)

type Timestamp

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

func NewTimestamp

func NewTimestamp(args []string, extra cfg.CommonCfg) (*Timestamp, error)

type UnderRoot

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

func NewUnderRoot

func NewUnderRoot(args []string) (*UnderRoot, error)