uploader

Documentation

Index

• type Uploader
  • func NewUploader(ctx context.Context, filePath string, ...) *Uploader
  • func (u *Uploader) Upload(ctx context.Context) ([]client.CachePartETag, error)

Types

type Uploader

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

Uploader uses go routines to upload files in parallel with a limit of 20 concurrent uploads. It is provided a list of URLs to upload and a channel to receive the results. The results are sent to the channel as a map of URL to error. If an error occurs, the error is sent to the channel and the upload is stopped. The uploader will continue to upload files until the channel is closed. The uploader will return when all uploads are complete or when an error occurs.

func NewUploader

func NewUploader(ctx context.Context, filePath string, uploadInstructs []client.CacheUploadInstruction, limit int) *Uploader

func (*Uploader) Upload

func (u *Uploader) Upload(ctx context.Context) ([]client.CachePartETag, error)