processor

Documentation

Index

• func CreateDoc(timestamp time.Time, docMappings []utility.DocMapping) beat.Event
• func CreateSchema(schemaData string, url string) *jsonschema.Schema
• func Validate(raw interface{}, schema *jsonschema.Schema) error
• type Config
• type NewProcessor
• type Processor

Functions

func CreateDoc

func CreateDoc(timestamp time.Time, docMappings []utility.DocMapping) beat.Event

func CreateSchema

func CreateSchema(schemaData string, url string) *jsonschema.Schema

func Validate

func Validate(raw interface{}, schema *jsonschema.Schema) error

Types

type Config

type Config struct {
	SmapMapper          sourcemap.Mapper
	LibraryPattern      *regexp.Regexp
	ExcludeFromGrouping *regexp.Regexp
}

type NewProcessor

type NewProcessor func(conf *Config) Processor

type Processor

type Processor interface {
	Validate(map[string]interface{}) error
	Transform(interface{}) ([]beat.Event, error)
	Name() string
}