replication

package

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

Details

This section is empty.

This section is empty.

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

func (e *NotAvailable) Error() string

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

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