local

Documentation

Index

• Constants
• type LocalDownloader
  • func NewLocalDownloader(aw archive.ArchiveWriter, prefix string) (*LocalDownloader, error)
  • func (d *LocalDownloader) Close() error
  • func (d *LocalDownloader) Download(ctx context.Context) error
  • func (d *LocalDownloader) ListFiles(ctx context.Context) ([]archive.FileEntry, error)

Constants

const DefaultDownloadPartSize = units.MiB * 5

DefaultDownloadPartSize is the default part size for downloading files from the local filesystem. This is the same as the default part size for S3.

Types

type LocalDownloader

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

LocalDownloader implements downloading a checkpoint from the local filesystem and sends it to the client in an archive file.

func NewLocalDownloader

func NewLocalDownloader(aw archive.ArchiveWriter, prefix string) (*LocalDownloader, error)

NewLocalDownloader returns a new LocalDownloader.

func (*LocalDownloader) Close

func (d *LocalDownloader) Close() error

Close closes the underlying ArchiveWriter.

func (*LocalDownloader) Download

func (d *LocalDownloader) Download(ctx context.Context) error

Download downloads the checkpoint.

func (*LocalDownloader) ListFiles

func (d *LocalDownloader) ListFiles(ctx context.Context) ([]archive.FileEntry, error)

ListFiles lists the files in the checkpoint.