object

Documentation

Index

• Constants
• type DelMakWalkFunc
• type Object
  • func New(ctx context.Context, bucket, region string, iam *sdkiam.Client, ...) Object
• type VersionWalkFunc
• type WalkFunc

Constants

const DefaultPartSize = 5 * libhlp.SizeMegaBytes

Types

type DelMakWalkFunc

type DelMakWalkFunc func(err liberr.Error, del sdktps.DeleteMarkerEntry) liberr.Error

type Object

type Object interface {
	Find(regex string) ([]string, liberr.Error)
	Size(object string) (size int64, err liberr.Error)

	List(continuationToken string) ([]sdktps.Object, string, int64, liberr.Error)
	Walk(f WalkFunc) liberr.Error

	ListPrefix(continuationToken string, prefix string) ([]sdktps.Object, string, int64, liberr.Error)
	WalkPrefix(prefix string, f WalkFunc) liberr.Error

	Head(object string) (*sdksss.HeadObjectOutput, liberr.Error)
	Get(object string) (*sdksss.GetObjectOutput, liberr.Error)
	Put(object string, body io.Reader) liberr.Error
	Delete(check bool, object string) liberr.Error
	DeleteAll(objects *sdktps.Delete) ([]sdktps.DeletedObject, liberr.Error)
	GetAttributes(object, version string) (*sdksss.GetObjectAttributesOutput, liberr.Error)

	MultipartList(keyMarker, markerId string) (uploads []sdktps.MultipartUpload, nextKeyMarker string, nextIdMarker string, count int64, e liberr.Error)
	MultipartPut(object string, body io.Reader) liberr.Error
	MultipartPutCustom(partSize libhlp.PartSize, object string, body io.Reader) liberr.Error
	MultipartCancel(uploadId, key string) liberr.Error

	UpdateMetadata(meta *sdksss.CopyObjectInput) liberr.Error
	SetWebsite(object, redirect string) liberr.Error

	VersionList(prefix, keyMarker, markerId string) (version []sdktps.ObjectVersion, delMarker []sdktps.DeleteMarkerEntry, nextKeyMarker, nextMarkerId string, count int64, err liberr.Error)
	VersionWalk(fv VersionWalkFunc, fd DelMakWalkFunc) liberr.Error
	VersionWalkPrefix(prefix string, fv VersionWalkFunc, fd DelMakWalkFunc) liberr.Error

	VersionGet(object, version string) (*sdksss.GetObjectOutput, liberr.Error)
	VersionHead(object, version string) (*sdksss.HeadObjectOutput, liberr.Error)
	VersionSize(object, version string) (size int64, err liberr.Error)
	VersionDelete(check bool, object, version string) liberr.Error

	GetRetention(object, version string) (*sdktps.ObjectLockRetention, liberr.Error)
	SetRetention(object, version string, retentionUntil time.Time) liberr.Error

	GetTags(object, version string) ([]sdktps.Tag, liberr.Error)
	SetTags(object, version string, tags ...sdktps.Tag) liberr.Error
}

func New

func New(ctx context.Context, bucket, region string, iam *sdkiam.Client, s3 *sdksss.Client) Object

type VersionWalkFunc

type VersionWalkFunc func(err liberr.Error, obj sdktps.ObjectVersion) liberr.Error

type WalkFunc

type WalkFunc func(err liberr.Error, obj sdktps.Object) liberr.Error