backend

Documentation

Index

• type Backend
• type HdfsBackend
  • 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
  • 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
  • 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)

Types

type Backend

type Backend interface {
	LatestVersion(checkForSuccessFile bool) (string, error)
	Download(version string, destPath string) error
	DisplayPath(version string) string
}

type HdfsBackend

type HdfsBackend struct {
	// contains filtered or unexported fields
}

func NewHdfsBackend

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

func (*HdfsBackend) DisplayPath

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

func (*HdfsBackend) Download

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

func (*HdfsBackend) LatestVersion

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

type LocalBackend

type LocalBackend struct {
	// contains filtered or unexported fields
}

A basic backend for the local filesystem

func NewLocalBackend

func NewLocalBackend(path string) *LocalBackend

func (*LocalBackend) DisplayPath

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

func (*LocalBackend) Download

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

func (*LocalBackend) LatestVersion

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

type S3Backend

type S3Backend struct {
	// contains filtered or unexported fields
}

func NewS3Backend

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

func (*S3Backend) DisplayPath

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

func (*S3Backend) Download

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

func (*S3Backend) LatestVersion

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