replication

Documentation

Index

• Variables
• 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
• type Source

Variables

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

Functions

func CurrentChangeset

func CurrentChangeset(url string) (int, error)

func CurrentDiff

func CurrentDiff(url string) (int, error)

func NewChangesetDownloader

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

func NewDiffDownloader

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

func NewDiffReader

func NewDiffReader(dest string, seq int) *reader

Types

type Sequence

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

type Source

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