oss

package

v0.0.0-...-2ab4f9d Latest Latest Go to latest Published: Jan 22, 2024 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xuelang-group/go-object-storage

Documentation ¶

Index ¶

Variables
func HandleError(err error) common.ObjectStorageError
func NewAliyunOSSStorage(config *common.Config) (common.Storage, common.ObjectStorageError)
type AccessDeniedErrorProcessor
- func NewAccessDeniedErrorProcessor() *AccessDeniedErrorProcessor
- func (p *AccessDeniedErrorProcessor) Match(err error) bool
- func (p *AccessDeniedErrorProcessor) Process(err error) common.ObjectStorageError
type AliyunOSSStorage
type DefaultErrorProcessor
- func NewDefaultErrorProcessor() *DefaultErrorProcessor
- func (p *DefaultErrorProcessor) Match(e error) bool
- func (p *DefaultErrorProcessor) Process(e error) common.ObjectStorageError
type NoSuchHostErrorProcessor
- func NewNoSuchHostErrorProcessor() *NoSuchHostErrorProcessor
- func (p *NoSuchHostErrorProcessor) Match(err error) bool
- func (p *NoSuchHostErrorProcessor) Process(err error) common.ObjectStorageError

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrorCodeMap = map[string]common.ErrorCode{
	"NoSuchKey":             common.ErrCodeNoSuchKey,
	"NoSuchBucket":          common.ErrCodeNoSuchBucket,
	"AccessDenied":          common.ErrCodeAccessDenied,
	"BucketNotFound":        common.ErrCodeNoSuchBucket,
	"RequestTimeout":        common.ErrCodeRequestTimeout,
	"InvalidObjectName":     common.ErrCodeInvalidObjectName,
	"InvalidAccessKeyId":    common.ErrCodeInvalidAccessKeyID,
	"BucketAlreadyExists":   common.ErrCodeBucketAlreadyExists,
	"SignatureDoesNotMatch": common.ErrCodeInvalidAccessKeySecret,
}

Functions ¶

func HandleError ¶

func HandleError(err error) common.ObjectStorageError

func NewAliyunOSSStorage ¶

func NewAliyunOSSStorage(config *common.Config) (common.Storage, common.ObjectStorageError)

Types ¶

type AccessDeniedErrorProcessor ¶

type AccessDeniedErrorProcessor struct {
	*common.BaseErrorProcessor
}

func NewAccessDeniedErrorProcessor ¶

func NewAccessDeniedErrorProcessor() *AccessDeniedErrorProcessor

func (*AccessDeniedErrorProcessor) Match ¶

func (p *AccessDeniedErrorProcessor) Match(err error) bool

func (*AccessDeniedErrorProcessor) Process ¶

func (p *AccessDeniedErrorProcessor) Process(err error) common.ObjectStorageError

type AliyunOSSStorage ¶

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

func (*AliyunOSSStorage) BucketExists ¶

func (oss *AliyunOSSStorage) BucketExists(bucketName string) (bool, common.ObjectStorageError)

func (*AliyunOSSStorage) CopyObject ¶

func (oss *AliyunOSSStorage) CopyObject(srcObjectKey, destObjectKey string, options *common.CopyOptions) common.ObjectStorageError

func (*AliyunOSSStorage) CreateBucket ¶

func (oss *AliyunOSSStorage) CreateBucket(bucketName string) common.ObjectStorageError

func (*AliyunOSSStorage) DeleteObject ¶

func (oss *AliyunOSSStorage) DeleteObject(objectKey string) common.ObjectStorageError

func (*AliyunOSSStorage) EnsureBucket ¶

func (oss *AliyunOSSStorage) EnsureBucket(bucketName string) common.ObjectStorageError

func (*AliyunOSSStorage) FGetObject ¶

func (oss *AliyunOSSStorage) FGetObject(objectKey, localFilePath string) common.ObjectStorageError

func (*AliyunOSSStorage) FPutObject ¶

func (oss *AliyunOSSStorage) FPutObject(localFilePath, objectKey string) common.ObjectStorageError

func (*AliyunOSSStorage) GetObject ¶

func (o *AliyunOSSStorage) GetObject(objectKey string) (common.IObjectData, common.ObjectStorageError)

func (*AliyunOSSStorage) ListObjects ¶

func (o *AliyunOSSStorage) ListObjects(opt common.ListOptions) ([]common.ObjectInfo, common.ObjectStorageError)

func (*AliyunOSSStorage) MoveObject ¶

func (oss *AliyunOSSStorage) MoveObject(srcObjectKey, destObjectKey string, options *common.MoveOptions) common.ObjectStorageError

func (*AliyunOSSStorage) ObjectExist ¶

func (oss *AliyunOSSStorage) ObjectExist(objectKey string) (bool, common.ObjectStorageError)

func (*AliyunOSSStorage) PutObject ¶

func (oss *AliyunOSSStorage) PutObject(objectKey string, reader io.Reader) common.ObjectStorageError

type DefaultErrorProcessor ¶

type DefaultErrorProcessor struct {
	*common.BaseErrorProcessor
}

func NewDefaultErrorProcessor ¶

func NewDefaultErrorProcessor() *DefaultErrorProcessor

func (*DefaultErrorProcessor) Match ¶

func (p *DefaultErrorProcessor) Match(e error) bool

func (*DefaultErrorProcessor) Process ¶

func (p *DefaultErrorProcessor) Process(e error) common.ObjectStorageError

type NoSuchHostErrorProcessor ¶

type NoSuchHostErrorProcessor struct {
	*common.BaseErrorProcessor
}

func NewNoSuchHostErrorProcessor ¶

func NewNoSuchHostErrorProcessor() *NoSuchHostErrorProcessor

func (*NoSuchHostErrorProcessor) Match ¶

func (p *NoSuchHostErrorProcessor) Match(err error) bool

func (*NoSuchHostErrorProcessor) Process ¶

func (p *NoSuchHostErrorProcessor) Process(err error) common.ObjectStorageError

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL