backend

Oct 26, 2016

Changes in this version

type Backend

+ ListDBs func() ([]string, error)

+ ListFiles func(db, version string) ([]string, error)

+ ListVersions func(db, after string, checkForSuccessFile bool) ([]string, error)

+ Open func(db, version, file string) (io.ReadCloser, error)

type HdfsBackend

+ func (h *HdfsBackend) ListDBs() ([]string, error)

+ func (h *HdfsBackend) ListFiles(db, version string) ([]string, error)

+ func (h *HdfsBackend) ListVersions(db, after string, checkForSuccess bool) ([]string, error)

+ func (h *HdfsBackend) Open(db, version, file string) (io.ReadCloser, error)

type LocalBackend

+ func (lb *LocalBackend) ListDBs() ([]string, error)

+ func (lb *LocalBackend) ListFiles(db, version string) ([]string, error)

+ func (lb *LocalBackend) ListVersions(db, after string, checkForSuccess bool) ([]string, error)

+ func (lb *LocalBackend) Open(db, version, file string) (io.ReadCloser, error)

type S3Backend

+ func (s *S3Backend) ListDBs() ([]string, error)

+ func (s *S3Backend) ListFiles(db, version string) ([]string, error)

+ func (s *S3Backend) ListVersions(db, after string, checkForSuccess bool) ([]string, error)

+ func (s *S3Backend) Open(db, version, file string) (io.ReadCloser, error)

Nov 21, 2014

Changes in this version

+ type Backend interface

+ DisplayPath func(version string) string

+ Download func(version string, destPath string) error

+ LatestVersion func(checkForSuccessFile bool) (string, error)

+ type HdfsBackend struct

+ func NewHdfsBackend(client *hdfs.Client, namenode string, hdfsPath string) *HdfsBackend

+ func (h *HdfsBackend) DisplayPath(version string) string

+ func (h *HdfsBackend) Download(version string, destPath string) error

+ func (h *HdfsBackend) LatestVersion(checkForSuccess bool) (string, error)

+ type LocalBackend struct

+ func NewLocalBackend(path string) *LocalBackend

+ func (lb *LocalBackend) DisplayPath(version string) string

+ func (lb *LocalBackend) Download(version string, destPath string) error

+ func (lb *LocalBackend) LatestVersion(checkForSuccess bool) (string, error)

+ type S3Backend struct

+ func NewS3Backend(bucket *s3.Bucket, s3path string) *S3Backend

+ func (s *S3Backend) DisplayPath(version string) string

+ func (s *S3Backend) Download(version string, destPath string) error

+ func (s *S3Backend) LatestVersion(checkForSuccess bool) (string, error)