cidprimary

Documentation

Index

• Constants
• type CIDPrimary
  • func OpenCIDPrimary(path string) (*CIDPrimary, error)
  • func (cp *CIDPrimary) Close() error
  • func (cp *CIDPrimary) Flush() (types.Work, error)
  • func (cp *CIDPrimary) Get(blk types.Block) (key []byte, value []byte, err error)
  • func (cp *CIDPrimary) GetIndexKey(blk types.Block) ([]byte, error)
  • func (cp *CIDPrimary) IndexKey(key []byte) ([]byte, error)
  • func (cp *CIDPrimary) Iter() (primary.PrimaryStorageIter, error)
  • func (cp *CIDPrimary) OutstandingWork() types.Work
  • func (cp *CIDPrimary) Put(key []byte, value []byte) (types.Block, error)
  • func (cp *CIDPrimary) Sync() error
• type CIDPrimaryIter
  • func NewCIDPrimaryIter(reader *os.File) *CIDPrimaryIter
  • func (cpi *CIDPrimaryIter) Next() ([]byte, []byte, error)

Constants

const CIDSizePrefix = 4

Types

type CIDPrimary

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

A primary storage that is CID aware.

func OpenCIDPrimary

func OpenCIDPrimary(path string) (*CIDPrimary, error)

func (*CIDPrimary) Close

func (cp *CIDPrimary) Close() error

func (*CIDPrimary) Flush

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

func (*CIDPrimary) Get

func (cp *CIDPrimary) Get(blk types.Block) (key []byte, value []byte, err error)

func (*CIDPrimary) GetIndexKey

func (cp *CIDPrimary) GetIndexKey(blk types.Block) ([]byte, error)

func (*CIDPrimary) IndexKey

func (cp *CIDPrimary) IndexKey(key []byte) ([]byte, error)

func (*CIDPrimary) Iter

func (cp *CIDPrimary) Iter() (primary.PrimaryStorageIter, error)

func (*CIDPrimary) OutstandingWork

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

func (*CIDPrimary) Put

func (cp *CIDPrimary) Put(key []byte, value []byte) (types.Block, error)

func (*CIDPrimary) Sync

func (cp *CIDPrimary) Sync() error

type CIDPrimaryIter

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

func NewCIDPrimaryIter

func NewCIDPrimaryIter(reader *os.File) *CIDPrimaryIter

func (*CIDPrimaryIter) Next

func (cpi *CIDPrimaryIter) Next() ([]byte, []byte, error)