Home
last modified time | relevance | path

Searched refs:streamDocuments (Results 1 – 10 of 10) sorted by relevance

/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoimport/
H A Dcsv.go133 csvErrChan <- streamDocuments(ordered, r.numDecoders, csvRecordChan, readDocs)
H A Dtsv.go145 tsvErrChan <- streamDocuments(ordered, r.numDecoders, tsvRecordChan, readDocs)
H A Djson.go145 jsonErrChan <- streamDocuments(ordered, r.numDecoders, rawChan, readChan)
H A Dcommon_test.go530 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldBeNil)
551 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldNotBeNil)
H A Dcommon.go303 func streamDocuments(ordered bool, numDecoders int, readDocs chan Converter, outputChan chan bson.D… func
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongoimport/
H A Dcsv.go133 csvErrChan <- streamDocuments(ordered, r.numDecoders, csvRecordChan, readDocs)
H A Dtsv.go145 tsvErrChan <- streamDocuments(ordered, r.numDecoders, tsvRecordChan, readDocs)
H A Djson.go151 jsonErrChan <- streamDocuments(ordered, r.numDecoders, rawChan, readChan)
H A Dcommon_test.go539 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldBeNil)
560 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldNotBeNil)
H A Dcommon.go285 func streamDocuments(ordered bool, numDecoders int, readDocs chan Converter, outputChan chan bson.D… func