transport

package

v0.0.0-...-c9abf0a Latest Latest Go to latest Published: Mar 17, 2016 License: BSD-3-Clause Imports: 6 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const MULTIPART_CHUNK_SIZE = 8 * 1024 * 1024

View Source

var ErrProgressCompleted error = errors.New("Progress done")

This section is empty.

type Blob struct {
	Hash string
}

func NewBlob(hash string) Blob

func (self Blob) Path() string

type ProgressMessage struct {
	Progress int
	Total    int
	Err      error
}

func NewProgressMessage(progress int, total int, err error) ProgressMessage

func (self ProgressMessage) IsCompleted() bool

func (self ProgressMessage) IsErrored() bool

type ProgressWriter struct {
	ProgressChan chan ProgressMessage
	Progress     uint64
	Total        uint64
}

func NewProgressWriter(progressChan chan ProgressMessage, total uint64) *ProgressWriter

func (self *ProgressWriter) Write(p []byte) (n int, err error)

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

func NewS3Transport(bucket *s3.Bucket) S3Transport

func (self S3Transport) Download(blob Blob) chan ProgressMessage

func (self S3Transport) Exists(blob Blob) (bool, error)

func (self S3Transport) Upload(blob Blob) chan ProgressMessage

type Transport interface {
	Upload(blob Blob) chan ProgressMessage
	Download(blob Blob) chan ProgressMessage
	Exists(blob Blob) (bool, error)
}