processor

Documentation

Index

• Variables
• 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
• type Register
  • func (r *Register) AddProcessor(path string, p Processor)
  • func (r *Register) Processor(name string) Processor
  • func (r *Register) Processors() map[string]Processor

Variables

var Registry = newRegister()

Registry is a global registry that contains all processors

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
}

type Register

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

func (*Register) AddProcessor

func (r *Register) AddProcessor(path string, p Processor)

AddProcessor adds a processor listening on the given path

func (*Register) Processor

func (r *Register) Processor(name string) Processor

func (*Register) Processors

func (r *Register) Processors() map[string]Processor

GetProcessors returns a list of all currently registered processors