processor

Documentation

Index

• func CreateDoc(timestamp time.Time, docMappings []m.DocMapping) beat.Event
• func CreateSchema(schemaData string, url string) *jsonschema.Schema
• func Validate(buf []byte, schema *jsonschema.Schema) error
• type NewProcessor
• type Processor

Functions

func CreateDoc

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

func CreateSchema

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

func Validate

func Validate(buf []byte, schema *jsonschema.Schema) error

Types

type NewProcessor

type NewProcessor func() Processor

type Processor

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