processors

Documentation

Index

• func RegisterProcessor(typ string, creator func(metric string, cfg []byte) (Processor, error))
• type Processor
  • func NewProcessor(name, typ string, cfg []byte) (Processor, error)
• type Processors
  • func New() *Processors
  • func (ps *Processors) Add(key string, tags map[string]string, name, typ string, config []byte) error
  • func (ps *Processors) Find(name, key string, tags map[string]string) []Processor

Functions

func RegisterProcessor

func RegisterProcessor(typ string, creator func(metric string, cfg []byte) (Processor, error))

RegisterProcessor .

Types

type Processor

type Processor interface {
	Process(content string) (string, map[string]interface{}, map[string]string, map[string]string, error)
	Keys() []*pb.FieldDefine
	Pattern() string
}

Processor .

func NewProcessor

func NewProcessor(name, typ string, cfg []byte) (Processor, error)

NewProcessor .

type Processors

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

Processors .

func New

func New() *Processors

New .

func (*Processors) Add

func (ps *Processors) Add(key string, tags map[string]string, name, typ string, config []byte) error

Add .

func (*Processors) Find

func (ps *Processors) Find(name, key string, tags map[string]string) []Processor

Find .