Documentation
¶
Index ¶
- Variables
- func Register(name string, register Creator)
- func Walk(root string, walkFn filepath.WalkFunc) error
- type COS
- func (c *COS) AbortUpload(key string, uploadID string)
- func (c *COS) CompleteUpload(key string, uploadID string, parts []*Part) error
- func (c *COS) Copy(dst, src string) error
- func (c *COS) Create() error
- func (c *COS) CreateMultipartUpload(key string) (*MultipartUpload, error)
- func (c *COS) Delete(key string) error
- func (c *COS) Get(key string, off, limit int64) (io.ReadCloser, error)
- func (c *COS) Head(key string) (*Object, error)
- func (c *COS) List(prefix, marker string, limit int64) ([]*Object, error)
- func (c *COS) ListAll(prefix, marker string) (<-chan *Object, error)
- func (c *COS) ListUploads(marker string) ([]*PendingPart, string, error)
- func (c *COS) Put(key string, in io.Reader) error
- func (c *COS) String() string
- func (c *COS) UploadPart(key string, uploadID string, num int, body []byte) (*Part, error)
- type Contents
- type Creator
- type DataItem
- type DefaultObjectStorage
- func (s DefaultObjectStorage) AbortUpload(key string, uploadID string)
- func (s DefaultObjectStorage) CompleteUpload(key string, uploadID string, parts []*Part) error
- func (s DefaultObjectStorage) Create() error
- func (s DefaultObjectStorage) CreateMultipartUpload(key string) (*MultipartUpload, error)
- func (s DefaultObjectStorage) Head(key string) (*Object, error)
- func (s DefaultObjectStorage) List(prefix, marker string, limit int64) ([]*Object, error)
- func (s DefaultObjectStorage) ListAll(prefix, marker string) (<-chan *Object, error)
- func (s DefaultObjectStorage) ListUploads(marker string) ([]*PendingPart, string, error)
- func (s DefaultObjectStorage) UploadPart(key string, uploadID string, num int, body []byte) (*Part, error)
- type File
- type FileSystem
- type ListBucketResult
- type MtimeChanger
- type MultipartUpload
- type Object
- type ObjectStorage
- type Part
- type PendingPart
- type RestfulStorage
- func (s *RestfulStorage) Copy(dst, src string) error
- func (s *RestfulStorage) Delete(key string) error
- func (s *RestfulStorage) Get(key string, off, limit int64) (io.ReadCloser, error)
- func (s *RestfulStorage) Head(key string) (*Object, error)
- func (s *RestfulStorage) List(prefix, marker string, limit int64) ([]*Object, error)
- func (u *RestfulStorage) Put(key string, body io.Reader) error
- func (s *RestfulStorage) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var HEADER_NAMES = []string{"Content-MD5", "Content-Type", "Date"}
View Source
var UserAgent = "JuiceFS"
Functions ¶
func Walk ¶ added in v0.1.6
Walk walks the file tree rooted at root, calling walkFn for each file or directory in the tree, including root. All errors that arise visiting files and directories are filtered by walkFn. The files are walked in lexical order, which makes the output deterministic but means that for very large directories Walk can be inefficient. Walk always follow symbolic links.
Types ¶
type COS ¶
type COS struct {
// contains filtered or unexported fields
}
func (*COS) AbortUpload ¶
func (*COS) CompleteUpload ¶
func (*COS) CreateMultipartUpload ¶
func (c *COS) CreateMultipartUpload(key string) (*MultipartUpload, error)
func (*COS) ListUploads ¶
func (c *COS) ListUploads(marker string) ([]*PendingPart, string, error)
type Creator ¶
type Creator func(bucket, accessKey, secretKey string) (ObjectStorage, error)
type DefaultObjectStorage ¶
type DefaultObjectStorage struct{}
func (DefaultObjectStorage) AbortUpload ¶
func (s DefaultObjectStorage) AbortUpload(key string, uploadID string)
func (DefaultObjectStorage) CompleteUpload ¶
func (s DefaultObjectStorage) CompleteUpload(key string, uploadID string, parts []*Part) error
func (DefaultObjectStorage) Create ¶
func (s DefaultObjectStorage) Create() error
func (DefaultObjectStorage) CreateMultipartUpload ¶
func (s DefaultObjectStorage) CreateMultipartUpload(key string) (*MultipartUpload, error)
func (DefaultObjectStorage) List ¶
func (s DefaultObjectStorage) List(prefix, marker string, limit int64) ([]*Object, error)
func (DefaultObjectStorage) ListAll ¶
func (s DefaultObjectStorage) ListAll(prefix, marker string) (<-chan *Object, error)
func (DefaultObjectStorage) ListUploads ¶
func (s DefaultObjectStorage) ListUploads(marker string) ([]*PendingPart, string, error)
func (DefaultObjectStorage) UploadPart ¶
type FileSystem ¶
type ListBucketResult ¶ added in v0.1.4
type ListBucketResult struct {
Contents []*Contents
IsTruncated bool
Prefix string
Marker string
MaxKeys string
NextMarker string
CommonPrefixes string
}
ListObjectsOutput presents output for ListObjects.
type MultipartUpload ¶
type ObjectStorage ¶
type ObjectStorage interface {
// Description of the object storage.
String() string
// Create the bucket if not existed.
Create() error
// Get the data for the given object specified by key.
Get(key string, off, limit int64) (io.ReadCloser, error)
// Put data read from a reader to an object specified by key.
Put(key string, in io.Reader) error
// Delete a object.
Delete(key string) error
Head(key string) (*Object, error)
List(prefix, marker string, limit int64) ([]*Object, error)
ListAll(prefix, marker string) (<-chan *Object, error)
CreateMultipartUpload(key string) (*MultipartUpload, error)
UploadPart(key string, uploadID string, num int, body []byte) (*Part, error)
AbortUpload(key string, uploadID string)
CompleteUpload(key string, uploadID string, parts []*Part) error
ListUploads(marker string) ([]*PendingPart, string, error)
}
ObjectStorage is the interface for object storage. all of these API should be idempotent.
func CreateStorage ¶
func CreateStorage(name, endpoint, accessKey, secretKey string) (ObjectStorage, error)
func WithPrefix ¶
func WithPrefix(os ObjectStorage, prefix string) (ObjectStorage, error)
WithPrefix retuns a object storage that add a prefix to keys.
type RestfulStorage ¶
type RestfulStorage struct {
DefaultObjectStorage
// contains filtered or unexported fields
}
func (*RestfulStorage) Copy ¶
func (s *RestfulStorage) Copy(dst, src string) error
func (*RestfulStorage) Delete ¶
func (s *RestfulStorage) Delete(key string) error
func (*RestfulStorage) Get ¶
func (s *RestfulStorage) Get(key string, off, limit int64) (io.ReadCloser, error)
func (*RestfulStorage) List ¶
func (s *RestfulStorage) List(prefix, marker string, limit int64) ([]*Object, error)
func (*RestfulStorage) String ¶
func (s *RestfulStorage) String() string
Source Files
¶
Click to show internal directories.
Click to hide internal directories.