dataexporter

type DeleteOption func(*DeleteOptions)

type DeleteOptions struct {
	ConcurrentJobs int
}

type Exporter interface {
	// Provider returns the cloud storage provider type.
	Provider() Provider

	// Upload uploads a directory as a compressed tarball to the specified bucket.
	// The name parameter specifies the object name in the bucket.
	// Options can be provided to customize the upload behavior.
	Upload(dir, bucket, name string, opts ...UploadOption) error

	// Delete removes an object from the specified bucket.
	// Options can be provided to customize the delete behavior.
	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
}