Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + func GetDefaultMetaStore(bucket, prefix, region, ak, sk, runnerName string) string + func GetDefaultSyncDir(bucket, prefix, region, ak, sk, runnerName string) (origDir string, newDir string) + func GetS3UserInfo(conf conf.MapConf) (bucket, prefix, region, endpoint, ak, sk string, err error) + func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) + type Reader struct + func (r *Reader) Close() error + func (r *Reader) Reset() (err error)