jsonlines

Documentation

Index

• type JsonLinesProcessor
  • func (d *JsonLinesProcessor) Unpack(i *processor.Document) ([]*processor.Document, error)
  • func (d *JsonLinesProcessor) ValidateSchema(i *processor.Document) error

Types

type JsonLinesProcessor

type JsonLinesProcessor struct{}

func (*JsonLinesProcessor) Unpack

func (d *JsonLinesProcessor) Unpack(i *processor.Document) ([]*processor.Document, error)

Unpack takes in the document and tries to unpack it if there is a valid decomposition of sub-documents.

For example, a DSSE envelope or a tarball Returns empty list and nil error if nothing to unpack Returns unpacked list and nil error if successfully unpacked

func (*JsonLinesProcessor) ValidateSchema

func (d *JsonLinesProcessor) ValidateSchema(i *processor.Document) error