ossfs

Documentation

Index

• Variables
• func New(config gfs.IAdapterConfig) gfs.IAdapter
• type Adapter
  • func NewOSS(config *Config) *Adapter
  • func (a *Adapter) Bucket(bucket string) gfs.IAdapter
  • func (a *Adapter) Client() (*oss.Client, error)
  • func (a *Adapter) Copy(source, destination string) (bool, error)
  • func (a *Adapter) CopyObject(srcObjectKey, destObjectKey string, isDelete bool) (bool, error)
  • func (a *Adapter) Delete(path string) (int64, error)
  • func (a *Adapter) DiskName() string
  • func (a *Adapter) Exist(path string) (bool, error)
  • func (a *Adapter) Meta(path string) (header http.Header, err error)
  • func (a *Adapter) MimeType(path string) (string, error)
  • func (a *Adapter) Move(source, destination string) (bool, error)
  • func (a *Adapter) OSSBucket() (*oss.Bucket, error)
  • func (a *Adapter) Read(path string) ([]byte, error)
  • func (a *Adapter) Size(path string) (int64, error)
  • func (a *Adapter) URL(path string) (*url.URL, error)
  • func (a *Adapter) Update(path string, contents []byte) error
  • func (a *Adapter) UpdateStream(path, resource string) error
  • func (a *Adapter) Write(path string, contents []byte) error
  • func (a *Adapter) WriteReader(path string, reader io.Reader) error
  • func (a *Adapter) WriteStream(path, resource string) error
• type Config
  • func (c *Config) NewAdapter() gfs.IAdapter
  • func (c *Config) URL(path string) (*url.URL, error)
  • func (c *Config) UseBucket(bucket string) string

Variables

var (
	DefaultEndpoint = "oss-cn-hangzhou.aliyuncs.com"
)

Functions

func New

func New(config gfs.IAdapterConfig) gfs.IAdapter

Types

type Adapter

type Adapter struct {
	Config *Config
	// contains filtered or unexported fields
}

func NewOSS

func NewOSS(config *Config) *Adapter

func (*Adapter) Bucket

func (a *Adapter) Bucket(bucket string) gfs.IAdapter

func (*Adapter) Client

func (a *Adapter) Client() (*oss.Client, error)

func (*Adapter) Copy

func (a *Adapter) Copy(source, destination string) (bool, error)

func (*Adapter) CopyObject

func (a *Adapter) CopyObject(srcObjectKey, destObjectKey string, isDelete bool) (bool, error)

func (*Adapter) Delete

func (a *Adapter) Delete(path string) (int64, error)

func (*Adapter) DiskName

func (a *Adapter) DiskName() string

func (*Adapter) Exist

func (a *Adapter) Exist(path string) (bool, error)

func (*Adapter) Meta

func (a *Adapter) Meta(path string) (header http.Header, err error)

func (*Adapter) MimeType

func (a *Adapter) MimeType(path string) (string, error)

func (*Adapter) Move

func (a *Adapter) Move(source, destination string) (bool, error)

func (*Adapter) OSSBucket

func (a *Adapter) OSSBucket() (*oss.Bucket, error)

func (*Adapter) Read

func (a *Adapter) Read(path string) ([]byte, error)

func (*Adapter) Size

func (a *Adapter) Size(path string) (int64, error)

func (*Adapter) URL

func (a *Adapter) URL(path string) (*url.URL, error)

func (*Adapter) Update

func (a *Adapter) Update(path string, contents []byte) error

func (*Adapter) UpdateStream

func (a *Adapter) UpdateStream(path, resource string) error

func (*Adapter) Write

func (a *Adapter) Write(path string, contents []byte) error

func (*Adapter) WriteReader

func (a *Adapter) WriteReader(path string, reader io.Reader) error

func (*Adapter) WriteStream

func (a *Adapter) WriteStream(path, resource string) error

type Config

type Config struct {
	CDN    string `json:"cdn" xml:"CDN" yaml:"CDN"`
	Bucket string `json:"bucket" xml:"Bucket" yaml:"Bucket"`
	//https://help.aliyun.com/zh/oss/user-guide/regions-and-endpoints
	Endpoint        string      `json:"endpoint" xml:"Endpoint" yaml:"Endpoint"`
	AccessKeyID     string      `json:"access_key_id" xml:"AccessKeyID" yaml:"AccessKeyID"`
	AccessKeySecret string      `json:"access_key_secret" xml:"AccessKeySecret" yaml:"AccessKeySecret"`
	Config          *oss.Config `json:"config" xml:"Config" yaml:"Config"`
}

func (*Config) NewAdapter

func (c *Config) NewAdapter() gfs.IAdapter

func (*Config) URL

func (c *Config) URL(path string) (*url.URL, error)

func (*Config) UseBucket

func (c *Config) UseBucket(bucket string) string