operation

Apr 14, 2022

Changes in this version

type Config

+ RecycleBin string

type Lister

+ func (l *Lister) ForceDelete(key string) error

+ func (l *Lister) ForceDeleteKeys(keys []string) ([]*DeleteKeysError, error)

Apr 7, 2022

Changes in this version

+ type DeleteKeysError struct

+ Code int

+ Error string

+ Name string

type Lister

+ func (l *Lister) DeleteKeys(keys []string) ([]*DeleteKeysError, error)

Mar 22, 2022

Changes in this version

type Downloader

+ func (d *Downloader) DownloadRangeReader(key string, offset, size int64) (l int64, reader io.ReadCloser, err error)

+ func (d *Downloader) DownloadRaw(key string, headers http.Header) (*http.Response, error)

Feb 9, 2022

Changes in this version

+ const FileError

+ const HostError

+ const PathError

type Downloader

+ func (d *Downloader) DownloadCheck(key string) (l int64, err error)

+ func (d *Downloader) DownloadCheckList(ctx context.Context, keys []string) ([]*FileStat, error)

Nov 11, 2021

Changes in this version

+ const DefaultPathPrefix

+ type ApiServer struct

+ func NewApiServer(c *Config) *ApiServer

+ func NewApiServerV2() *ApiServer

+ func (svr *ApiServer) GetLogicalAvailableSizes() (map[string]uint64, error)

type Config

+ ApiServerHosts []string

type Queryer

+ func (queryer *Queryer) QueryApiServerHosts(https bool) (urls []string)

Nov 3, 2021

Changes in this version

+ const QINIU_DISABLE_CONFIG_HOT_RELOADING_ENV

+ const QINIU_ENV

+ const QINIU_MULTI_CLUSTER_ENV

+ var ErrCannotTransferBetweenDifferentClusters = errors.New("cannot transfer between different clusters")

+ var ErrUndefinedConfig = errors.New("undefined config")

+ func WithCurrentConfigurable(f func(configurable Configurable))

+ type Configurable interface

+ type MultiClustersConfig struct

+ func LoadMultiClusterConfigs(file string) (*MultiClustersConfig, error)

+ func (multiConfigs *MultiClustersConfig) SetConfigSelectCallback(f func(map[string]*Config, string) (*Config, bool))

+ type SingleClusterConfig = Config

Jul 13, 2021

Changes in this version

type Config

+ BatchConcurrency int

+ BatchSize int

Jun 25, 2021

Changes in this version

+ var MaxContinuousFailureDuration = 1 * time.Minute

+ var MaxContinuousFailureTimes = 5

+ var MaxFindHostsPrecent = 50

Mar 24, 2021

Changes in this version

+ func FileServer(root FileSystem) http.Handler

+ func NewTransport(dialTimeoutMs int) http.RoundTripper

+ func ServeContent(w http.ResponseWriter, req *http.Request, name string, modtime time.Time, ...)

+ func ServeFile(w http.ResponseWriter, r *http.Request, name string)

+ func SetCacheDirectoryAndLoad(path string) error

+ func SetLogger(logger kodocli.Ilog)

+ func StartServer(cfg *Config) (*http.Server, error)

+ func StartSimulateErrorServer(_ *Config)

+ type Config struct

+ Addr string

+ Ak string

+ Bucket string

+ Delete bool

+ DialTimeoutMs int

+ DownPath string

+ IoHosts []string

+ PartSize int64

+ PunishTimeS int

+ Retry int

+ RsHosts []string

+ RsfHosts []string

+ Sim bool

+ Sk string

+ UcHosts []string

+ UpConcurrency int

+ UpHosts []string

+ func Load(file string) (*Config, error)

+ type Dir string

+ func (d Dir) Open(name string) (File, error)

+ type Downloader struct

+ func NewDownloader(c *Config) *Downloader

+ func NewDownloaderV2() *Downloader

+ func (d *Downloader) DownloadBytes(key string) ([]byte, error)

+ func (d *Downloader) DownloadBytesWithContext(ctx context.Context, key string) (data []byte, err error)

+ func (d *Downloader) DownloadFile(key, path string) (*os.File, error)

+ func (d *Downloader) DownloadFileWithContext(ctx context.Context, key, path string) (f *os.File, err error)

+ func (d *Downloader) DownloadRangeBytes(key string, offset, size int64) (int64, []byte, error)

+ func (d *Downloader) DownloadRangeBytesWithContext(ctx context.Context, key string, offset, size int64) (l int64, data []byte, err error)

+ func (d *Downloader) DownloadReader(key string) (io.ReadCloser, error)

+ func (d *Downloader) DownloadReaderWithContext(ctx context.Context, key string) (r io.ReadCloser, err error)

+ type File interface

+ Readdir func(count int) ([]os.FileInfo, error)

+ Stat func() (os.FileInfo, error)

+ type FileStat struct

+ Name string

+ Size int64

+ type FileSystem interface

+ Open func(name string) (File, error)

+ type HostSelector struct

+ func NewHostSelector(hosts []string, update func() []string, ...) *HostSelector

+ func (hostSelector *HostSelector) Punish(host string)

+ func (hostSelector *HostSelector) PunishIfNeeded(host string, err error)

+ func (hostSelector *HostSelector) Reward(host string)

+ func (hostSelector *HostSelector) SelectHost() string

+ type Lister struct

+ func NewLister(c *Config) *Lister

+ func NewListerV2() *Lister

+ func (l *Lister) Copy(fromKey, toKey string) error

+ func (l *Lister) CopyWithContext(ctx context.Context, fromKey, toKey string) (err error)

+ func (l *Lister) Delete(key string) error

+ func (l *Lister) DeleteWithContext(ctx context.Context, key string) (err error)

+ func (l *Lister) ListPrefix(prefix string) []string

+ func (l *Lister) ListPrefixWithContext(ctx context.Context, prefix string) (keys []string)

+ func (l *Lister) ListPrefixWithMarker(prefix, marker string, limit int) ([]kodo.ListItem, string, error)

+ func (l *Lister) ListPrefixWithMarkerAndContext(ctx context.Context, prefix, marker string, limit int) (entries []kodo.ListItem, nextContinuousToken string, err error)

+ func (l *Lister) ListStat(paths []string) []*FileStat

+ func (l *Lister) ListStatWithContext(ctx context.Context, paths []string) (stats []*FileStat, anyError error)

+ func (l *Lister) MoveTo(fromKey, toBucket, toKey string) error

+ func (l *Lister) MoveToWithContext(ctx context.Context, fromKey, toBucket, toKey string) (err error)

+ func (l *Lister) Rename(fromKey, toKey string) error

+ func (l *Lister) RenameWithContext(ctx context.Context, fromKey, toKey string) (err error)

+ func (l *Lister) Stat(key string) (kodo.Entry, error)

+ func (l *Lister) StatWithContext(ctx context.Context, key string) (entry kodo.Entry, err error)

+ type Queryer struct

+ func NewQueryer(c *Config) *Queryer

+ func (queryer *Queryer) QueryIoHosts(https bool) (urls []string)

+ func (queryer *Queryer) QueryRsHosts(https bool) (urls []string)

+ func (queryer *Queryer) QueryRsfHosts(https bool) (urls []string)

+ func (queryer *Queryer) QueryUpHosts(https bool) (urls []string)

+ type Req struct

+ Delete *bool

+ Key string

+ Path string

+ type Uploader struct

+ func NewUploader(c *Config) *Uploader

+ func NewUploaderV2() *Uploader

+ func (p *Uploader) Upload(file string, key string) error

+ func (p *Uploader) UploadData(data []byte, key string) error

+ func (p *Uploader) UploadDataReader(data io.ReaderAt, size int64, key string) error

+ func (p *Uploader) UploadDataReaderAt(data io.ReaderAt, size int64, key string) error

+ func (p *Uploader) UploadDataReaderAtWithContext(ctx context.Context, data io.ReaderAt, size int64, key string, ret interface{}) error

+ func (p *Uploader) UploadDataReaderWithContext(ctx context.Context, data io.ReaderAt, size int64, key string, ret interface{}) error

+ func (p *Uploader) UploadDataWithContext(ctx context.Context, data []byte, key string, ret interface{}) error

+ func (p *Uploader) UploadReader(reader io.Reader, key string) error

+ func (p *Uploader) UploadReaderWithContext(ctx context.Context, reader io.Reader, key string, ret interface{}) error

+ func (p *Uploader) UploadWithContext(ctx context.Context, file string, key string, ret interface{}) error

+ func (p *Uploader) UploadWithDataChan(key string, dataCh chan q.PartData, ret interface{}, ...) error

+ func (p *Uploader) UploadWithDataChanWithContext(ctx context.Context, key string, dataCh chan q.PartData, ret interface{}, ...) error