processor

Documentation

Index

• Variables
• func CreateDoc(strTime string, docMappings []m.DocMapping) beat.Event
• func CreateSchema(schemaData string, url string) *jsonschema.Schema
• func Validate(reader io.Reader, schema *jsonschema.Schema, data Payload) error
• type NewProcessor
• type Payload
• type Processor
• type Register
  • func (r *Register) AddProcessor(path string, p Processor)
  • func (r *Register) GetProcessor(name string) Processor
  • func (r *Register) GetProcessors() map[string]Processor

Variables

var Registry = newRegister()

Registry is a global registry that contains all processors

Functions

func CreateDoc

func CreateDoc(strTime string, docMappings []m.DocMapping) beat.Event

func CreateSchema

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

func Validate

func Validate(reader io.Reader, schema *jsonschema.Schema, data Payload) error

Types

type NewProcessor

type NewProcessor func() Processor

type Payload

type Payload interface {
	Transform() []beat.Event
}

type Processor

type Processor interface {
	Validate(io.Reader) error
	Payload
	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) GetProcessor

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

func (*Register) GetProcessors

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

GetProcessors returns a list of all currently registered processors