storage

Documentation

Index

• type ByteRange
  • func BRange(start, end uint32) ByteRange
  • func BRangeStart(start uint32) ByteRange
• type Fetcher
  • func InitializeFsService(directory string) Fetcher
  • func InitializeS3Service(bucketName, region string) Fetcher
• type FsImpl
  • func (fs *FsImpl) Fetch(path string, brange ByteRange) []byte
  • func (fs *FsImpl) ListFiles() []string
• type S3Impl
  • func (service *S3Impl) Fetch(objectName string, bRange ByteRange) []byte
  • func (service *S3Impl) ListFiles() []string

Types

type ByteRange

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

func BRange

func BRange(start, end uint32) ByteRange

func BRangeStart

func BRangeStart(start uint32) ByteRange

type Fetcher

type Fetcher interface {
	// Fetch the byte range. Start and end of byte range are inclusive.
	Fetch(objectName string, bRange ByteRange) []byte
	ListFiles() []string
}

func InitializeFsService

func InitializeFsService(directory string) Fetcher

func InitializeS3Service

func InitializeS3Service(bucketName, region string) Fetcher

type FsImpl

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

func (*FsImpl) Fetch

func (fs *FsImpl) Fetch(path string, brange ByteRange) []byte

func (*FsImpl) ListFiles

func (fs *FsImpl) ListFiles() []string

type S3Impl

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

func (*S3Impl) Fetch

func (service *S3Impl) Fetch(objectName string, bRange ByteRange) []byte

func (*S3Impl) ListFiles

func (service *S3Impl) ListFiles() []string