block

Documentation

Index

• Constants
• Variables
• func GetBlockHeaderHashByHeight(dbase db.Database, c codec.Codec, height int64) ([]byte, error)
• func GetBlockVersion(dbase db.Database, c codec.Codec, height int64) (int, error)
• func GetCommitVoteListBytesByHeight(dbase db.Database, c codec.Codec, height int64) ([]byte, error)
• func GetLastHeight(dbase db.Database) (int64, error)
• func GetLastHeightOf(dbase db.Database) int64
• func GetLastHeightWithCodec(dbase db.Database, c codec.Codec) (int64, error)
• func NewBlockV2Handler(chain base.Chain) base.BlockHandler
• func NewManager(chain module.Chain, timestamper module.Timestamper, ...) (module.BlockManager, error)
• func PeekVersion(r io.Reader) (int, io.Reader, error)
• func ReadVersion(r io.Reader) (int, error)
• func ResetDB(d db.Database, c codec.Codec, height int64) error
• func WriteTransactionLocators(dbase db.Database, height int64, ptl module.TransactionList, ...) error
• type Chain
• type RefCounter
• type RefTracer
  • func (rt *RefTracer) TraceDispose(rc RefCounter)
  • func (rt *RefTracer) TraceNew(rc RefCounter)
  • func (rt *RefTracer) TraceRef(rc RefCounter)
  • func (rt *RefTracer) TraceUnref(rc RefCounter)
• type ServiceManager

Constants

const (
	ResultNotFinalizedError = errors.CodeBlock + iota
)

Variables

var (
	ErrResultNotFinalized = errors.NewBase(ResultNotFinalizedError, "ResultNotFinalized")
)

Functions

func GetBlockHeaderHashByHeight

func GetBlockHeaderHashByHeight(
	dbase db.Database,
	c codec.Codec,
	height int64,
) ([]byte, error)

func GetBlockVersion

func GetBlockVersion(
	dbase db.Database,
	c codec.Codec,
	height int64,
) (int, error)

func GetCommitVoteListBytesByHeight

func GetCommitVoteListBytesByHeight(
	dbase db.Database,
	c codec.Codec,
	height int64,
) ([]byte, error)

func GetLastHeight

func GetLastHeight(dbase db.Database) (int64, error)

func GetLastHeightOf

func GetLastHeightOf(dbase db.Database) int64

func GetLastHeightWithCodec

func GetLastHeightWithCodec(dbase db.Database, c codec.Codec) (int64, error)

func NewBlockV2Handler

func NewBlockV2Handler(chain base.Chain) base.BlockHandler

func NewManager

func NewManager(
	chain module.Chain,
	timestamper module.Timestamper,
	handlers []base.BlockHandler,
) (module.BlockManager, error)

NewManager creates BlockManager.

func PeekVersion

func PeekVersion(r io.Reader) (int, io.Reader, error)

func ReadVersion

func ReadVersion(r io.Reader) (int, error)

func ResetDB

func ResetDB(d db.Database, c codec.Codec, height int64) error

func WriteTransactionLocators

func WriteTransactionLocators(
	dbase db.Database,
	height int64,
	ptl module.TransactionList,
	ntl module.TransactionList,
) error

Types

type Chain

type Chain interface {
	Database() db.Database
	Wallet() module.Wallet
	ServiceManager() module.ServiceManager
	NID() int
	CID() int
	GenesisStorage() module.GenesisStorage
	CommitVoteSetDecoder() module.CommitVoteSetDecoder
	Genesis() []byte
}

type RefCounter

type RefCounter interface {
	RefCount() int
}

type RefTracer

type RefTracer struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

func (*RefTracer) TraceDispose

func (rt *RefTracer) TraceDispose(rc RefCounter)

func (*RefTracer) TraceNew

func (rt *RefTracer) TraceNew(rc RefCounter)

func (*RefTracer) TraceRef

func (rt *RefTracer) TraceRef(rc RefCounter)

func (*RefTracer) TraceUnref

func (rt *RefTracer) TraceUnref(rc RefCounter)

type ServiceManager

type ServiceManager interface {
	module.TransitionManager
	TransactionFromBytes(b []byte, blockVersion int) (module.Transaction, error)
	GetChainID(result []byte) (int64, error)
	GetNetworkID(result []byte) (int64, error)
	GetNextBlockVersion(result []byte) int
	ImportResult(result []byte, vh []byte, src db.Database) error
	GenesisTransactionFromBytes(b []byte, blockVersion int) (module.Transaction, error)
	TransactionListFromHash(hash []byte) module.TransactionList
	ReceiptListFromResult(result []byte, g module.TransactionGroup) (module.ReceiptList, error)
	SendTransaction(result []byte, tx interface{}) ([]byte, error)
	ValidatorListFromHash(hash []byte) module.ValidatorList
	TransactionListFromSlice(txs []module.Transaction, version int) module.TransactionList
	SendTransactionAndWait(result []byte, tx interface{}) ([]byte, <-chan interface{}, error)
	WaitTransactionResult(id []byte) (<-chan interface{}, error)
	ExportResult(result []byte, vh []byte, dst db.Database) error
}