1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
// Copyright (C) MongoDB, Inc. 2014-present.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
package archive
import "io"
// NamespaceHeader is a data structure that, as BSON, is found in archives where it indicates
// that either the subsequent stream of BSON belongs to this new namespace, or that the
// indicated namespace will have no more documents (EOF)
type NamespaceHeader struct {
Database string `bson:"db"`
Collection string `bson:"collection"`
EOF bool `bson:"EOF"`
CRC int64 `bson:"CRC"`
}
// CollectionMetadata is a data structure that, as BSON, is found in the prelude of the archive.
// There is one CollectionMetadata per collection that will be in the archive.
type CollectionMetadata struct {
Database string `bson:"db"`
Collection string `bson:"collection"`
Metadata string `bson:"metadata"`
Size int `bson:"size"`
}
// Header is a data structure that, as BSON, is found immediately after the magic
// number in the archive, before any CollectionMetadatas. It is the home of any archive level information
type Header struct {
ConcurrentCollections int32 `bson:"concurrent_collections"`
FormatVersion string `bson:"version"`
ServerVersion string `bson:"server_version"`
ToolVersion string `bson:"tool_version"`
}
const minBSONSize = 4 + 1 // an empty BSON document should be exactly five bytes long
var terminator int32 = -1
var terminatorBytes = []byte{0xFF, 0xFF, 0xFF, 0xFF} // TODO, rectify this with terminator
// MagicNumber is four bytes that are found at the beginning of the archive that indicate that
// the byte stream is an archive, as opposed to anything else, including a stream of BSON documents
const MagicNumber uint32 = 0x8199e26d
const archiveFormatVersion = "0.1"
// Writer is the top level object to contain information about archives in mongodump
type Writer struct {
Out io.WriteCloser
Prelude *Prelude
Mux *Multiplexer
}
// Reader is the top level object to contain information about archives in mongorestore
type Reader struct {
In io.ReadCloser
Demux *Demultiplexer
Prelude *Prelude
}
|
