buckets

type Bucket struct {
	ID       string
	Name     string // 桶名称
	Provider string // 驱动名称

	EndpointDN string
	BucketDN   string
	Credential string

	Driver Driver
	Ext    map[string]string
}

type Connection interface {
	io.Closer

	Check() error

	GetObject(name string) Object

	GetBucketName() string
}

type Connector interface {
	Open(b *Bucket) (Connection, error)
}

type Driver interface {
	GetConnector() Connector

	// 从 properties 中加载 bucket 的参数
	GetBucket(tag, id string, p collection.Properties) (*Bucket, error)
}

type DriverRegistration struct {
	Name   string
	Driver Driver
}

type DriverRegistry interface {
	ListDrivers() []*DriverRegistration
}

type HTTPUploading struct {
	UseHTTPS       bool
	Method         string
	URL            string
	ContentType    string
	ContentLength  int64
	ContentMD5     util.Hex
	MaxAge         int64 // in seconds
	RequestHeaders map[string]string
}

type Manager interface {
	FindDriver(name string) (Driver, error)

	OpenBucket(b *Bucket) (Connection, error)

	GetBucket(tag, id string, p collection.Properties) (*Bucket, error)
}

type Object interface {
	Exists() (bool, error)
	GetDownloadURL() string
	GetMeta() (*ObjectMeta, error)
	GetName() string
	UpdateMeta(meta *ObjectMeta) error
	GetEntity() (ObjectEntity, error)
	PutEntity(entity ObjectEntity, meta *ObjectMeta) error
	PutFile(file fs.Path, meta *ObjectMeta) error

	// UploadByAPI 准备上传参数;
	// 输入：待准备的参数;
	// 输出：已经准备好的参数;
	UploadByAPI(up *HTTPUploading) (*HTTPUploading, error)
}

type ObjectEntity interface {
	GetSize() int64
	Open() (io.ReadCloser, error)
}

type ObjectMeta struct {
	Size          int64
	Date          time.Time
	Hash          string
	HashAlgorithm string
	ContentType   string
	More          map[string]string
}