ossclient

Documentation

Index

• type AliyunOssStarter
  • func (inst *AliyunOssStarter) GetConnection() Connection
  • func (inst *AliyunOssStarter) Start() error
  • func (inst *AliyunOssStarter) Stop() error
• type Configuration
• type Connection
• type ConnectionHolder
• type Connector
• type DataSource
• type DefaultConnector
  • func (inst *DefaultConnector) Connect(ds DataSource, cfg *Configuration) (Connection, error)
• type OssDataSource
  • func (inst *OssDataSource) Connect(bucket string) (Connection, error)
  • func (inst *OssDataSource) FetchBucketList() ([]string, error)
  • func (inst *OssDataSource) GetBucketList() []string
  • func (inst *OssDataSource) GetDefaultBucket() string

Types

type AliyunOssStarter

type AliyunOssStarter struct {
	markup.Component `id:"aliyun-oss-agent" class:"aliyun-oss-starter" initMethod:"Start" destroyMethod:"Stop"`

	DS     DataSource `inject:"#aliyun-oss-data-source"`
	Enable bool       `inject:"${aliyun.oss.enable}"`
	// contains filtered or unexported fields
}

AliyunOssStarter 控制OSS数据源

func (*AliyunOssStarter) GetConnection

func (inst *AliyunOssStarter) GetConnection() Connection

func (*AliyunOssStarter) Start

func (inst *AliyunOssStarter) Start() error

func (*AliyunOssStarter) Stop

func (inst *AliyunOssStarter) Stop() error

type Configuration

type Configuration struct {
	BucketName      string
	Endpoint        string
	AccessKeyID     string
	AccessKeySecret string
}

Configuration 表示一个连接的配置

type Connection

type Connection interface {
	io.Closer
	Client() *oss.Client
	Bucket() *oss.Bucket
	BucketName() string
	DataSource() DataSource
	Test() error
}

Connection 表示一个连接

type ConnectionHolder

type ConnectionHolder interface {
	GetConnection() Connection
}

ConnectionHolder 持有一个 OSS 连接

type Connector

type Connector interface {
	Connect(ds DataSource, c *Configuration) (Connection, error)
}

Connector 表示一个连接器

type DataSource

type DataSource interface {
	GetDefaultBucket() string
	GetBucketList() []string
	FetchBucketList() ([]string, error)
	Connect(bucket string) (Connection, error)
}

DataSource 表示一个 oss 数据源

type DefaultConnector

type DefaultConnector struct {
	markup.Component `id:"aliyun-oss-connector"`
}

DefaultConnector 表示一个连接器

func (*DefaultConnector) Connect

func (inst *DefaultConnector) Connect(ds DataSource, cfg *Configuration) (Connection, error)

Connect 连接到 OSS 服务

type OssDataSource

type OssDataSource struct {
	markup.Component `id:"aliyun-oss-data-source"`

	Endpoint          string `inject:"${aliyun.oss.endpoint}"`
	AccessKeyID       string `inject:"${aliyun.oss.access-key-id}"`
	AccessKeySecret   string `inject:"${aliyun.oss.access-key-secret}"`
	DefaultBucketName string `inject:"${aliyun.oss.default-bucket-name}"`

	Connector Connector `inject:"#aliyun-oss-connector"`
	// contains filtered or unexported fields
}

OssDataSource OSS 数据源

func (*OssDataSource) Connect

func (inst *OssDataSource) Connect(bucket string) (Connection, error)

Connect 连接到 OSS 服务

func (*OssDataSource) FetchBucketList

func (inst *OssDataSource) FetchBucketList() ([]string, error)

FetchBucketList 从服务端获取bucket列表

func (*OssDataSource) GetBucketList

func (inst *OssDataSource) GetBucketList() []string

GetBucketList 取本地缓存的 bucket 列表

func (*OssDataSource) GetDefaultBucket

func (inst *OssDataSource) GetDefaultBucket() string

GetDefaultBucket 取默认的 bucket 名称