procjs

Documentation

Index

• func Builder(config processor.Config) (processor.Interface, error)
• type Processor
  • func New(src string, logger zerolog.Logger) (*Processor, error)
  • func (p *Processor) Close()
  • func (p *Processor) InspectIn(ctx context.Context, id string) *inspector.Session
  • func (p *Processor) InspectOut(ctx context.Context, id string) *inspector.Session
  • func (p *Processor) Process(ctx context.Context, in record.Record) (record.Record, error)

Functions

func Builder

func Builder(config processor.Config) (processor.Interface, error)

Builder parses the config and if valid returns a JS processor, an error otherwise. It requires the config field "script".

Types

type Processor

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

Processor is able to run processors defined in JavaScript.

func New

func New(src string, logger zerolog.Logger) (*Processor, error)

func (*Processor) Close

func (p *Processor) Close()

func (*Processor) InspectIn

func (p *Processor) InspectIn(ctx context.Context, id string) *inspector.Session

func (*Processor) InspectOut

func (p *Processor) InspectOut(ctx context.Context, id string) *inspector.Session

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, in record.Record) (record.Record, error)