Versions in this module Expand all Collapse all v0 v0.5.0 Jun 14, 2019 Changes in this version + type Apply struct + func (oa *Apply) Count() int64 + func (oa *Apply) Run() error + type Collation struct + Alternate string + Backwards bool + CaseFirst string + CaseLevel bool + Locale string + MaxVariable string + Normalization bool + NumericOrdering bool + Strength int + Version string + type Common struct + H int64 + NS string + Op string + T int + TS bson.MongoTimestamp + UI bson.Binary + V int + Wall time.Time v0.4.0 May 16, 2019 v0.3.0 Feb 14, 2019 v0.2.1 Jan 12, 2019 v0.2.0 Jan 9, 2019 v0.1.0 Dec 18, 2018 Changes in this version + type OplogApply struct + func NewOplogApply(session *mgo.Session, r bsonfile.BSONReader) (*OplogApply, error) + func NewOplogApplyUntil(session *mgo.Session, r bsonfile.BSONReader, stopAtTs bson.MongoTimestamp) (*OplogApply, error) + func (oa *OplogApply) Count() int64 + func (oa *OplogApply) Run() error + type OplogTail struct + func Open(session *mgo.Session) (*OplogTail, error) + func OpenAt(session *mgo.Session, t time.Time, c uint32) (*OplogTail, error) + func (ot *OplogTail) Cancel() + func (ot *OplogTail) Close() error + func (ot *OplogTail) CloseAt(ts bson.MongoTimestamp) error + func (ot *OplogTail) Count() uint64 + func (ot *OplogTail) LastOplogTimestamp() bson.MongoTimestamp + func (ot *OplogTail) Read(buf []byte) (int, error) + func (ot *OplogTail) Size() uint64 + func (ot *OplogTail) WaitUntilFirstDoc() error + func (ot *OplogTail) WaitUntilFirstDocWithTimeout(timeout time.Duration) (bool, error)