syncer

Documentation

Index

• type CachedSyncer
  • func NewCachedSyncer(t *oauth.Transport, metaService *metadata.MetaService, ...) *CachedSyncer
  • func (d *CachedSyncer) Start()
  • func (d *CachedSyncer) Sync(isForce bool) (err error)
• type Downloader
  • func NewDownloader(client *http.Client, m *metadata.MetaService, blobMngr *blob.Manager) *Downloader
  • func (d *Downloader) Start()
• type Syncer

Types

type CachedSyncer

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

func NewCachedSyncer

func NewCachedSyncer(t *oauth.Transport, metaService *metadata.MetaService, blobManager *blob.Manager) *CachedSyncer

func (*CachedSyncer) Start

func (d *CachedSyncer) Start()

func (*CachedSyncer) Sync

func (d *CachedSyncer) Sync(isForce bool) (err error)

type Downloader

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

func NewDownloader

func NewDownloader(client *http.Client, m *metadata.MetaService, blobMngr *blob.Manager) *Downloader

func (*Downloader) Start

func (d *Downloader) Start()

type Syncer

type Syncer interface {
	// Starts a periodic syncing, returns immediately.
	Start()

	// Starts a sync if no syncing ,waits for the existing
	// sync process to be finished. Ignores incremental syncs
	// if isForce is set.
	Sync(isForce bool) (err error)
}