store

Documentation

Index

• Constants
• func ReadUrlData(urlType UrlType, urlStr string) ([]byte, error)
• type CephClient
  • func NewCephClient(cfg *CephConfig) (*CephClient, error)
  • func (cephClient *CephClient) CheckBucketExist(bucketName string) (bool, error)
  • func (cephClient *CephClient) CreateBucket(bucketName string) error
  • func (cephClient *CephClient) GetObjectUrl(bucketName, objectName string) (string, UrlType, error)
  • func (cephClient *CephClient) ListBuckets() (*ListBucketsResult, error)
  • func (cephClient *CephClient) ListObjects(bucketName, marker, prefix string) (*ListObjectsResult, error)
  • func (cephClient *CephClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error
• type CephConfig
• type ListBucketsResult
• type ListObjectsResult
• type LocalClient
  • func NewLocalClient() (*LocalClient, error)
  • func (localClient *LocalClient) CheckBucketExist(dirName string) (bool, error)
  • func (localClient *LocalClient) CreateBucket(dirName string) error
  • func (localClient *LocalClient) GetObjectUrl(dirName, objectName string) (string, UrlType, error)
  • func (localClient *LocalClient) ListBuckets() (*ListBucketsResult, error)
  • func (localClient *LocalClient) ListObjects(dirName, marker, prefix string) (*ListObjectsResult, error)
  • func (localClient *LocalClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error
• type OssClient
  • func NewOssClient(cfg *OssConfig) (*OssClient, error)
  • func (ossClient *OssClient) CheckBucketExist(bucketName string) (bool, error)
  • func (ossClient *OssClient) CreateBucket(bucketName string) error
  • func (ossClient *OssClient) GetObjectUrl(bucketName, objectName string) (string, UrlType, error)
  • func (ossClient *OssClient) ListBuckets() (*ListBucketsResult, error)
  • func (ossClient *OssClient) ListObjects(bucketName, marker, prefix string) (*ListObjectsResult, error)
  • func (ossClient *OssClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error
• type OssConfig
• type Store
• type UrlType

Constants

const DefaultS3Region string = "us-east-1"

Functions

func ReadUrlData

func ReadUrlData(urlType UrlType, urlStr string) ([]byte, error)

Types

type CephClient

type CephClient struct {
	*s3.S3
	// contains filtered or unexported fields
}

func NewCephClient

func NewCephClient(cfg *CephConfig) (*CephClient, error)

func (*CephClient) CheckBucketExist

func (cephClient *CephClient) CheckBucketExist(bucketName string) (bool, error)

func (*CephClient) CreateBucket

func (cephClient *CephClient) CreateBucket(bucketName string) error

func (*CephClient) GetObjectUrl

func (cephClient *CephClient) GetObjectUrl(bucketName, objectName string) (string, UrlType, error)

func (*CephClient) ListBuckets

func (cephClient *CephClient) ListBuckets() (*ListBucketsResult, error)

func (*CephClient) ListObjects

func (cephClient *CephClient) ListObjects(bucketName, marker, prefix string) (*ListObjectsResult, error)

func (*CephClient) UploadFile

func (cephClient *CephClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error

type CephConfig

type CephConfig struct {
	AccessKey string
	SecretKey string
	EndPoint  string
}

type ListBucketsResult

type ListBucketsResult struct {
	BucketNames []string
}

type ListObjectsResult

type ListObjectsResult struct {
	ObjectsName []string
	Suspend     *bool
	NextMarker  *string
}

type LocalClient

type LocalClient struct {
}

func NewLocalClient

func NewLocalClient() (*LocalClient, error)

func (*LocalClient) CheckBucketExist

func (localClient *LocalClient) CheckBucketExist(dirName string) (bool, error)

func (*LocalClient) CreateBucket

func (localClient *LocalClient) CreateBucket(dirName string) error

func (*LocalClient) GetObjectUrl

func (localClient *LocalClient) GetObjectUrl(dirName, objectName string) (string, UrlType, error)

func (*LocalClient) ListBuckets

func (localClient *LocalClient) ListBuckets() (*ListBucketsResult, error)

func (*LocalClient) ListObjects

func (localClient *LocalClient) ListObjects(dirName, marker, prefix string) (*ListObjectsResult, error)

func (*LocalClient) UploadFile

func (localClient *LocalClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error

type OssClient

type OssClient struct {
	*oss.Client
}

func NewOssClient

func NewOssClient(cfg *OssConfig) (*OssClient, error)

func (*OssClient) CheckBucketExist

func (ossClient *OssClient) CheckBucketExist(bucketName string) (bool, error)

func (*OssClient) CreateBucket

func (ossClient *OssClient) CreateBucket(bucketName string) error

func (*OssClient) GetObjectUrl

func (ossClient *OssClient) GetObjectUrl(bucketName, objectName string) (string, UrlType, error)

func (*OssClient) ListBuckets

func (ossClient *OssClient) ListBuckets() (*ListBucketsResult, error)

func (*OssClient) ListObjects

func (ossClient *OssClient) ListObjects(bucketName, marker, prefix string) (*ListObjectsResult, error)

func (*OssClient) UploadFile

func (ossClient *OssClient) UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error

type OssConfig

type OssConfig struct {
	AccessID  string
	AccessKey string
	EndPoint  string
}

type Store

type Store interface {
	ListBuckets() (*ListBucketsResult, error)
	CheckBucketExist(bucketName string) (bool, error)
	CreateBucket(bucketName string) error
	UploadFile(urlType UrlType, urlStr, dstBucketName, dstObjectName string) error
	GetObjectUrl(bucketName, objectName string) (string, UrlType, error)
	ListObjects(bucketName, marker, prefix string) (*ListObjectsResult, error)
}

type UrlType

type UrlType string

const (
	HttpUrl  UrlType = "http"
	LocalUrl UrlType = "file"
)