dataexporter

type DeleteOption func(*DeleteOptions)

type DeleteOptions struct {
	ConcurrentJobs int
}

type Exporter interface {
	Provider() Provider
	Upload(dir, bucket, name string, opts ...UploadOption) error
	Delete(bucket, name string, opts ...DeleteOption) error
}

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

type Provider string

type UploadOption func(*UploadOptions)

type UploadOptions struct {
	PartSize       datasize.ByteSize
	ChunkSize      datasize.ByteSize
	SizeLimit      datasize.ByteSize
	ReportPeriod   time.Duration
	ConcurrentJobs int
	BufferSize     datasize.ByteSize
}