ingest_predicates

Documentation

Index

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

Types

type IngestPredicatesProcessor

type IngestPredicatesProcessor struct {
}

IngestPredicatesProcessor processes IngestPredicates documents. Currently only supports JSON IngestPredicates documents

func (*IngestPredicatesProcessor) Unpack

func (p *IngestPredicatesProcessor) Unpack(d *processor.Document) ([]*processor.Document, error)

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

Returns empty list and nil error if nothing to unpack Returns unpacked list and nil error if successfully unpacked

func (*IngestPredicatesProcessor) ValidateSchema

func (p *IngestPredicatesProcessor) ValidateSchema(d *processor.Document) error