localdisk

Documentation

Index

• func BlobFileBaseName(b *blobref.BlobRef) string
• type DiskStorage
  • func New(root string) (*DiskStorage, error)
  • func (ds *DiskStorage) CreateQueue(name string) (blobserver.Storage, error)
  • func (ds *DiskStorage) EnumerateBlobs(dest chan<- blobref.SizedBlobRef, after string, limit int, wait time.Duration) error
  • func (ds *DiskStorage) Fetch(blob *blobref.BlobRef) (blobref.ReadSeekCloser, int64, error)
  • func (ds *DiskStorage) FetchStreaming(blob *blobref.BlobRef) (io.ReadCloser, int64, error)
  • func (ds *DiskStorage) PartitionRoot(partition string) string
  • func (ds *DiskStorage) ReceiveBlob(blobRef *blobref.BlobRef, source io.Reader) (blobGot blobref.SizedBlobRef, err error)
  • func (ds *DiskStorage) RemoveBlobs(blobs []*blobref.BlobRef) error
  • func (ds *DiskStorage) ResetStorageGeneration() error
  • func (ds *DiskStorage) StatBlobs(dest chan<- blobref.SizedBlobRef, blobs []*blobref.BlobRef, wait time.Duration) error
  • func (ds *DiskStorage) StorageGeneration() (initTime time.Time, random string, err error)

Functions

func BlobFileBaseName

func BlobFileBaseName(b *blobref.BlobRef) string

Types

type DiskStorage

type DiskStorage struct {
	*blobserver.SimpleBlobHubPartitionMap
	// contains filtered or unexported fields
}

func New

func New(root string) (*DiskStorage, error)

New returns a new local disk storage implementation, rooted at the provided directory, which must already exist.

func (*DiskStorage) CreateQueue

func (ds *DiskStorage) CreateQueue(name string) (blobserver.Storage, error)

func (*DiskStorage) EnumerateBlobs

func (ds *DiskStorage) EnumerateBlobs(dest chan<- blobref.SizedBlobRef, after string, limit int, wait time.Duration) error

func (*DiskStorage) Fetch

func (ds *DiskStorage) Fetch(blob *blobref.BlobRef) (blobref.ReadSeekCloser, int64, error)

func (*DiskStorage) FetchStreaming

func (ds *DiskStorage) FetchStreaming(blob *blobref.BlobRef) (io.ReadCloser, int64, error)

func (*DiskStorage) PartitionRoot

func (ds *DiskStorage) PartitionRoot(partition string) string

func (*DiskStorage) ReceiveBlob

func (ds *DiskStorage) ReceiveBlob(blobRef *blobref.BlobRef, source io.Reader) (blobGot blobref.SizedBlobRef, err error)

func (*DiskStorage) RemoveBlobs

func (ds *DiskStorage) RemoveBlobs(blobs []*blobref.BlobRef) error

func (*DiskStorage) ResetStorageGeneration

func (ds *DiskStorage) ResetStorageGeneration() error

func (*DiskStorage) StatBlobs

func (ds *DiskStorage) StatBlobs(dest chan<- blobref.SizedBlobRef, blobs []*blobref.BlobRef, wait time.Duration) error

func (*DiskStorage) StorageGeneration

func (ds *DiskStorage) StorageGeneration() (initTime time.Time, random string, err error)