bcm

package
v0.25.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 9, 2019 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBcm = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBcm   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type Block added in v0.24.0 

type Block struct {
	*types.Block
	// contains filtered or unexported fields
}

func NewBlock added in v0.24.0 

func NewBlock(txDecoder txs.Decoder, block *types.Block) *Block

func (*Block) Transactions added in v0.24.0 

func (b *Block) Transactions(iter func(*txs.Envelope) (stop bool)) (stopped bool, err error)

type BlockStore added in v0.24.0 

type BlockStore struct {
	state.BlockStoreRPC
	// contains filtered or unexported fields
}

func NewBlockExplorer added in v0.24.0 

func NewBlockExplorer(dbBackendType db.DBBackendType, dbDir string) *BlockStore

func NewBlockStore added in v0.24.0 

func NewBlockStore(blockStore state.BlockStoreRPC) *BlockStore

func (*BlockStore) Block added in v0.24.0 

func (bs *BlockStore) Block(height int64) (_ *Block, err error)

func (*BlockStore) BlockMeta added in v0.24.0 

func (bs *BlockStore) BlockMeta(height int64) (_ *types.BlockMeta, err error)

func (*BlockStore) Blocks added in v0.24.0 

func (bs *BlockStore) Blocks(start, end int64, iter func(*Block) (stop bool)) (stopped bool, err error)

Iterate over blocks between start (inclusive) and end (exclusive)

type Blockchain 

type Blockchain struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func DecodeBlockchain 

func DecodeBlockchain(encodedState []byte) (*Blockchain, error)

func LoadOrNewBlockchain 

func LoadOrNewBlockchain(db dbm.DB, genesisDoc *genesis.GenesisDoc, logger *logging.Logger) (bool, *Blockchain, error)

func NewBlockchain added in v0.23.3 

func NewBlockchain(db dbm.DB, genesisDoc *genesis.GenesisDoc) *Blockchain

Pointer to blockchain state initialised from genesis

func (*Blockchain) AppHashAfterLastBlock 

func (bc *Blockchain) AppHashAfterLastBlock() []byte

func (*Blockchain) BlockHash added in v0.24.0 

func (bc *Blockchain) BlockHash(height uint64) []byte

func (*Blockchain) ChainID 

func (bc *Blockchain) ChainID() string

func (*Blockchain) CommitBlock 

func (bc *Blockchain) CommitBlock(blockTime time.Time, blockHash, appHash []byte) error

func (*Blockchain) CommitBlockAtHeight added in v0.23.3 

func (bc *Blockchain) CommitBlockAtHeight(blockTime time.Time, blockHash, appHash []byte, height uint64) error

func (*Blockchain) CommitWithAppHash added in v0.25.0 

func (bc *Blockchain) CommitWithAppHash(appHash []byte) error

func (*Blockchain) Encode 

func (bc *Blockchain) Encode() ([]byte, error)

func (*Blockchain) GenesisDoc 

func (bc *Blockchain) GenesisDoc() genesis.GenesisDoc

func (*Blockchain) GenesisHash 

func (bc *Blockchain) GenesisHash() []byte

func (*Blockchain) GetBlockHeader added in v0.24.0 

func (bc *Blockchain) GetBlockHeader(height uint64) (*types.Header, error)

func (*Blockchain) LastBlockHash 

func (bc *Blockchain) LastBlockHash() []byte

func (*Blockchain) LastBlockHeight 

func (bc *Blockchain) LastBlockHeight() uint64

func (*Blockchain) LastBlockTime 

func (bc *Blockchain) LastBlockTime() time.Time

func (*Blockchain) LastCommitDuration added in v0.24.5 

func (bc *Blockchain) LastCommitDuration() time.Duration

func (*Blockchain) LastCommitTime added in v0.20.1 

func (bc *Blockchain) LastCommitTime() time.Time

func (*Blockchain) SetBlockStore added in v0.24.0 

func (bc *Blockchain) SetBlockStore(bs *BlockStore)

type BlockchainInfo 

type BlockchainInfo interface {
	GenesisHash() []byte
	GenesisDoc() genesis.GenesisDoc
	ChainID() string
	LastBlockHeight() uint64
	LastBlockTime() time.Time
	LastCommitTime() time.Time
	LastCommitDuration() time.Duration
	LastBlockHash() []byte
	AppHashAfterLastBlock() []byte
	// Gets the BlockHash at a height (or nil if no BlockStore mounted or block could not be found)
	BlockHash(height uint64) []byte
	// GetBlockHash returns	hash of the specific block
	GetBlockHeader(blockNumber uint64) (*types.Header, error)
}

type PersistedState 

type PersistedState struct {
	AppHashAfterLastBlock []byte
	LastBlockHeight       uint64
	GenesisDoc            genesis.GenesisDoc
}

type SyncInfo added in v0.24.3 

type SyncInfo struct {
	LatestBlockHeight uint64                                        `protobuf:"varint,1,opt,name=LatestBlockHeight,proto3" json:""`
	LatestBlockHash   github_com_hyperledger_burrow_binary.HexBytes `` /* 130-byte string literal not displayed */
	LatestAppHash     github_com_hyperledger_burrow_binary.HexBytes `` /* 126-byte string literal not displayed */
	// Timestamp of block as set by the block proposer
	LatestBlockTime time.Time `protobuf:"bytes,4,opt,name=LatestBlockTime,proto3,stdtime" json:"LatestBlockTime"`
	// Time at which we committed the last block
	LatestBlockSeenTime time.Time `protobuf:"bytes,5,opt,name=LatestBlockSeenTime,proto3,stdtime" json:"LatestBlockSeenTime"`
	// Time elapsed since last commit
	LatestBlockDuration  time.Duration `protobuf:"bytes,6,opt,name=LatestBlockDuration,proto3,stdduration" json:"LatestBlockDuration"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func GetSyncInfo added in v0.24.3 

func GetSyncInfo(blockchain BlockchainInfo) *SyncInfo

func (*SyncInfo) Descriptor added in v0.24.3 

func (*SyncInfo) Descriptor() ([]byte, []int)

func (*SyncInfo) GetLatestBlockDuration added in v0.24.5 

func (m *SyncInfo) GetLatestBlockDuration() time.Duration

func (*SyncInfo) GetLatestBlockHeight added in v0.24.3 

func (m *SyncInfo) GetLatestBlockHeight() uint64

func (*SyncInfo) GetLatestBlockSeenTime added in v0.24.3 

func (m *SyncInfo) GetLatestBlockSeenTime() time.Time

func (*SyncInfo) GetLatestBlockTime added in v0.24.3 

func (m *SyncInfo) GetLatestBlockTime() time.Time

func (*SyncInfo) Marshal added in v0.24.3 

func (m *SyncInfo) Marshal() (dAtA []byte, err error)

func (*SyncInfo) MarshalTo added in v0.24.3 

func (m *SyncInfo) MarshalTo(dAtA []byte) (int, error)

func (*SyncInfo) ProtoMessage added in v0.24.3 

func (*SyncInfo) ProtoMessage()

func (*SyncInfo) Reset added in v0.24.3 

func (m *SyncInfo) Reset()

func (*SyncInfo) Size added in v0.24.3 

func (m *SyncInfo) Size() (n int)

func (*SyncInfo) String added in v0.24.3 

func (m *SyncInfo) String() string

func (*SyncInfo) Unmarshal added in v0.24.3 

func (m *SyncInfo) Unmarshal(dAtA []byte) error

func (*SyncInfo) XXX_DiscardUnknown added in v0.24.3 

func (m *SyncInfo) XXX_DiscardUnknown()

func (*SyncInfo) XXX_Marshal added in v0.24.3 

func (m *SyncInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncInfo) XXX_Merge added in v0.24.3 

func (m *SyncInfo) XXX_Merge(src proto.Message)

func (*SyncInfo) XXX_MessageName added in v0.24.3 

func (*SyncInfo) XXX_MessageName() string

func (*SyncInfo) XXX_Size added in v0.24.3 

func (m *SyncInfo) XXX_Size() int

func (*SyncInfo) XXX_Unmarshal added in v0.24.3 

func (m *SyncInfo) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.