estuary

Documentation

Index

• type Downloader
  • func NewEstuaryDownloader(cm *system.CleanupManager, settings *model.DownloaderSettings) *Downloader
  • func (downloader *Downloader) FetchResult(ctx context.Context, result model.PublishedResult, downloadPath string) error
  • func (downloader *Downloader) IsInstalled(ctx context.Context) (bool, error)

Types

type Downloader

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

Estuary downloader uses HTTP downloader to download result published to Estuary by combining Estuary gateway URL and CID returned by Estuary publisher and passing it for download.

func NewEstuaryDownloader

func NewEstuaryDownloader(cm *system.CleanupManager, settings *model.DownloaderSettings) *Downloader

func (*Downloader) FetchResult

func (downloader *Downloader) FetchResult(ctx context.Context, result model.PublishedResult, downloadPath string) error

func (*Downloader) IsInstalled

func (downloader *Downloader) IsInstalled(ctx context.Context) (bool, error)