replication

package

v0.6.0-alpha.2 Latest Latest Go to latest Published: Apr 15, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

View Source

var NotAvailable = errors.New("file not available")

func CurrentChangeset(url string) (int, error)

func CurrentDiff(url string) (int, error)

func NewChangesetDownloader(dest, url string, seq int, interval time.Duration) *downloader

func NewDiffDownloader(dest, url string, seq int, interval time.Duration) *downloader

func NewDiffReader(dest string, seq int) *reader

type Sequence struct {
	Filename      string
	StateFilename string
	Time          time.Time
	Sequence      int
}

type Source interface {
	Sequences() <-chan Sequence
}