The highest tagged major version is v2.

oplog

package

v0.3.0 Latest Latest Go to latest Published: Feb 14, 2019 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type OplogApply struct {
	// contains filtered or unexported fields
}

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 {
	// contains filtered or unexported fields
}

func Open(session *mgo.Session) (*OplogTail, error)

func OpenAt(session *mgo.Session, t time.Time, c uint32) (*OplogTail, error)

func (ot *OplogTail) Cancel()

Cancel stopts the tailer immediately without waiting the tailer to reach the document having timestamp = IsMasterDoc().LastWrite.OpTime.Ts

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)

Implement the Reader interface to be able to pipe it into an S3 stream or through an encrypter

func (ot *OplogTail) Size() uint64

func (ot *OplogTail) WaitUntilFirstDoc() error

func (ot *OplogTail) WaitUntilFirstDocWithTimeout(timeout time.Duration) (bool, error)