vdb

Documentation

Index

• func CreateVFS(block *im.GenBlock, ind *core.IpfsNode, idxSer AIndexes.IndexesServices) (cid.Cid, error)
• func NewCacheCVFS(rdonlyCVFS CVFS) (*aCacheCVFS, error)
• type CVFS
  • func LinkVFS(chainId string, ind *core.IpfsNode, idxSer AIndexes.IndexesServices) (CVFS, error)
• type CacheCVFS
• type TransactionContext
  • func WithCancel(ctx context.Context) *TransactionContext
  • func (ttxc *TransactionContext) CancelWithErr(err error)
  • func (ttxc *TransactionContext) HasError() error

Functions

func CreateVFS

func CreateVFS(block *im.GenBlock, ind *core.IpfsNode, idxSer AIndexes.IndexesServices) (cid.Cid, error)

func NewCacheCVFS

func NewCacheCVFS(rdonlyCVFS CVFS) (*aCacheCVFS, error)

Types

type CVFS

type CVFS interface {
	Indexes() AIndexes.IndexesServices

	Nodes() ANodes.Services

	Blocks() ABlock.Services

	Assetses() AAssets.Services

	Receipts() AReceipts.Services

	Transactions() ATx.Services

	ForkMergeBatch(merger VDBMerge.CVFSMerger) (cid.Cid, error)

	NewCVFSWriter() (CacheCVFS, error)
}

func LinkVFS

func LinkVFS(chainId string, ind *core.IpfsNode, idxSer AIndexes.IndexesServices) (CVFS, error)

type CacheCVFS

type CacheCVFS interface {
	Close() error

	BestCID() cid.Cid

	Blocks() ABlock.MergeWriter

	Nodes() ANodes.MergeWriter

	Assetses() AAssetses.MergeWriter

	Receipts() AReceipts.MergeWriter

	Transactions() ATx.MergeWriter

	MergeGroup() merger.CVFSMerger
}

type TransactionContext

type TransactionContext struct {
	context.Context
	// contains filtered or unexported fields
}

func WithCancel

func WithCancel(ctx context.Context) *TransactionContext

func (*TransactionContext) CancelWithErr

func (ttxc *TransactionContext) CancelWithErr(err error)

func (*TransactionContext) HasError

func (ttxc *TransactionContext) HasError() error