| components/extractor/util.go | 22 |
|
|
| components/index/cache/errors.go | 11 |
|
|
| components/index/cache/index.go | 153 |
|
|
| components/index/cache/reflect.go | 15 |
|
|
| components/index/index.go | 10 |
|
|
| components/index/opensearch/bulkgetter/asyncgetter.go | 21 |
|
|
| components/index/opensearch/bulkgetter/bulkgetter.go | 86 |
|
|
| components/index/opensearch/bulkgetter/bulkrequest.go | 260 |
|
|
| components/index/opensearch/bulkgetter/config.go | 10 |
|
|
| components/index/opensearch/bulkgetter/mock.go | 19 |
|
|
| components/index/opensearch/bulkgetter/reqresp.go | 14 |
|
|
| components/index/opensearch/client.go | 129 |
|
|
| components/index/opensearch/config.go | 4 |
|
|
| components/index/opensearch/index.go | 122 |
|
|
| components/index/redis/client.go | 73 |
|
|
| components/index/redis/config.go | 5 |
|
|
| components/index/redis/existsindex.go | 67 |
|
|
| components/index/redis/index.go | 89 |
|
|
| components/index/types/directory.go | 19 |
|
|
| components/index/types/document.go | 10 |
|
|
| components/index/types/file.go | 16 |
|
|
| components/index/types/invalid.go | 4 |
|
|
| components/index/types/nfsw.go | 13 |
|
|
| components/index/types/partial.go | 2 |
|
|
| components/index/types/references.go | 36 |
|
|
| components/index/types/update.go | 8 |
|
|
| components/protocol/mock.go | 26 |
|
|
| components/protocol/protocol.go | 10 |
|
|
| components/queue/amqp/channel.go | 42 |
|
|
| components/queue/amqp/config.go | 18 |
|
|
| components/queue/amqp/connection.go | 110 |
|
|
| components/queue/amqp/publisherfactory.go | 35 |
|
|
| components/queue/amqp/queue.go | 65 |
|
|
| components/queue/mock.go | 26 |
|
|
| components/queue/queue.go | 18 |
|
|
| components/sniffer/eventsource/event.go | 11 |
|
|
| components/sniffer/handler/handler.go | 43 |
|
|
| components/sniffer/providerfilters/interfaces.go | 7 |
|
|
| components/worker/pool/getconsumechans.go | 28 |
|
|
| components/worker/pool/getcrawler.go | 25 |
|
|
| components/worker/pool/getextractors.go | 16 |
|
|
| components/worker/pool/getindexes.go | 105 |
|
|
| components/worker/pool/getprotocol.go | 12 |
|
|
| components/worker/pool/getqueues.go | 36 |
|
|
| components/worker/pool/pool.go | 77 |
|
|
| components/worker/worker.go | 70 |
|
|
| instr/config.go | 11 |
|
|
| instr/instr.go | 49 |
|
|
| types/annotatedresource.go | 16 |
|
|
| types/doc.go | 1 |
|
|