process

Documentation

Index

• func Process(ctx context.Context, i *processor.Document) (processor.DocumentTree, error)
• func RegisterDocumentProcessor(p processor.DocumentProcessor, d processor.DocumentType) error
• func Subscribe(ctx context.Context, em collector.Emitter, blobStore *blob.BlobStore, ...) error

Functions

func Process

func Process(ctx context.Context, i *processor.Document) (processor.DocumentTree, error)

Process processes the documents received from the collector to determine their format and document type.

func RegisterDocumentProcessor

func RegisterDocumentProcessor(p processor.DocumentProcessor, d processor.DocumentType) error

func Subscribe

func Subscribe(ctx context.Context, em collector.Emitter, blobStore *blob.BlobStore, emPubSub *emitter.EmitterPubSub) error

Subscribe receives the CD event and decodes the event to obtain the blob store key. The key is used to retrieve the "document" from the blob store to be processed and ingested.