oss

Documentation

Index

• Constants
• func CheckWithCopy(ctx context.Context, handle Handle, srcPath string, business, scene string) (string, error)
• func GetFilePath(scene *SceneInfo, rename bool) (string, error)
• type AliYunOss
  • func (a *AliYunOss) CopyFromTempBucket(tempPath, dstPath string) (string, error)
  • func (a *AliYunOss) Delete(ctx context.Context, fileDir string, opKv common.OptionKv) error
  • func (a *AliYunOss) GetObjectInfo(ctx context.Context, fileDir string) (*common.StorageObjectInfo, error)
  • func (a *AliYunOss) GetUrl(filePath string) (string, error)
  • func (a *AliYunOss) PrivateBucket() Handle
  • func (a *AliYunOss) PublicBucket() Handle
  • func (a *AliYunOss) SignedGetUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)
  • func (a *AliYunOss) SignedPutUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)
  • func (a *AliYunOss) TemporaryBucket() Handle
  • func (a *AliYunOss) Upload(ctx context.Context, filePath string, content io.Reader, opKv common.OptionKv) (string, error)
• type Client
  • func NewOssClient(c conf.OssConf) *Client
• type Handle
• type Minio
  • func (m *Minio) CopyFromTempBucket(tempPath, dstPath string) (string, error)
  • func (m *Minio) Delete(ctx context.Context, fileDir string, opKv common.OptionKv) error
  • func (m *Minio) GetObjectInfo(ctx context.Context, filePath string) (*common.StorageObjectInfo, error)
  • func (m *Minio) GetUrl(path string) (string, error)
  • func (m *Minio) IsObjectExist(ctx context.Context, filePath string, opKv common.OptionKv) (bool, error)
  • func (m *Minio) PrivateBucket() Handle
  • func (m *Minio) PublicBucket() Handle
  • func (m *Minio) SignedGetUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)
  • func (m *Minio) SignedPutUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)
  • func (m *Minio) TemporaryBucket() Handle
  • func (m *Minio) Upload(ctx context.Context, filePath string, reader io.Reader, opKv common.OptionKv) (string, error)
• type OpOption
• type SceneInfo
  • func GetSceneInfo(filePath string) (*SceneInfo, error)

Constants

const (
	BusinessProductManage = "productManage" //产品管理
	SceneProductImg       = "productImg"    //产品图片
)

产品管理

Functions

func CheckWithCopy

func CheckWithCopy(ctx context.Context, handle Handle, srcPath string, business, scene string) (string, error)

func GetFilePath

func GetFilePath(scene *SceneInfo, rename bool) (string, error)

Types

type AliYunOss

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

func (*AliYunOss) CopyFromTempBucket

func (a *AliYunOss) CopyFromTempBucket(tempPath, dstPath string) (string, error)

func (*AliYunOss) Delete

func (a *AliYunOss) Delete(ctx context.Context, fileDir string, opKv common.OptionKv) error

func (*AliYunOss) GetObjectInfo

func (a *AliYunOss) GetObjectInfo(ctx context.Context, fileDir string) (*common.StorageObjectInfo, error)

func (*AliYunOss) GetUrl

func (a *AliYunOss) GetUrl(filePath string) (string, error)

func (*AliYunOss) PrivateBucket

func (a *AliYunOss) PrivateBucket() Handle

func (*AliYunOss) PublicBucket

func (a *AliYunOss) PublicBucket() Handle

func (*AliYunOss) SignedGetUrl

func (a *AliYunOss) SignedGetUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)

func (*AliYunOss) SignedPutUrl

func (a *AliYunOss) SignedPutUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)

获取put上传url

func (*AliYunOss) TemporaryBucket

func (a *AliYunOss) TemporaryBucket() Handle

func (*AliYunOss) Upload

func (a *AliYunOss) Upload(ctx context.Context, filePath string, content io.Reader, opKv common.OptionKv) (string, error)

type Client

type Client struct {
	Handle
}

func NewOssClient

func NewOssClient(c conf.OssConf) *Client

type Handle

type Handle interface {
	SignedPutUrl(ctx context.Context, objectName string, expiredSec int64, opKv common.OptionKv) (string, error)
	SignedGetUrl(ctx context.Context, objectName string, expiredSec int64, opKv common.OptionKv) (string, error)
	Delete(ctx context.Context, objectName string, opKv common.OptionKv) error
	Upload(ctx context.Context, objectName string, reader io.Reader, opKv common.OptionKv) (string, error)
	GetObjectInfo(ctx context.Context, objectName string) (*common.StorageObjectInfo, error)
	PrivateBucket() Handle
	PublicBucket() Handle
	TemporaryBucket() Handle
	CopyFromTempBucket(tempPath, dstPath string) (string, error)
	GetUrl(path string) (string, error)
}

type Minio

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

func (*Minio) CopyFromTempBucket

func (m *Minio) CopyFromTempBucket(tempPath, dstPath string) (string, error)

func (*Minio) Delete

func (m *Minio) Delete(ctx context.Context, fileDir string, opKv common.OptionKv) error

删除

func (*Minio) GetObjectInfo

func (m *Minio) GetObjectInfo(ctx context.Context, filePath string) (*common.StorageObjectInfo, error)

func (*Minio) GetUrl

func (m *Minio) GetUrl(path string) (string, error)

获取完整链接

func (*Minio) IsObjectExist

func (m *Minio) IsObjectExist(ctx context.Context, filePath string, opKv common.OptionKv) (bool, error)

func (*Minio) PrivateBucket

func (m *Minio) PrivateBucket() Handle

func (*Minio) PublicBucket

func (m *Minio) PublicBucket() Handle

func (*Minio) SignedGetUrl

func (m *Minio) SignedGetUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)

获取get下载url

func (*Minio) SignedPutUrl

func (m *Minio) SignedPutUrl(ctx context.Context, fileDir string, expiredSec int64, opKv common.OptionKv) (string, error)

获取put上传url

func (*Minio) TemporaryBucket

func (m *Minio) TemporaryBucket() Handle

func (*Minio) Upload

func (m *Minio) Upload(ctx context.Context, filePath string, reader io.Reader, opKv common.OptionKv) (string, error)

type OpOption

type OpOption func(*common.OptionKv)

type SceneInfo

type SceneInfo struct {
	Business string
	Scene    string
	FilePath string
	FileName string
}

func GetSceneInfo

func GetSceneInfo(filePath string) (*SceneInfo, error)