freelist

Documentation

Index

• Constants
• type FreeList
  • func OpenFreeList(path string) (*FreeList, error)
  • func (cp *FreeList) Close() error
  • func (cp *FreeList) Flush() (types.Work, error)
  • func (cp *FreeList) Iter() (*FreeListIter, error)
  • func (cp *FreeList) OutstandingWork() types.Work
  • func (cp *FreeList) Put(blk types.Block) error
  • func (cp *FreeList) Sync() error
• type FreeListIter
  • func NewFreeListIter(reader *os.File) *FreeListIter
  • func (cpi *FreeListIter) Next() (*types.Block, error)

Constants

const CIDSizePrefix = 4

Types

type FreeList

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

A primary storage that is CID aware.

func OpenFreeList

func OpenFreeList(path string) (*FreeList, error)

func (*FreeList) Close

func (cp *FreeList) Close() error

Close calls Flush to write work and data to the freelist file, and then closes the file.

func (*FreeList) Flush

func (cp *FreeList) Flush() (types.Work, error)

Flush writes outstanding work and buffered data to the freelist file.

func (*FreeList) Iter

func (cp *FreeList) Iter() (*FreeListIter, error)

func (*FreeList) OutstandingWork

func (cp *FreeList) OutstandingWork() types.Work

func (*FreeList) Put

func (cp *FreeList) Put(blk types.Block) error

func (*FreeList) Sync

func (cp *FreeList) Sync() error

Sync commits the contents of the freelist file to disk. Flush should be called before calling Sync.

type FreeListIter

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

func NewFreeListIter

func NewFreeListIter(reader *os.File) *FreeListIter

func (*FreeListIter) Next

func (cpi *FreeListIter) Next() (*types.Block, error)