filestore

Documentation

Index

• Variables
• type CorruptReferenceError
  • func (c CorruptReferenceError) Error() string
• type FileManager
  • func NewFileManager(ds ds.Batching, root string) *FileManager
  • func (f *FileManager) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)
  • func (f *FileManager) DeleteBlock(c *cid.Cid) error
  • func (f *FileManager) Get(c *cid.Cid) (blocks.Block, error)
  • func (f *FileManager) Has(c *cid.Cid) (bool, error)
  • func (f *FileManager) Put(b *posinfo.FilestoreNode) error
  • func (f *FileManager) PutMany(bs []*posinfo.FilestoreNode) error
• type Filestore
  • func NewFilestore(bs blockstore.Blockstore, fm *FileManager) *Filestore
  • func (f *Filestore) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)
  • func (f *Filestore) DeleteBlock(c *cid.Cid) error
  • func (f *Filestore) Get(c *cid.Cid) (blocks.Block, error)
  • func (f *Filestore) Has(c *cid.Cid) (bool, error)
  • func (f *Filestore) Put(b blocks.Block) error
  • func (f *Filestore) PutMany(bs []blocks.Block) error

Variables

var FilestorePrefix = ds.NewKey("filestore")

Types

type CorruptReferenceError

type CorruptReferenceError struct {
	Err error
}

func (CorruptReferenceError) Error

func (c CorruptReferenceError) Error() string

type FileManager

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

func NewFileManager

func NewFileManager(ds ds.Batching, root string) *FileManager

func (*FileManager) AllKeysChan

func (f *FileManager) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)

func (*FileManager) DeleteBlock

func (f *FileManager) DeleteBlock(c *cid.Cid) error

func (*FileManager) Get

func (f *FileManager) Get(c *cid.Cid) (blocks.Block, error)

func (*FileManager) Has

func (f *FileManager) Has(c *cid.Cid) (bool, error)

func (*FileManager) Put

func (f *FileManager) Put(b *posinfo.FilestoreNode) error

func (*FileManager) PutMany

func (f *FileManager) PutMany(bs []*posinfo.FilestoreNode) error

type Filestore

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

func NewFilestore

func NewFilestore(bs blockstore.Blockstore, fm *FileManager) *Filestore

func (*Filestore) AllKeysChan

func (f *Filestore) AllKeysChan(ctx context.Context) (<-chan *cid.Cid, error)

func (*Filestore) DeleteBlock

func (f *Filestore) DeleteBlock(c *cid.Cid) error

func (*Filestore) Get

func (f *Filestore) Get(c *cid.Cid) (blocks.Block, error)

func (*Filestore) Has

func (f *Filestore) Has(c *cid.Cid) (bool, error)

func (*Filestore) Put

func (f *Filestore) Put(b blocks.Block) error

func (*Filestore) PutMany

func (f *Filestore) PutMany(bs []blocks.Block) error