mhprimary

Documentation

Index

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

Constants

const SizePrefix = 4

Types

type MultihashPrimary

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

A primary storage that is multihash aware.

func OpenMultihashPrimary

func OpenMultihashPrimary(path string) (*MultihashPrimary, error)

func (*MultihashPrimary) Close

func (cp *MultihashPrimary) Close() error

func (*MultihashPrimary) Flush

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

func (*MultihashPrimary) Get

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

func (*MultihashPrimary) GetIndexKey

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

func (*MultihashPrimary) IndexKey

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

func (*MultihashPrimary) Iter

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

func (*MultihashPrimary) OutstandingWork

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

func (*MultihashPrimary) Put

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

func (*MultihashPrimary) Sync

func (cp *MultihashPrimary) Sync() error

type MultihashPrimaryIter

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

func NewMultihashPrimaryIter

func NewMultihashPrimaryIter(reader *os.File) *MultihashPrimaryIter

func (*MultihashPrimaryIter) Next

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