Documentation ¶
Index ¶
- Variables
- func InitObjectUpPool()
- type Backend
- func (db *Backend) CreateBucket(publicKey, name string) error
- func (db *Backend) DelBucket(publicKey, bucketname string)
- func (db *Backend) DeleteBucket(publicKey, bucketName string) error
- func (db *Backend) DeleteMulti(publicKey, bucketName string, objects ...string) (result yts3.MultiDeleteResult, err error)
- func (db *Backend) DeleteObject(publicKey, bucketName, objectName string) (result yts3.ObjectDeleteResult, rerr error)
- func (db *Backend) GetBucket(publicKey, bucketname string) (*bucket, error)
- func (db *Backend) GetObject(publicKey, bucketName, objectName string, ...) (*yts3.Object, error)
- func (db *Backend) GetObjectV2(publicKey, bucketName, objectName string, ...) (*yts3.Object, error)
- func (db *Backend) HeadObject(publicKey, bucketName, objectName string) (*yts3.Object, error)
- func (me *Backend) ListBucket(publicKey, name string, prefix *yts3.Prefix, page yts3.ListBucketPage) (*yts3.ObjectList, error)
- func (db *Backend) ListBuckets(publicKey string) ([]yts3.BucketInfo, error)
- func (db *Backend) MultipartUpload(publicKey, bucketName, objectName string, partsPath []string, size int64) (result yts3.PutObjectResult, err error)
- func (db *Backend) PutObject(publicKey, bucketName, objectName string, meta map[string]string, ...) (result yts3.PutObjectResult, err error)
- type ContentReader
- type Option
- type ZeroReader
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 (*Backend) CreateBucket ¶
func (*Backend) DeleteBucket ¶
func (*Backend) DeleteMulti ¶
func (*Backend) DeleteObject ¶
func (db *Backend) DeleteObject(publicKey, bucketName, objectName string) (result yts3.ObjectDeleteResult, rerr error)
func (*Backend) GetObjectV2 ¶
func (*Backend) HeadObject ¶
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 ¶
type ContentReader ¶
type ContentReader struct {
io.ReadCloser
}
func (*ContentReader) Close ¶
func (cr *ContentReader) Close() error
type Option ¶
type Option func(b *Backend)
func WithTimeSource ¶
func WithTimeSource(timeSource yts3.TimeSource) Option
func WithVersionSeed ¶
type ZeroReader ¶
type ZeroReader struct {
io.ReadCloser
}
func (*ZeroReader) Close ¶
func (cr *ZeroReader) Close() error
Click to show internal directories.
Click to hide internal directories.