blockledger

Documentation

Index

• func CreateNextBlock(rl Reader, messages []*cb.Envelope) *cb.Block
• func GetBlock(rl Reader, index uint64) *cb.Block
• type Factory
• type Iterator
• type NotFoundErrorIterator
  • func (nfei *NotFoundErrorIterator) Close()
  • func (nfei *NotFoundErrorIterator) Next() (*cb.Block, cb.Status)
  • func (nfei *NotFoundErrorIterator) ReadyChan() <-chan struct{}
• type ReadWriter
• type Reader
• type Writer

Functions

func CreateNextBlock

func CreateNextBlock(rl Reader, messages []*cb.Envelope) *cb.Block

适应非确定性编组

func GetBlock

func GetBlock(rl Reader, index uint64) *cb.Block

Types

type Factory

type Factory interface {
	//
	//
	GetOrCreate(chainID string) (ReadWriter, error)

	//chainIds返回工厂知道的链ID
	ChainIDs() []string

	//
	Close()
}

type Iterator

type Iterator interface {
	//
	//下一个块不再可检索
	Next() (*cb.Block, cb.Status)
	//
	Close()
}

迭代器对于链读取器在创建块时流式处理块很有用。

type NotFoundErrorIterator

type NotFoundErrorIterator struct{}

NotFoundErrorIterator只返回cb.status的错误“未找到”，

func (*NotFoundErrorIterator) Close

func (nfei *NotFoundErrorIterator) Close()

func (*NotFoundErrorIterator) Next

func (nfei *NotFoundErrorIterator) Next() (*cb.Block, cb.Status)

func (*NotFoundErrorIterator) ReadyChan

func (nfei *NotFoundErrorIterator) ReadyChan() <-chan struct{}

type ReadWriter

type ReadWriter interface {
	Reader
	Writer
}

type Reader

type Reader interface {
	//
	//
	Iterator(startType *ab.SeekPosition) (Iterator, uint64)
	//height返回分类帐上的块数
	Height() uint64
}

type Writer

type Writer interface {
	//将新块追加到分类帐
	Append(block *cb.Block) error
}