resumableuploadservice

package

v0.0.0-...-79683fd Latest Latest Go to latest Published: Jul 12, 2023 License: MIT Imports: 5 Imported by: 3

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

This section is empty.

This section is empty.

This section is empty.

type ReadCloserInformer interface {
	Read(buf []byte) (n int, err error)
	Close() error
	GetFractionRead() float32
}

type ReadCloserInformerProvider interface {
	GetReadCloserInformer() (ReadCloserInformer, error)
}

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

func New(path string) (*ResumableUploadService, error)

func (rsu *ResumableUploadService) Close()

Close stops what needs to be stopped

func (rsu *ResumableUploadService) DeleteFile(uid int64, fileID string, chunkCount int) error

DeleteFile deletes the whole file bucket

func (rsu *ResumableUploadService) IsUploadFinished(uid int64, fileID string, chunkCount int, expectedSize int64) (bool, error)

IsUploadFinished compares the total size of stored chunks a to provided size

func (rsu *ResumableUploadService) NewFileReader(uid int64, fileID string, chunkCount int) (ReadCloserInformer, error)

NewFileReader returns a reader that reconstructs the file from the chunks on the fly. It does not check if the file is complete.

func (rsu *ResumableUploadService) PutChunk(uid int64, fileID string, chunkNumber int, chunk []byte) error

PutChunk stores chunk, overwrites if exists.

func (rsu *ResumableUploadService) TestChunk(uid int64, fileID string, chunkNumber int, chunkSize int64) (bool, error)

TestChunk returns true if the chunk is already received