gndlbs

README

Gonudb-lbs

Gonudb-lbs is a Lotus blockstore implementation using Gonudb, an append-only key/value datastore written in Go.

Author

Written by:

• Ian Davis - http://iandavis.com/

License

This is free and unencumbered software released into the public domain. Anyone is free to copy, modify, publish, use, compile, sell, or distribute this software, either in source code form or as a compiled binary, for any purpose, commercial or non-commercial, and by any means. For more information, see http://unlicense.org/ or the accompanying UNLICENSE file.

Documentation

Index

• Constants
• Variables
• type BlockCache
  • func NewBlockCache(bs *Blockstore) *BlockCache
  • func (bc *BlockCache) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (bc *BlockCache) Close() error
  • func (bc *BlockCache) DeleteBlock(cid cid.Cid) error
  • func (bc *BlockCache) Get(c cid.Cid) (blocks.Block, error)
  • func (bc *BlockCache) GetSize(c cid.Cid) (int, error)
  • func (bc *BlockCache) Has(c cid.Cid) (bool, error)
  • func (bc *BlockCache) HashOnRead(_ bool)
  • func (bc *BlockCache) Put(block blocks.Block) error
  • func (bc *BlockCache) PutMany(blocks []blocks.Block) error
  • func (bc *BlockCache) SetUpstream(upstream blockstore.Blockstore)
• type Blockstore
  • func Open(directory string, name string, opts *gonudb.StoreOptions) (*Blockstore, error)
  • func (b *Blockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (b *Blockstore) Close() error
  • func (b *Blockstore) DeleteBlock(cid cid.Cid) error
  • func (b *Blockstore) Get(cid cid.Cid) (blocks.Block, error)
  • func (b *Blockstore) GetSize(cid cid.Cid) (int, error)
  • func (b *Blockstore) Has(cid cid.Cid) (bool, error)
  • func (b *Blockstore) HashOnRead(_ bool)
  • func (b *Blockstore) Put(block blocks.Block) error
  • func (b *Blockstore) PutMany(blocks []blocks.Block) error
• type Options

Constants

const (
	BlockSize  = 4096 // should align with ssd block size
	LoadFactor = 0.5  // target occupancy of buckets
)

Variables

var BlocksBucket = []byte("blocks")

Types

type BlockCache

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

func NewBlockCache

func NewBlockCache(bs *Blockstore) *BlockCache

func (*BlockCache) AllKeysChan

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

func (*BlockCache) Close

func (bc *BlockCache) Close() error

func (*BlockCache) DeleteBlock

func (bc *BlockCache) DeleteBlock(cid cid.Cid) error

func (*BlockCache) Get

func (bc *BlockCache) Get(c cid.Cid) (blocks.Block, error)

func (*BlockCache) GetSize

func (bc *BlockCache) GetSize(c cid.Cid) (int, error)

func (*BlockCache) Has

func (bc *BlockCache) Has(c cid.Cid) (bool, error)

func (*BlockCache) HashOnRead

func (bc *BlockCache) HashOnRead(_ bool)

func (*BlockCache) Put

func (bc *BlockCache) Put(block blocks.Block) error

func (*BlockCache) PutMany

func (bc *BlockCache) PutMany(blocks []blocks.Block) error

func (*BlockCache) SetUpstream

func (bc *BlockCache) SetUpstream(upstream blockstore.Blockstore)

type Blockstore

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

func Open

func Open(directory string, name string, opts *gonudb.StoreOptions) (*Blockstore, error)

func (*Blockstore) AllKeysChan

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

func (*Blockstore) Close

func (b *Blockstore) Close() error

func (*Blockstore) DeleteBlock

func (b *Blockstore) DeleteBlock(cid cid.Cid) error

func (*Blockstore) Get

func (b *Blockstore) Get(cid cid.Cid) (blocks.Block, error)

func (*Blockstore) GetSize

func (b *Blockstore) GetSize(cid cid.Cid) (int, error)

func (*Blockstore) Has

func (b *Blockstore) Has(cid cid.Cid) (bool, error)

func (*Blockstore) HashOnRead

func (b *Blockstore) HashOnRead(_ bool)

func (*Blockstore) Put

func (b *Blockstore) Put(block blocks.Block) error

func (*Blockstore) PutMany

func (b *Blockstore) PutMany(blocks []blocks.Block) error

type Options

type Options = gonudb.StoreOptions