multipart

package

v1.15.1 Latest Latest Go to latest Published: Apr 30, 2024 License: MIT Imports: 18 Imported by: 0

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

Repository

github.com/nabbar/golib

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetOptimalPartSize(objectSize, partSize libsiz.Size) (libsiz.Size, error)
type FuncClientS3
type MultiPart
- func New(partSize libsiz.Size, object string, bucket string) MultiPart

Constants ¶

View Source

const (
	DefaultPartSize       = 5 * libsiz.SizeMega
	MaxPartSize           = 5 * libsiz.SizeGiga
	MaxObjectSize         = 5 * libsiz.SizeTera
	MaxNumberPart   int32 = 10000
)

Variables ¶

View Source

var (
	ErrInvalidInstance           = fmt.Errorf("invalid instance")
	ErrInvalidClient             = fmt.Errorf("invalid aws S3 client")
	ErrInvalidResponse           = fmt.Errorf("invalid aws S3 response")
	ErrInvalidUploadID           = fmt.Errorf("invalid aws s3 MPU Upload ID")
	ErrInvalidTMPFile            = fmt.Errorf("invalid working or temporary file")
	ErrWorkingPartFileExceedSize = fmt.Errorf("working or temporary file used exceed the aws S3 size limits")
)

Functions ¶

func GetOptimalPartSize ¶

func GetOptimalPartSize(objectSize, partSize libsiz.Size) (libsiz.Size, error)

Types ¶

type FuncClientS3 ¶

type FuncClientS3 func() *sdksss.Client

type MultiPart ¶

type MultiPart interface {
	io.WriteCloser

	RegisterContext(fct libctx.FuncContext)
	RegisterClientS3(fct FuncClientS3)
	RegisterMultipartID(id string)
	RegisterWorkingFile(file string, truncate bool) error
	RegisterFuncOnPushPart(fct func(eTag string, e error))
	RegisterFuncOnAbort(fct func(nPart int, obj string, e error))
	RegisterFuncOnComplete(fct func(nPart int, obj string, e error))

	StartMPU() error
	StopMPU(abort bool) error

	Copy(fromBucket, fromObject, fromVersionId string) error
	AddPart(r io.Reader) (n int64, e error)
	SendPart() error
	CurrentSizePart() int64
	AddToPart(p []byte) (n int, e error)
	RegisterPart(etag string)

	IsStarted() bool
	Counter() int32
	CounterLeft() int32
}

func New ¶

func New(partSize libsiz.Size, object string, bucket string) MultiPart

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL