ribsbstore

Documentation

Index

• Variables
• type Blockstore
  • func New(ctx context.Context, r ribs.RIBS) *Blockstore
  • func (b *Blockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (b *Blockstore) Close() error
  • func (b *Blockstore) DeleteBlock(ctx context.Context, c cid.Cid) error
  • func (b *Blockstore) Flush(ctx context.Context) error
  • func (b *Blockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)
  • func (b *Blockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)
  • func (b *Blockstore) Has(ctx context.Context, c cid.Cid) (bool, error)
  • func (b *Blockstore) HashOnRead(bool)
  • func (b *Blockstore) Put(ctx context.Context, block blocks.Block) error
  • func (b *Blockstore) PutMany(ctx context.Context, blk []blocks.Block) error
• type Request
  • func MakeRequest[P, R any](param P) Request[P, R]

Variables

var (
	BlockstoreMaxQueuedBlocks    = 640
	BlockstoreMaxUnflushedBlocks = 10240
)

Types

type Blockstore

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

func New

func New(ctx context.Context, r ribs.RIBS) *Blockstore

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(ctx context.Context, c cid.Cid) error

func (*Blockstore) Flush

func (b *Blockstore) Flush(ctx context.Context) error

func (*Blockstore) Get

func (b *Blockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)

func (*Blockstore) GetSize

func (b *Blockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

func (*Blockstore) Has

func (b *Blockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

func (*Blockstore) HashOnRead

func (b *Blockstore) HashOnRead(bool)

func (*Blockstore) Put

func (b *Blockstore) Put(ctx context.Context, block blocks.Block) error

func (*Blockstore) PutMany

func (b *Blockstore) PutMany(ctx context.Context, blk []blocks.Block) error

type Request

type Request[P, R any] struct {
	Param P
	Resp  chan R
}

func MakeRequest

func MakeRequest[P, R any](param P) Request[P, R]