core

Documentation

Index

• Constants
• func ComputeDownloadURL(p1, p2 string) string
• func LoadBucketParams(tag, name string, p collection.Properties) (*buckets.Bucket, error)
• type BucketDNSet
  • func (inst *BucketDNSet) Init(kvs map[string]string)
• type BucketLoader
  • func (inst *BucketLoader) Load(tag, id string, p collection.Properties) (*buckets.Bucket, error)
• type DefaultBucketDriverManager
  • func (inst *DefaultBucketDriverManager) FindDriver(name string) (buckets.Driver, error)
  • func (inst *DefaultBucketDriverManager) GetBucket(tag, id string, p collection.Properties) (*buckets.Bucket, error)
  • func (inst *DefaultBucketDriverManager) OpenBucket(b *buckets.Bucket) (buckets.Connection, error)
• type TempFile
  • func PrepareLargeTempFileForUploading(entity buckets.ObjectEntity) (TempFile, error)
• type TempFileManager
  • func GetTempFileManager() TempFileManager

Constants

const (
	ParamBucketID         = "id"
	ParamBucketDriver     = "driver"
	ParamBucketCredential = "credential"
	ParamBucketName       = "name"
	ParamBucketDN         = "dn-bucket"
	ParamEndpointDN       = "dn-endpoint"
)

基本的 bucket 参数

Functions

func ComputeDownloadURL

func ComputeDownloadURL(p1, p2 string) string

ComputeDownloadURL 根据参数计算下载地址 p1: 基本的URL p2: 对象的名称(路径)

func LoadBucketParams

func LoadBucketParams(tag, name string, p collection.Properties) (*buckets.Bucket, error)

LoadBucketParams 从 properties 加载 bucket 参数

Types

type BucketDNSet

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

BucketDNSet 这个结构保存，并管理一个存储桶相关的各个域名

func (*BucketDNSet) Init

func (inst *BucketDNSet) Init(kvs map[string]string)

Init ...

type BucketLoader

type BucketLoader struct {
	WantBucketExt     []string // 扩展的 bucket 参数
	WantCredentialExt []string // 扩展的 Credential 参数
	WantDriverExt     []string // 扩展的 driver 参数
}

BucketLoader 是 Bucket 的加载器

func (*BucketLoader) Load

func (inst *BucketLoader) Load(tag, id string, p collection.Properties) (*buckets.Bucket, error)

Load ...

type DefaultBucketDriverManager

type DefaultBucketDriverManager struct {
	markup.Component `id:"buckets.Manager"`

	DriverSources []buckets.DriverRegistry `inject:".buckets.Driver"`
	// contains filtered or unexported fields
}

DefaultBucketDriverManager 是默认的存储桶驱动管理器

func (*DefaultBucketDriverManager) FindDriver

func (inst *DefaultBucketDriverManager) FindDriver(name string) (buckets.Driver, error)

FindDriver 查找驱动

func (*DefaultBucketDriverManager) GetBucket

func (inst *DefaultBucketDriverManager) GetBucket(tag, id string, p collection.Properties) (*buckets.Bucket, error)

GetBucket ...

func (*DefaultBucketDriverManager) OpenBucket

func (inst *DefaultBucketDriverManager) OpenBucket(b *buckets.Bucket) (buckets.Connection, error)

OpenBucket ...

type TempFile

type TempFile interface {
	io.Closer
	GetPath() fs.Path
}

TempFile 代表临时文件

func PrepareLargeTempFileForUploading

func PrepareLargeTempFileForUploading(entity buckets.ObjectEntity) (TempFile, error)

PrepareLargeTempFileForUploading 为上传大型文件做准备

type TempFileManager

type TempFileManager interface {
	NewTempFile() TempFile
	GetTempDir() fs.Path
	SetTempDir(dir fs.Path)
}

TempFileManager 代表临时文件管理器

func GetTempFileManager

func GetTempFileManager() TempFileManager

GetTempFileManager 取临时文件管理器