process

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.