cloudtrail

Documentation

Index

• func GetDefaultMetaStore(bucket, prefix, region, ak, sk, runnerName string) string
• func GetDefaultSyncDir(bucket, prefix, region, ak, sk, runnerName string) string
• func GetS3UserInfo(conf conf.MapConf) (bucket, prefix, region, ak, sk string, err error)
• func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error)
• type Reader
  • func (r *Reader) Close() error
  • func (r *Reader) Reset() (err error)

Functions

func GetDefaultMetaStore

func GetDefaultMetaStore(bucket, prefix, region, ak, sk, runnerName string) string

func GetDefaultSyncDir

func GetDefaultSyncDir(bucket, prefix, region, ak, sk, runnerName string) string

func GetS3UserInfo

func GetS3UserInfo(conf conf.MapConf) (bucket, prefix, region, ak, sk string, err error)

func NewReader

func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error)

Types

type Reader

type Reader struct {
	*reader.BufReader
	// contains filtered or unexported fields
}

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Reset

func (r *Reader) Reset() (err error)