Versions in this module Expand all Collapse all v1 v1.4.3 Nov 17, 2021 v1.4.2 Nov 17, 2021 Changes in this version + const MagicNumber + const NamespaceClosed + const NamespaceOpened + const NamespaceUnopened + type CollectionMetadata struct + Collection string + Database string + Metadata string + Size int + Type string + type Demultiplexer struct + In io.Reader + NamespaceChan chan string + NamespaceErrorChan chan error + NamespaceStatus map[string]int + func CreateDemux(namespaceMetadatas []*CollectionMetadata, in io.Reader) *Demultiplexer + func (demux *Demultiplexer) BodyBSON(buf []byte) error + func (demux *Demultiplexer) End() error + func (demux *Demultiplexer) HeaderBSON(buf []byte) error + func (demux *Demultiplexer) NewPrioritizer(mgr *intents.Manager) *Prioritizer + func (demux *Demultiplexer) Open(ns string, out DemuxOut) + func (demux *Demultiplexer) Run() error + type DemuxOut interface + End func() + Sum64 func() (uint64, bool) + Write func([]byte) (int, error) + type DirLike interface + IsDir func() bool + Name func() string + Parent func() DirLike + Path func() string + ReadDir func() ([]DirLike, error) + Size func() int64 + Stat func() (DirLike, error) + type Header struct + ConcurrentCollections int32 + FormatVersion string + ServerVersion string + ToolVersion string + type MetadataFile struct + Intent *intents.Intent + func (md *MetadataFile) Close() error + func (md *MetadataFile) Open() error + func (md *MetadataFile) Pos() int64 + func (md *MetadataFile) Read(p []byte) (int, error) + type MetadataPreludeFile struct + Intent *intents.Intent + Origin string + Prelude *Prelude + func (mpf *MetadataPreludeFile) Close() error + func (mpf *MetadataPreludeFile) Open() error + func (mpf *MetadataPreludeFile) Pos() int64 + func (mpf *MetadataPreludeFile) Read(p []byte) (int, error) + type Multiplexer struct + Completed chan error + Control chan *MuxIn + Out io.WriteCloser + func NewMultiplexer(out io.WriteCloser, shutdownInputs notifier) *Multiplexer + func (mux *Multiplexer) Run() + type MutedCollection struct + Demux *Demultiplexer + Intent *intents.Intent + func (*MutedCollection) Close() error + func (*MutedCollection) End() + func (*MutedCollection) Open() error + func (*MutedCollection) Read([]byte) (int, error) + func (*MutedCollection) Sum64() (uint64, bool) + func (*MutedCollection) Write(b []byte) (int, error) + type MuxIn struct + Intent *intents.Intent + Mux *Multiplexer + func (muxIn *MuxIn) Close() error + func (muxIn *MuxIn) Open() error + func (muxIn *MuxIn) Pos() int64 + func (muxIn *MuxIn) Read([]byte) (int, error) + func (muxIn *MuxIn) Write(buf []byte) (int, error) + type NamespaceHeader struct + CRC int64 + Collection string + Database string + EOF bool + type Parser struct + In io.Reader + func (parse *Parser) ReadAllBlocks(consumer ParserConsumer) (err error) + func (parse *Parser) ReadBlock(consumer ParserConsumer) (err error) + type ParserConsumer interface + BodyBSON func([]byte) error + End func() error + HeaderBSON func([]byte) error + type Prelude struct + DBS []string + Header *Header + NamespaceMetadatas []*CollectionMetadata + NamespaceMetadatasByDB map[string][]*CollectionMetadata + func NewPrelude(manager *intents.Manager, concurrentColls int, ...) (*Prelude, error) + func (prelude *Prelude) AddMetadata(cm *CollectionMetadata) + func (prelude *Prelude) NewPreludeExplorer() (*PreludeExplorer, error) + func (prelude *Prelude) Read(in io.Reader) error + func (prelude *Prelude) Write(out io.Writer) error + type PreludeExplorer struct + func (pe *PreludeExplorer) IsDir() bool + func (pe *PreludeExplorer) Name() string + func (pe *PreludeExplorer) Parent() DirLike + func (pe *PreludeExplorer) Path() string + func (pe *PreludeExplorer) ReadDir() ([]DirLike, error) + func (pe *PreludeExplorer) Size() int64 + func (pe *PreludeExplorer) Stat() (DirLike, error) + type Prioritizer struct + NamespaceChan <-chan string + NamespaceErrorChan chan<- error + func (prioritizer *Prioritizer) Finish(*intents.Intent) + func (prioritizer *Prioritizer) Get() *intents.Intent + type Reader struct + Demux *Demultiplexer + In io.ReadCloser + Prelude *Prelude + type RegularCollectionReceiver struct + Demux *Demultiplexer + Intent *intents.Intent + Origin string + func (receiver *RegularCollectionReceiver) Close() error + func (receiver *RegularCollectionReceiver) End() + func (receiver *RegularCollectionReceiver) Open() error + func (receiver *RegularCollectionReceiver) Pos() int64 + func (receiver *RegularCollectionReceiver) Read(r []byte) (int, error) + func (receiver *RegularCollectionReceiver) ReleaseIOBuffer() + func (receiver *RegularCollectionReceiver) Sum64() (uint64, bool) + func (receiver *RegularCollectionReceiver) TakeIOBuffer(ioBuf []byte) + func (receiver *RegularCollectionReceiver) Write(buf []byte) (int, error) + type SpecialCollectionCache struct + Demux *Demultiplexer + Intent *intents.Intent + func NewSpecialCollectionCache(intent *intents.Intent, demux *Demultiplexer) *SpecialCollectionCache + func (cache *SpecialCollectionCache) Close() error + func (cache *SpecialCollectionCache) End() + func (cache *SpecialCollectionCache) Open() error + func (cache *SpecialCollectionCache) Pos() int64 + func (cache *SpecialCollectionCache) Read(p []byte) (int, error) + func (cache *SpecialCollectionCache) Sum64() (uint64, bool) + func (cache *SpecialCollectionCache) Write(b []byte) (int, error) + type Writer struct + Mux *Multiplexer + Out io.WriteCloser + Prelude *Prelude