eoss

package module

Go to main page

Versions in this module

v1

v1.0.6

Oct 10, 2023

v1.0.5

Sep 18, 2023

Changes in this version

+ var DefaultGzipCompressor = &GzipCompressor

+ func GetReaderLength(reader io.ReadSeeker) (int64, error)

+ func Register(comp Compressor)

+ type Compressor interface

+ Compress func(reader io.ReadSeeker) (gzipReader io.ReadSeeker, err error)

+ ContentEncoding func() string

type CopyOption

+ func CopyWithNewAttributes(meta map[string]string) CopyOption

+ type GzipCompressor struct

+ func (g *GzipCompressor) Compress(reader io.ReadSeeker) (gzipReader io.ReadSeeker, err error)

+ func (g *GzipCompressor) ContentEncoding() string

v1.0.4

Mar 17, 2023

Changes in this version

+ func DefaultSignOptions() *signOptions

+ type SignOptions func(options *signOptions)

+ func SignWithProcess(process string) SignOptions

v1.0.3

Mar 15, 2023

Changes in this version

+ const MetaCompressor

+ const PackageName

+ const StorageTypeOSS

+ const StorageTypeS3

+ func DefaultConfig() *config

+ func DefaultCopyOptions() *copyOptions

+ func DefaultGetOptions() *getOptions

+ func DefaultPutOptions() *putOptions

+ type BuildOption func(c *Container)

+ func WithAccessKeyID(ak string) BuildOption

+ func WithAccessKeySecret(sk string) BuildOption

+ func WithBucket(bucket string) BuildOption

+ func WithBucketKey(bucketKey string) BuildOption

+ func WithEndpoint(endpoint string) BuildOption

+ func WithRegion(region string) BuildOption

+ func WithS3ForcePathStyle(s3ForcePathStyle bool) BuildOption

+ func WithS3HttpTimeoutSecs(s3HttpTimeoutSecs int64) BuildOption

+ func WithSSL(ssl bool) BuildOption

+ func WithShards(shards []string) BuildOption

+ func WithStorageType(storageType string) BuildOption

+ type CombinedReadCloser struct

+ ReadCloser io.ReadCloser

+ Reader io.Reader

+ func (combined CombinedReadCloser) Close() error

+ func (combined CombinedReadCloser) Read(b []byte) (int, error)

+ type Component interface

+ CompressAndPut func(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ Copy func(srcKey, dstKey string, options ...CopyOption) error

+ Del func(key string) error

+ DelMulti func(keys []string) error

+ Exists func(key string) (bool, error)

+ Get func(key string, options ...GetOptions) (string, error)

+ GetAndDecompress func(key string) (string, error)

+ GetAndDecompressAsReader func(key string) (io.ReadCloser, error)

+ GetAsReader func(key string, options ...GetOptions) (io.ReadCloser, error)

+ GetBucketName func(key string) (string, error)

+ GetBytes func(key string, options ...GetOptions) ([]byte, error)

+ GetWithMeta func(key string, attributes []string, options ...GetOptions) (io.ReadCloser, map[string]string, error)

+ Head func(key string, meta []string) (map[string]string, error)

+ ListObject func(key string, prefix string, marker string, maxKeys int, delimiter string) ([]string, error)

+ Put func(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ Range func(key string, offset int64, length int64) (io.ReadCloser, error)

+ SignURL func(key string, expired int64) (string, error)

+ WithContext func(ctx context.Context) Component

+ type Container struct

+ func DefaultContainer() *Container

+ func Load(key string) *Container

+ func (c *Container) Build(options ...BuildOption) Component

+ type CopyOption func(options *copyOptions)

+ func CopyWithAttributes(meta []string) CopyOption

+ func CopyWithRawSrcKey() CopyOption

+ type GetOptions func(options *getOptions)

+ func EnableCRCValidation() GetOptions

+ func GetWithContentEncoding(contentEncoding string) GetOptions

+ func GetWithContentType(contentType string) GetOptions

+ type HeadGetObjectOutputWrapper struct

+ type OSS struct

+ Bucket *oss.Bucket

+ Shards map[string]*oss.Bucket

+ func (ossClient *OSS) CompressAndPut(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ func (ossClient *OSS) Copy(srcKey, dstKey string, options ...CopyOption) error

+ func (ossClient *OSS) Del(key string) error

+ func (ossClient *OSS) DelMulti(keys []string) error

+ func (ossClient *OSS) Exists(key string) (bool, error)

+ func (ossClient *OSS) Get(key string, options ...GetOptions) (string, error)

+ func (ossClient *OSS) GetAndDecompress(key string) (string, error)

+ func (ossClient *OSS) GetAndDecompressAsReader(key string) (io.ReadCloser, error)

+ func (ossClient *OSS) GetAsReader(key string, options ...GetOptions) (io.ReadCloser, error)

+ func (ossClient *OSS) GetBucketName(key string) (string, error)

+ func (ossClient *OSS) GetBytes(key string, options ...GetOptions) ([]byte, error)

+ func (ossClient *OSS) GetWithMeta(key string, attributes []string, options ...GetOptions) (io.ReadCloser, map[string]string, error)

+ func (ossClient *OSS) Head(key string, attributes []string) (map[string]string, error)

+ func (ossClient *OSS) ListObject(key string, prefix string, marker string, maxKeys int, delimiter string) ([]string, error)

+ func (ossClient *OSS) Put(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ func (ossClient *OSS) Range(key string, offset int64, length int64) (io.ReadCloser, error)

+ func (ossClient *OSS) SignURL(key string, expired int64) (string, error)

+ func (ossClient *OSS) WithContext(context.Context) Component

+ type PutOptions func(options *putOptions)

+ func PutWithCacheControl(cacheControl string) PutOptions

+ func PutWithContentDisposition(contentDisposition string) PutOptions

+ func PutWithContentEncoding(contentEncoding string) PutOptions

+ func PutWithContentType(contentType string) PutOptions

+ func PutWithExpireTime(expires time.Time) PutOptions

+ type S3 struct

+ BucketName string

+ Client *s3.S3

+ ShardsBucket map[string]string

+ func (a *S3) CompressAndPut(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ func (a *S3) Copy(srcKey, dstKey string, options ...CopyOption) error

+ func (a *S3) Del(key string) error

+ func (a *S3) DelMulti(keys []string) error

+ func (a *S3) Exists(key string) (bool, error)

+ func (a *S3) Get(key string, options ...GetOptions) (string, error)

+ func (a *S3) GetAndDecompress(key string) (string, error)

+ func (a *S3) GetAndDecompressAsReader(key string) (io.ReadCloser, error)

+ func (a *S3) GetAsReader(key string, options ...GetOptions) (io.ReadCloser, error)

+ func (a *S3) GetBucketName(key string) (string, error)

+ func (a *S3) GetBytes(key string, options ...GetOptions) ([]byte, error)

+ func (a *S3) GetWithMeta(key string, attributes []string, options ...GetOptions) (io.ReadCloser, map[string]string, error)

+ func (a *S3) Head(key string, attributes []string) (map[string]string, error)

+ func (a *S3) ListObject(key string, prefix string, marker string, maxKeys int, delimiter string) ([]string, error)

+ func (a *S3) Put(key string, reader io.ReadSeeker, meta map[string]string, ...) error

+ func (a *S3) Range(key string, offset int64, length int64) (io.ReadCloser, error)

+ func (a *S3) SignURL(key string, expired int64) (string, error)

+ func (a *S3) WithContext(ctx context.Context) Component

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