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 D | csv.go | 133 csvErrChan <- streamDocuments(ordered, r.numDecoders, csvRecordChan, readDocs)
|
H A D | tsv.go | 145 tsvErrChan <- streamDocuments(ordered, r.numDecoders, tsvRecordChan, readDocs)
|
H A D | json.go | 145 jsonErrChan <- streamDocuments(ordered, r.numDecoders, rawChan, readChan)
|
H A D | common_test.go | 530 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldBeNil) 551 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldNotBeNil)
|
H A D | common.go | 303 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 D | csv.go | 133 csvErrChan <- streamDocuments(ordered, r.numDecoders, csvRecordChan, readDocs)
|
H A D | tsv.go | 145 tsvErrChan <- streamDocuments(ordered, r.numDecoders, tsvRecordChan, readDocs)
|
H A D | json.go | 151 jsonErrChan <- streamDocuments(ordered, r.numDecoders, rawChan, readChan)
|
H A D | common_test.go | 539 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldBeNil) 560 So(streamDocuments(true, 3, inputChannel, outputChannel), ShouldNotBeNil)
|
H A D | common.go | 285 func streamDocuments(ordered bool, numDecoders int, readDocs chan Converter, outputChan chan bson.D… func
|