processor

Documentation

Index

• Constants
• 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

Constants

const (
	Backend = iota
	Frontend
	HealthCheck
)

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
}