backend

package

Go to main page

Versions in this module

v1

v1.0.9

Dec 7, 2024

Changes in this version

+ func GetStringFromPtr(str *string) string

v1.0.8

Oct 28, 2024

Changes in this version

+ func GetPtrFromString(str string) *string

+ func ParseCopySource(copySourceHeader string) (string, string, string, error)

+ type GetVersionsFunc func(path, versionIdMarker string, pastVersionIdMarker *bool, availableObjCount int, ...) (*ObjVersionFuncResult, error)

+ type ObjVersionFuncResult struct

+ DelMarkers []types.DeleteMarkerEntry

+ NextVersionIdMarker string

+ ObjectVersions []types.ObjectVersion

+ Truncated bool

+ type WalkVersioningResults struct

+ CommonPrefixes []types.CommonPrefix

+ DelMarkers []types.DeleteMarkerEntry

+ NextMarker string

+ NextVersionIdMarker string

+ ObjectVersions []types.ObjectVersion

+ Truncated bool

+ func WalkVersions(ctx context.Context, fileSystem fs.FS, ...) (WalkVersioningResults, error)

v1.0.7

Sep 18, 2024

Changes in this version

+ const DefaultContentType

+ const DirContentType

v1.0.6

Aug 29, 2024

v1.0.5

Aug 6, 2024

v1.0.4

Jul 17, 2024

v1.0.3

Jul 11, 2024

Changes in this version

type Backend

+ DeleteBucketOwnershipControls func(_ context.Context, bucket string) error

+ GetBucketOwnershipControls func(_ context.Context, bucket string) (types.ObjectOwnership, error)

+ PutBucketOwnershipControls func(_ context.Context, bucket string, ownership types.ObjectOwnership) error

type BackendUnsupported

+ func (BackendUnsupported) DeleteBucketOwnershipControls(_ context.Context, bucket string) error

+ func (BackendUnsupported) GetBucketOwnershipControls(_ context.Context, bucket string) (types.ObjectOwnership, error)

+ func (BackendUnsupported) PutBucketOwnershipControls(_ context.Context, bucket string, ownership types.ObjectOwnership) error

+ type FileSectionReadCloser struct

+ F *os.File

+ R io.Reader

+ func (f *FileSectionReadCloser) Close() error

+ func (f *FileSectionReadCloser) Read(p []byte) (int, error)

v1.0.2

Jun 25, 2024

Changes in this version

+ func CreateExceedingRangeErr(objSize int64) s3err.APIError

v1.0.1

Jun 11, 2024

v1.0.0

Jun 11, 2024

Changes in this version

+ var ErrSkipObj = errors.New("skip this object")

+ var RFC3339TimeFormat = "2006-01-02T15:04:05.999Z"

+ func GetMultipartMD5(parts []types.CompletedPart) string

+ func GetStringPtr(s string) *string

+ func GetTimePtr(t time.Time) *time.Time

+ func IsValidBucketName(name string) bool

+ func MkdirAll(path string, uid, gid int, doChown bool) error

+ func ParseRange(fi fs.FileInfo, acceptRange string) (int64, int64, error)

+ type Backend interface

+ AbortMultipartUpload func(context.Context, *s3.AbortMultipartUploadInput) error

+ ChangeBucketOwner func(_ context.Context, bucket, newOwner string) error

+ CompleteMultipartUpload func(context.Context, *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)

+ CopyObject func(context.Context, *s3.CopyObjectInput) (*s3.CopyObjectOutput, error)

+ CreateBucket func(_ context.Context, _ *s3.CreateBucketInput, defaultACL []byte) error

+ CreateMultipartUpload func(context.Context, *s3.CreateMultipartUploadInput) (*s3.CreateMultipartUploadOutput, error)

+ DeleteBucket func(context.Context, *s3.DeleteBucketInput) error

+ DeleteBucketPolicy func(_ context.Context, bucket string) error

+ DeleteBucketTagging func(_ context.Context, bucket string) error

+ DeleteObject func(context.Context, *s3.DeleteObjectInput) error

+ DeleteObjectTagging func(_ context.Context, bucket, object string) error

+ DeleteObjects func(context.Context, *s3.DeleteObjectsInput) (s3response.DeleteResult, error)

+ GetBucketAcl func(context.Context, *s3.GetBucketAclInput) ([]byte, error)

+ GetBucketPolicy func(_ context.Context, bucket string) ([]byte, error)

+ GetBucketTagging func(_ context.Context, bucket string) (map[string]string, error)

+ GetBucketVersioning func(_ context.Context, bucket string) (*s3.GetBucketVersioningOutput, error)

+ GetObject func(context.Context, *s3.GetObjectInput, io.Writer) (*s3.GetObjectOutput, error)

+ GetObjectAcl func(context.Context, *s3.GetObjectAclInput) (*s3.GetObjectAclOutput, error)

+ GetObjectAttributes func(context.Context, *s3.GetObjectAttributesInput) (s3response.GetObjectAttributesResult, error)

+ GetObjectLegalHold func(_ context.Context, bucket, object, versionId string) (*bool, error)

+ GetObjectLockConfiguration func(_ context.Context, bucket string) ([]byte, error)

+ GetObjectRetention func(_ context.Context, bucket, object, versionId string) ([]byte, error)

+ GetObjectTagging func(_ context.Context, bucket, object string) (map[string]string, error)

+ HeadBucket func(context.Context, *s3.HeadBucketInput) (*s3.HeadBucketOutput, error)

+ HeadObject func(context.Context, *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)

+ ListBuckets func(_ context.Context, owner string, isAdmin bool) (s3response.ListAllMyBucketsResult, error)

+ ListBucketsAndOwners func(context.Context) ([]s3response.Bucket, error)

+ ListMultipartUploads func(context.Context, *s3.ListMultipartUploadsInput) (s3response.ListMultipartUploadsResult, error)

+ ListObjectVersions func(context.Context, *s3.ListObjectVersionsInput) (*s3.ListObjectVersionsOutput, error)

+ ListObjects func(context.Context, *s3.ListObjectsInput) (*s3.ListObjectsOutput, error)

+ ListObjectsV2 func(context.Context, *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

+ ListParts func(context.Context, *s3.ListPartsInput) (s3response.ListPartsResult, error)

+ PutBucketAcl func(_ context.Context, bucket string, data []byte) error

+ PutBucketPolicy func(_ context.Context, bucket string, policy []byte) error

+ PutBucketTagging func(_ context.Context, bucket string, tags map[string]string) error

+ PutBucketVersioning func(context.Context, *s3.PutBucketVersioningInput) error

+ PutObject func(context.Context, *s3.PutObjectInput) (string, error)

+ PutObjectAcl func(context.Context, *s3.PutObjectAclInput) error

+ PutObjectLegalHold func(_ context.Context, bucket, object, versionId string, status bool) error

+ PutObjectLockConfiguration func(_ context.Context, bucket string, config []byte) error

+ PutObjectRetention func(_ context.Context, bucket, object, versionId string, bypass bool, ...) error

+ PutObjectTagging func(_ context.Context, bucket, object string, tags map[string]string) error

+ RestoreObject func(context.Context, *s3.RestoreObjectInput) error

+ SelectObjectContent func(ctx context.Context, input *s3.SelectObjectContentInput) func(w *bufio.Writer)

+ Shutdown func()

+ UploadPart func(context.Context, *s3.UploadPartInput) (etag string, err error)

+ UploadPartCopy func(context.Context, *s3.UploadPartCopyInput) (s3response.CopyObjectResult, error)

+ func New() Backend

+ type BackendUnsupported struct

+ func (BackendUnsupported) AbortMultipartUpload(context.Context, *s3.AbortMultipartUploadInput) error

+ func (BackendUnsupported) ChangeBucketOwner(_ context.Context, bucket, newOwner string) error

+ func (BackendUnsupported) CompleteMultipartUpload(context.Context, *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)

+ func (BackendUnsupported) CopyObject(context.Context, *s3.CopyObjectInput) (*s3.CopyObjectOutput, error)

+ func (BackendUnsupported) CreateBucket(context.Context, *s3.CreateBucketInput, []byte) error

+ func (BackendUnsupported) CreateMultipartUpload(context.Context, *s3.CreateMultipartUploadInput) (*s3.CreateMultipartUploadOutput, error)

+ func (BackendUnsupported) DeleteBucket(context.Context, *s3.DeleteBucketInput) error

+ func (BackendUnsupported) DeleteBucketPolicy(_ context.Context, bucket string) error

+ func (BackendUnsupported) DeleteBucketTagging(_ context.Context, bucket string) error

+ func (BackendUnsupported) DeleteObject(context.Context, *s3.DeleteObjectInput) error

+ func (BackendUnsupported) DeleteObjectTagging(_ context.Context, bucket, object string) error

+ func (BackendUnsupported) DeleteObjects(context.Context, *s3.DeleteObjectsInput) (s3response.DeleteResult, error)

+ func (BackendUnsupported) GetBucketAcl(context.Context, *s3.GetBucketAclInput) ([]byte, error)

+ func (BackendUnsupported) GetBucketPolicy(_ context.Context, bucket string) ([]byte, error)

+ func (BackendUnsupported) GetBucketTagging(_ context.Context, bucket string) (map[string]string, error)

+ func (BackendUnsupported) GetBucketVersioning(_ context.Context, bucket string) (*s3.GetBucketVersioningOutput, error)

+ func (BackendUnsupported) GetObject(context.Context, *s3.GetObjectInput, io.Writer) (*s3.GetObjectOutput, error)

+ func (BackendUnsupported) GetObjectAcl(context.Context, *s3.GetObjectAclInput) (*s3.GetObjectAclOutput, error)

+ func (BackendUnsupported) GetObjectAttributes(context.Context, *s3.GetObjectAttributesInput) (s3response.GetObjectAttributesResult, error)

+ func (BackendUnsupported) GetObjectLegalHold(_ context.Context, bucket, object, versionId string) (*bool, error)

+ func (BackendUnsupported) GetObjectLockConfiguration(_ context.Context, bucket string) ([]byte, error)

+ func (BackendUnsupported) GetObjectRetention(_ context.Context, bucket, object, versionId string) ([]byte, error)

+ func (BackendUnsupported) GetObjectTagging(_ context.Context, bucket, object string) (map[string]string, error)

+ func (BackendUnsupported) HeadBucket(context.Context, *s3.HeadBucketInput) (*s3.HeadBucketOutput, error)

+ func (BackendUnsupported) HeadObject(context.Context, *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)

+ func (BackendUnsupported) ListBuckets(context.Context, string, bool) (s3response.ListAllMyBucketsResult, error)

+ func (BackendUnsupported) ListBucketsAndOwners(context.Context) ([]s3response.Bucket, error)

+ func (BackendUnsupported) ListMultipartUploads(context.Context, *s3.ListMultipartUploadsInput) (s3response.ListMultipartUploadsResult, error)

+ func (BackendUnsupported) ListObjectVersions(context.Context, *s3.ListObjectVersionsInput) (*s3.ListObjectVersionsOutput, error)

+ func (BackendUnsupported) ListObjects(context.Context, *s3.ListObjectsInput) (*s3.ListObjectsOutput, error)

+ func (BackendUnsupported) ListObjectsV2(context.Context, *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

+ func (BackendUnsupported) ListParts(context.Context, *s3.ListPartsInput) (s3response.ListPartsResult, error)

+ func (BackendUnsupported) PutBucketAcl(_ context.Context, bucket string, data []byte) error

+ func (BackendUnsupported) PutBucketPolicy(_ context.Context, bucket string, policy []byte) error

+ func (BackendUnsupported) PutBucketTagging(_ context.Context, bucket string, tags map[string]string) error

+ func (BackendUnsupported) PutBucketVersioning(context.Context, *s3.PutBucketVersioningInput) error

+ func (BackendUnsupported) PutObject(context.Context, *s3.PutObjectInput) (string, error)

+ func (BackendUnsupported) PutObjectAcl(context.Context, *s3.PutObjectAclInput) error

+ func (BackendUnsupported) PutObjectLegalHold(_ context.Context, bucket, object, versionId string, status bool) error

+ func (BackendUnsupported) PutObjectLockConfiguration(_ context.Context, bucket string, config []byte) error

+ func (BackendUnsupported) PutObjectRetention(_ context.Context, bucket, object, versionId string, bypass bool, ...) error

+ func (BackendUnsupported) PutObjectTagging(_ context.Context, bucket, object string, tags map[string]string) error

+ func (BackendUnsupported) RestoreObject(context.Context, *s3.RestoreObjectInput) error

+ func (BackendUnsupported) SelectObjectContent(ctx context.Context, input *s3.SelectObjectContentInput) func(w *bufio.Writer)

+ func (BackendUnsupported) Shutdown()

+ func (BackendUnsupported) String() string

+ func (BackendUnsupported) UploadPart(context.Context, *s3.UploadPartInput) (etag string, err error)

+ func (BackendUnsupported) UploadPartCopy(context.Context, *s3.UploadPartCopyInput) (s3response.CopyObjectResult, error)

+ type ByBucketName []s3response.ListAllMyBucketsEntry

+ func (d ByBucketName) Len() int

+ func (d ByBucketName) Less(i, j int) bool

+ func (d ByBucketName) Swap(i, j int)

+ type ByObjectName []types.Object

+ func (d ByObjectName) Len() int

+ func (d ByObjectName) Less(i, j int) bool

+ func (d ByObjectName) Swap(i, j int)

+ type GetObjFunc func(path string, d fs.DirEntry) (types.Object, error)

+ type WalkResults struct

+ CommonPrefixes []types.CommonPrefix

+ NextMarker string

+ Objects []types.Object

+ Truncated bool

+ func Walk(fileSystem fs.FS, prefix, delimiter, marker string, max int32, ...) (WalkResults, error)

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