storage

type Client interface {
	// PutObject put object to storage
	PutObject(input ObjectInput, opts ...func(o *PutOptions)) error
	// PutFolder put files in folder to storage
	PutFolder(bucket string, prefix string, root string, opts ...func(o *PutOptions)) error

	// GetObject get object
	GetObject(bucket string, key string, opts ...func(o *GetOptions)) (*ObjectOutputHook, error)
	// GetObjectsWithIterator get object list
	GetObjectsWithIterator(bucket string, prefix string, iterator func(keys []*string) error, opts ...func(o *ListOptions)) error

	// DelObject delete object with key
	DelObject(bucket string, key string, opts ...func(o *DelOptions)) error
	// DelPrefix delete object list with prefix
	DelPrefix(bucket string, prefix string, opts ...func(o *DelOptions)) error

	// Copy copy Object to target
	// If the source is prefixed, copy all the objects
	Copy(src Position, dst Position, opts ...func(o *CopyOptions)) error

	// IsExist query whether the object exists
	// If the query is prefixed, the key needs to end with '/'
	IsExist(bucket string, key string, opts ...func(o *GetOptions)) (bool, error)

	// Presign url of object
	Presign(bucket string, key string, opts ...func(o *PresignOptions)) (string, error)

	// Compress compress object into '*.tar.gz'
	// If compressing multiple objects, the key needs to end with '/'
	Compress(bucket string, key string, dst io.Writer, opts ...func(o *ListOptions)) error
}

type CopyOptions struct {
	// Context .
	Context context.Context
}

type DelOptions struct {
	// Context .
	Context context.Context
	// VersionID version id
	VersionID string
}

type Factory struct {
	// Concurrency The number of goroutines
	Works int
	// contains filtered or unexported fields
}

type GetOptions struct {
	// Context .
	Context context.Context
	// VersionID object version
	VersionID string
}

type ListOptions struct {
	// Context .
	Context context.Context
	// MaxKeys .
	MaxKeys int
	// Recursive Ignore '/' delimiter
	Recursive bool
}

type ObjectInput interface {
	Bucket() string
	Key() string
	ContentType() string
	Close() error
	Error() error
	Body() io.ReadSeeker
}

type ObjectOutput interface {
	Bucket() string
	Key() string
	ContentType() content.Type
	Decode(vPointer interface{}) error
	Body() io.ReadCloser
	Close() error
}

type ObjectOutputHook struct {
	// Fetch get object with io.ReadCloser
	Fetch func(hook func(output ObjectOutput) error) error
	// Write write object to io.WriterAt
	Write func(w io.WriterAt) error
}

type Options struct {
	// Context context
	Context context.Context
	// Timeout 连接超时时间
	Timeout time.Duration
	// Region region
	Region string
	// SSL use ssl
	UseSSL bool
}

type Position interface {
	Bucket() string
	Path() string
	IsPrefix() bool
}

type PresignOptions struct {
	// Context .
	Context context.Context
	// VersionID data version
	VersionID string
	// Expires expires time (s)
	Expires time.Duration
}

type PutOptions struct {
	// Context .
	Context context.Context
}

type Type string