s3mem

package
v0.0.0-...-86e4c60 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Bucket_CACHE = cache.New(5*time.Second, 5*time.Second)
View Source
var Object_Timeout int = 60
View Source
var Object_UP_CH chan int
View Source
var SyncFileMin int

Functions

func InitObjectUpPool

func InitObjectUpPool()

Types

type Backend

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

func New

func New(opts ...Option) *Backend

func (*Backend) CreateBucket

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

func (*Backend) DelBucket

func (db *Backend) DelBucket(publicKey, bucketname string)

func (*Backend) DeleteBucket

func (db *Backend) DeleteBucket(publicKey, bucketName string) error

func (*Backend) DeleteMulti

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

func (*Backend) DeleteObject

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

func (*Backend) GetBucket

func (db *Backend) GetBucket(publicKey, bucketname string) (*bucket, error)

func (*Backend) GetObject

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

func (*Backend) GetObjectV2

func (db *Backend) GetObjectV2(publicKey, bucketName, objectName string, rangeRequest *yts3.ObjectRangeRequest, prefix *yts3.Prefix, page yts3.ListBucketPage) (*yts3.Object, error)

func (*Backend) HeadObject

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

func (*Backend) ListBucket

func (me *Backend) ListBucket(publicKey, name string, prefix *yts3.Prefix, page yts3.ListBucketPage) (*yts3.ObjectList, error)

func (*Backend) ListBuckets

func (db *Backend) ListBuckets(publicKey string) ([]yts3.BucketInfo, error)

func (*Backend) MultipartUpload

func (db *Backend) MultipartUpload(publicKey, bucketName, objectName string, partsPath []string, size int64) (result yts3.PutObjectResult, err error)

func (*Backend) PutObject

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

type ContentReader

type ContentReader struct {
	io.ReadCloser
}

func (*ContentReader) Close

func (cr *ContentReader) Close() error

func (*ContentReader) Read

func (cr *ContentReader) Read(buf []byte) (int, error)

type Option

type Option func(b *Backend)

func WithTimeSource

func WithTimeSource(timeSource yts3.TimeSource) Option

func WithVersionSeed

func WithVersionSeed(seed int64) Option

type ZeroReader

type ZeroReader struct {
	io.ReadCloser
}

func (*ZeroReader) Close

func (cr *ZeroReader) Close() error

func (*ZeroReader) Read

func (cr *ZeroReader) Read(buf []byte) (int, error)

Jump to

Keyboard shortcuts

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