discovery

Documentation

Index

• func BuildCursorFromTS(ctx context.Context, since models.Timestamp, uploader archive.Uploader, ...) (oplogCursor client.OplogCursor, fromTS models.Timestamp, err error)
• func ResolveStartingTS(ctx context.Context, downloader archive.Downloader, ...) (models.Timestamp, error)

Functions

func BuildCursorFromTS

func BuildCursorFromTS(ctx context.Context,
	since models.Timestamp,
	uploader archive.Uploader,
	mongoClient client.MongoDriver) (oplogCursor client.OplogCursor, fromTS models.Timestamp, err error)

BuildCursorFromTS finds point to resume archiving or _restarts_ procedure from newest oplog document

func ResolveStartingTS

func ResolveStartingTS(ctx context.Context,
	downloader archive.Downloader,
	mongoClient client.MongoDriver) (models.Timestamp, error)

ResolveStartingTS fetches last-known folder TS or initiates first run from last-known mongoClient TS