s3mem

package
v0.0.0-...-2d6084a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 23, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Backend

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

func New

func New(opts ...Option) *Backend

func (*Backend) BucketExists

func (db *Backend) BucketExists(name string) (exists bool, err error)

func (*Backend) CreateBucket

func (db *Backend) CreateBucket(name string) error

func (*Backend) DeleteBucket

func (db *Backend) DeleteBucket(name string) error

func (*Backend) DeleteMulti

func (db *Backend) DeleteMulti(bucketName string, objects ...string) (result s3tohdfs.MultiDeleteResult, err error)

func (*Backend) DeleteMultiVersions

func (db *Backend) DeleteMultiVersions(bucketName string, objects ...s3tohdfs.ObjectID) (result s3tohdfs.MultiDeleteResult, err error)

func (*Backend) DeleteObject

func (db *Backend) DeleteObject(bucketName, objectName string) (result s3tohdfs.ObjectDeleteResult, rerr error)

func (*Backend) DeleteObjectVersion

func (db *Backend) DeleteObjectVersion(bucketName, objectName string, versionID s3tohdfs.VersionID) (result s3tohdfs.ObjectDeleteResult, rerr error)

func (*Backend) GetObject

func (db *Backend) GetObject(bucketName, objectName string, rangeRequest *s3tohdfs.ObjectRangeRequest) (*s3tohdfs.Object, error)

func (*Backend) GetObjectVersion

func (db *Backend) GetObjectVersion(
	bucketName, objectName string,
	versionID s3tohdfs.VersionID,
	rangeRequest *s3tohdfs.ObjectRangeRequest) (*s3tohdfs.Object, error)

func (*Backend) HeadObject

func (db *Backend) HeadObject(bucketName, objectName string) (*s3tohdfs.Object, error)

func (*Backend) HeadObjectVersion

func (db *Backend) HeadObjectVersion(bucketName, objectName string, versionID s3tohdfs.VersionID) (*s3tohdfs.Object, error)

func (*Backend) ListBucket

func (db *Backend) ListBucket(name string, prefix *s3tohdfs.Prefix, page s3tohdfs.ListBucketPage) (*s3tohdfs.ObjectList, error)

func (*Backend) ListBucketVersions

func (db *Backend) ListBucketVersions(
	bucketName string,
	prefix *s3tohdfs.Prefix,
	page *s3tohdfs.ListBucketVersionsPage,
) (*s3tohdfs.ListBucketVersionsResult, error)

func (*Backend) ListBuckets

func (db *Backend) ListBuckets() ([]s3tohdfs.BucketInfo, error)

func (*Backend) PutObject

func (db *Backend) PutObject(bucketName, objectName string, meta map[string]string, input io.Reader, size int64) (result s3tohdfs.PutObjectResult, err error)

func (*Backend) SetVersioningConfiguration

func (db *Backend) SetVersioningConfiguration(bucketName string, v s3tohdfs.VersioningConfiguration) error

func (*Backend) VersioningConfiguration

func (db *Backend) VersioningConfiguration(bucketName string) (versioning s3tohdfs.VersioningConfiguration, rerr error)

type Option

type Option func(b *Backend)

func WithTimeSource

func WithTimeSource(timeSource s3tohdfs.TimeSource) Option

func WithVersionSeed

func WithVersionSeed(seed int64) Option

Jump to

Keyboard shortcuts

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