gcs

Documentation

Index

• Constants
• type GCSDownloader
  • func NewGCSDownloader(aw archive.ArchiveWriter, bucket string, prefix string) *GCSDownloader
  • func (d *GCSDownloader) Close() error
  • func (d *GCSDownloader) Download(ctx context.Context) error

Constants

const DefaultDownloadPartSize = units.MiB * 5

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

Types

type GCSDownloader

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

GCSDownloader implements downloading a checkpoint from GCS and sends it to the client in an archive file.

func NewGCSDownloader

func NewGCSDownloader(aw archive.ArchiveWriter, bucket string, prefix string) *GCSDownloader

NewGCSDownloader returns a new GCSDownloader.

func (*GCSDownloader) Close

func (d *GCSDownloader) Close() error

Close closes the underlying ArchiveWriter.

func (*GCSDownloader) Download

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

Download downloads the checkpoint.