blockchain

package

Go to main page

Versions in this module

v0

v0.4.3

May 9, 2020

v0.4.2

Mar 5, 2020

v0.4.1

Jan 8, 2020

v0.4.0

Dec 11, 2019

Changes in this version

+ const HashSize

+ const MaxBlockBaseSize

+ const MaxBlockSigOpsCost

+ const MaxBlockWeight

+ const MaxOutputsPerBlock

+ const MinTxOutputWeight

+ const WitnessScaleFactor

+ func DBRemoveBlockIndex(dbTx database.Tx, hash *common.Uint256, height uint32) error

+ func DBRemoveBlockNode(dbTx database.Tx, header *types.Header) error

+ func DBStoreBlockNode(dbTx database.Tx, header *types.Header, status blockStatus) error

+ func DeserializeBlockRow(blockRow []byte) (*types.Header, blockStatus, error)

+ func GetBlockWeight(blk *types.Block) int64

+ func GetTransactionWeight(tx *types.Transaction) int64

+ func LoadBlockDB(dataPath string) (database.DB, error)

+ type BestState struct

+ Bits uint32

+ BlockSize uint64

+ BlockWeight uint64

+ Hash common.Uint256

+ Height uint32

+ MedianTime time.Time

+ NumTxns uint64

type BlockChain

+ Nodes []*BlockNode

+ UTXOCache *UTXOCache

+ func (b *BlockChain) GetBlockHash(height uint32) (Uint256, error)

+ func (b *BlockChain) GetBlockNode(height uint32) *BlockNode

+ func (b *BlockChain) GetCRCommittee() *crstate.Committee

+ func (b *BlockChain) GetCurrentBlockHash() Uint256

+ func (b *BlockChain) InitCheckpoint(interrupt <-chan struct{}, barStart func(total uint32), increase func()) (err error)

+ func (b *BlockChain) InitFFLDBFromChainStore(interrupt <-chan struct{}, barStart func(total uint32), increase func(), ...) (err error)

+ func (b *BlockChain) SetTip(node *BlockNode)

type BlockNode

+ Status blockStatus

type ChainStore

+ func (c *ChainStore) GetFFLDB() IFFLDBChainStore

+ func (c *ChainStore) SetHeight(height uint32)

+ type ChainStoreFFLDB struct

+ func (c *ChainStoreFFLDB) Begin(writable bool) (database.Tx, error)

+ func (c *ChainStoreFFLDB) BlockExists(hash *Uint256) (bool, uint32, error)

+ func (c *ChainStoreFFLDB) Close() error

+ func (c *ChainStoreFFLDB) GetBlock(hash Uint256) (*Block, error)

+ func (c *ChainStoreFFLDB) GetHeader(hash Uint256) (*Header, error)

+ func (c *ChainStoreFFLDB) IsBlockInStore(hash *Uint256) bool

+ func (c *ChainStoreFFLDB) RollbackBlock(b *Block, node *BlockNode, confirm *payload.Confirm, medianTimePast time.Time) error

+ func (c *ChainStoreFFLDB) SaveBlock(b *Block, node *BlockNode, confirm *payload.Confirm, medianTimePast time.Time) error

+ func (c *ChainStoreFFLDB) Type() string

+ func (c *ChainStoreFFLDB) Update(fn func(tx database.Tx) error) error

+ func (c *ChainStoreFFLDB) View(fn func(tx database.Tx) error) error

type IChainStore

+ GetFFLDB func() IFFLDBChainStore

+ SetHeight func(height uint32)

+ type IFFLDBChainStore interface

+ BlockExists func(hash *Uint256) (bool, uint32, error)

+ GetBlock func(hash Uint256) (*Block, error)

+ GetHeader func(hash Uint256) (*Header, error)

+ IsBlockInStore func(hash *Uint256) bool

+ RollbackBlock func(b *Block, node *BlockNode, confirm *payload.Confirm, medianTimePast time.Time) error

+ SaveBlock func(b *Block, node *BlockNode, confirm *payload.Confirm, medianTimePast time.Time) error

+ func NewChainStoreFFLDB(dataDir string) (IFFLDBChainStore, error)

type Ledger

+ Committee *crstate.Committee

type MedianTimeSource

+ Reset func()

+ type UTXOCache struct

+ func NewUTXOCache(db IChainStore) *UTXOCache

+ func (up *UTXOCache) CleanCache()

+ func (up *UTXOCache) CleanTxCache()

+ func (up *UTXOCache) GetTransaction(txID common.Uint256) (*types.Transaction, error)

+ func (up *UTXOCache) GetTxReference(tx *types.Transaction) (map[*types.Input]*types.Output, error)

v0.3.9

Nov 21, 2019

v0.3.8

Oct 23, 2019

v0.3.7

Aug 17, 2019

v0.3.6

Aug 8, 2019

v0.3.5

Aug 1, 2019

v0.3.4

Jul 20, 2019

Changes in this version

type BlockChain

+ func (b *BlockChain) CheckBlockContext(block *Block, prevNode *BlockNode) error

+ func (b *BlockChain) GetNetworkHashPS() *big.Int

v0.3.3

Jun 14, 2019

Changes in this version

+ const BlocksCacheSize

+ func CalculateTxsFee(block *Block)

v0.3.2

Jun 2, 2019

Changes in this version

+ func PreProcessSpecialTx(block *Block) error

+ func ProposalCheck(proposal *payload.DPOSProposal) error

+ func ProposalCheckByHeight(proposal *payload.DPOSProposal, height uint32) error

+ func ProposalContextCheckByHeight(proposal *payload.DPOSProposal, height uint32) error

+ func VoteCheck(vote *payload.DPOSProposalVote) error

+ func VoteCheckByHeight(vote *payload.DPOSProposalVote, height uint32) error

+ func VoteContextCheckByHeight(vote *payload.DPOSProposalVote, height uint32) error

type BlockChain

+ func (b *BlockChain) GetOrphan(hash *Uint256) *OrphanBlock

+ func (b *BlockChain) InitProducerState(interrupt <-chan struct{}, start func(total uint32), increase func()) (err error)

+ func (b *BlockChain) ProcessInactiveArbiter(payload *payload.InactiveArbitrators)

v0.3.2-e935

Jun 10, 2019

v0.3.1

Apr 12, 2019

v0.3.0

Mar 28, 2019

Changes in this version

+ const InactiveRecoveringHeightLimit

+ func CheckDPOSIllegalBlocks(d *payload.DPOSIllegalBlocks) error

+ func CheckDPOSIllegalProposals(d *payload.DPOSIllegalProposals) error

+ func CheckDPOSIllegalVotes(d *payload.DPOSIllegalVotes) error

+ func CheckInactiveArbitrators(txn *Transaction, inactiveArbitratorsCount uint32) error

+ func CheckSidechainIllegalEvidence(p *payload.SidechainIllegalData) error

+ func ConfirmContextCheck(confirm *payload.Confirm) error

+ func ConfirmSanityCheck(confirm *payload.Confirm) error

+ func ProposalContextCheck(proposal *payload.DPOSProposal) error

+ func ProposalSanityCheck(proposal *payload.DPOSProposal) error

+ func VoteContextCheck(vote *payload.DPOSProposalVote) error

+ func VoteSanityCheck(vote *payload.DPOSProposalVote) error

+ type BlockChain struct

+ BestChain *BlockNode

+ DepNodes map[Uint256][]*BlockNode

+ GenesisHash Uint256

+ Index map[Uint256]*BlockNode

+ IndexLock sync.RWMutex

+ MedianTimePast time.Time

+ Root *BlockNode

+ TimeSource MedianTimeSource

+ func New(db IChainStore, chainParams *config.Params, state *state.State) (*BlockChain, error)

+ func (b *BlockChain) AddNodeToIndex(node *BlockNode)

+ func (b *BlockChain) AddOrphanBlock(block *Block)

+ func (b *BlockChain) AddOrphanConfirm(confirm *payload.Confirm)

+ func (b *BlockChain) BlockExists(hash *Uint256) bool

+ func (b *BlockChain) BlockLocatorFromHash(inhash *Uint256) []*Uint256

+ func (b *BlockChain) CalcCurrentDifficulty(currentBits uint32) string

+ func (b *BlockChain) CalcNextRequiredDifficulty(prevNode *BlockNode, newBlockTime time.Time) (uint32, error)

+ func (b *BlockChain) CheckBlockSanity(block *Block) error

+ func (b *BlockChain) CheckTransactionContext(blockHeight uint32, txn *Transaction) ErrCode

+ func (b *BlockChain) CheckTransactionSanity(blockHeight uint32, txn *Transaction) ErrCode

+ func (b *BlockChain) ContainsTransaction(hash Uint256) bool

+ func (b *BlockChain) CurrentBlockHash() Uint256

+ func (b *BlockChain) GetBlockByHash(hash Uint256) (*Block, error)

+ func (b *BlockChain) GetDposBlockByHash(hash Uint256) (*DposBlock, error)

+ func (b *BlockChain) GetHeader(hash Uint256) (*Header, error)

+ func (b *BlockChain) GetHeight() uint32

+ func (b *BlockChain) GetOrphanConfirm(hash *Uint256) (*payload.Confirm, bool)

+ func (b *BlockChain) GetOrphanRoot(hash *Uint256) *Uint256

+ func (b *BlockChain) GetState() *state.State

+ func (b *BlockChain) HaveBlock(hash *Uint256) (bool, error)

+ func (b *BlockChain) InitializeProducersState(interrupt <-chan struct{}, start func(total uint32), increase func()) (err error)

+ func (b *BlockChain) IsKnownOrphan(hash *Uint256) bool

+ func (b *BlockChain) LatestBlockLocator() ([]*Uint256, error)

+ func (b *BlockChain) LoadBlockNode(blockHeader *Header, hash *Uint256) (*BlockNode, error)

+ func (b *BlockChain) LocateBlocks(locator []*Uint256, hashStop *Uint256, maxHashes uint32) []*Uint256

+ func (b *BlockChain) LookupNodeInIndex(hash *Uint256) (*BlockNode, bool)

+ func (b *BlockChain) MedianAdjustedTime() time.Time

+ func (b *BlockChain) ProcessBlock(block *Block, confirm *payload.Confirm) (bool, bool, error)

+ func (b *BlockChain) ProcessIllegalBlock(payload *payload.DPOSIllegalBlocks)

+ func (b *BlockChain) ProcessOrphans(hash *Uint256) error

+ func (b *BlockChain) RemoveNodeFromIndex(node *BlockNode)

+ func (b *BlockChain) RemoveOrphanBlock(orphan *OrphanBlock)

+ func (b *BlockChain) ReorganizeChain(block *Block) error

v0.2.2

Feb 19, 2019

Changes in this version

+ const DepositLockupBlocks

+ const MaxStringLength

+ const MinDepositAmount

+ const ProducerConfirmations

+ func CheckBlockWithConfirmation(block *Block, confirm *DPosProposalVoteSlot) error

+ func CheckCancelProducerTransaction(txn *Transaction) error

+ func CheckConfirm(confirm *DPosProposalVoteSlot) error

+ func CheckDposIllegalBlocks(d *DposIllegalBlocks) error

+ func CheckIllegalBlocksTransaction(txn *Transaction) error

+ func CheckIllegalProposalsTransaction(txn *Transaction) error

+ func CheckIllegalVotesTransaction(txn *Transaction) error

+ func CheckRegisterProducerTransaction(txn *Transaction) error

+ func CheckReturnDepositCoinTransaction(txn *Transaction) error

+ func CheckTransactionDepositUTXO(txn *Transaction, references map[*Input]*Output) error

+ func CheckUpdateProducerTransaction(txn *Transaction) error

+ func IsProposalValid(proposal *DPosProposal) bool

+ func IsVoteValid(vote *DPosProposalVote) bool

type Blockchain

+ NewBlocksListeners []interfaces.NewBlocksListener

+ func (b *Blockchain) AddConfirm(confirm *DPosProposalVoteSlot) error

+ func (b *Blockchain) GetBlock(hash Uint256) (*Block, error)

+ func (b *Blockchain) ProcessConfirm(confirm *DPosProposalVoteSlot) error

type ChainStore

+ func (c *ChainStore) GetActiveRegisteredProducers() []*PayloadRegisterProducer

+ func (c *ChainStore) GetCancelProducerHeight(publicKey []byte) (uint32, error)

+ func (c *ChainStore) GetConfirm(hash Uint256) (*DPosProposalVoteSlot, error)

+ func (c *ChainStore) GetIllegalProducers() map[string]struct{}

+ func (c *ChainStore) GetProducerStatus(publicKey string) ProducerState

+ func (c *ChainStore) GetProducerVote(publicKey []byte) Fixed64

+ func (c *ChainStore) GetRegisteredProducers() []*PayloadRegisterProducer

+ func (c *ChainStore) GetRegisteredProducersSorted() ([]*PayloadRegisterProducer, error)

+ func (c *ChainStore) InitProducerVotes() error

+ func (c *ChainStore) OnIllegalBlockTxnReceived(txn *Transaction)

+ func (c *ChainStore) PersistConfirm(confirm *DPosProposalVoteSlot) error

+ func (c *ChainStore) RollbackConfirm(b *Block) error

+ func (c *ChainStore) SaveConfirm(confirm *DPosProposalVoteSlot) error

+ type ChainStoreMock struct

+ BlockHeight uint32

+ CancelProducerHeight uint32

+ RegisterProducers []*payload.PayloadRegisterProducer

+ func (c *ChainStoreMock) Close()

+ func (c *ChainStoreMock) ContainsUnspent(txID common.Uint256, index uint16) (bool, error)

+ func (c *ChainStoreMock) GetActiveRegisteredProducers() []*payload.PayloadRegisterProducer

+ func (c *ChainStoreMock) GetAsset(hash common.Uint256) (*payload.Asset, error)

+ func (c *ChainStoreMock) GetAssets() map[common.Uint256]*payload.Asset

+ func (c *ChainStoreMock) GetBlock(hash common.Uint256) (*types.Block, error)

+ func (c *ChainStoreMock) GetBlockHash(height uint32) (common.Uint256, error)

+ func (c *ChainStoreMock) GetCancelProducerHeight(publicKey []byte) (uint32, error)

+ func (c *ChainStoreMock) GetConfirm(hash common.Uint256) (*types.DPosProposalVoteSlot, error)

+ func (c *ChainStoreMock) GetCurrentBlockHash() common.Uint256

+ func (c *ChainStoreMock) GetHeader(hash common.Uint256) (*types.Header, error)

+ func (c *ChainStoreMock) GetHeight() uint32

+ func (c *ChainStoreMock) GetIllegalProducers() map[string]struct{}

+ func (c *ChainStoreMock) GetProducerStatus(address string) ProducerState

+ func (c *ChainStoreMock) GetProducerVote(publicKey []byte) common.Fixed64

+ func (c *ChainStoreMock) GetRegisteredProducers() []*payload.PayloadRegisterProducer

+ func (c *ChainStoreMock) GetRegisteredProducersSorted() ([]*payload.PayloadRegisterProducer, error)

+ func (c *ChainStoreMock) GetSidechainTx(sidechainTxHash common.Uint256) (byte, error)

+ func (c *ChainStoreMock) GetTransaction(txID common.Uint256) (*types.Transaction, uint32, error)

+ func (c *ChainStoreMock) GetTxReference(tx *types.Transaction) (map[*types.Input]*types.Output, error)

+ func (c *ChainStoreMock) GetUnspent(txID common.Uint256, index uint16) (*types.Output, error)

+ func (c *ChainStoreMock) GetUnspentFromProgramHash(programHash common.Uint168, assetid common.Uint256) ([]*UTXO, error)

+ func (c *ChainStoreMock) GetUnspentsFromProgramHash(programHash common.Uint168) (map[common.Uint256][]*UTXO, error)

+ func (c *ChainStoreMock) InitProducerVotes() error

+ func (c *ChainStoreMock) InitWithGenesisBlock(genesisblock *types.Block) (uint32, error)

+ func (c *ChainStoreMock) IsBlockInStore(hash common.Uint256) bool

+ func (c *ChainStoreMock) IsDoubleSpend(tx *types.Transaction) bool

+ func (c *ChainStoreMock) IsSidechainTxHashDuplicate(sidechainTxHash common.Uint256) bool

+ func (c *ChainStoreMock) IsTxHashDuplicate(txhash common.Uint256) bool

+ func (c *ChainStoreMock) OnIllegalBlockTxnReceived(txn *types.Transaction)

+ func (c *ChainStoreMock) PersistAsset(assetid common.Uint256, asset payload.Asset) error

+ func (c *ChainStoreMock) PersistSidechainTx(sidechainTxHash common.Uint256)

+ func (c *ChainStoreMock) RollbackBlock(hash common.Uint256) error

+ func (c *ChainStoreMock) SaveBlock(b *types.Block) error

+ func (c *ChainStoreMock) SaveConfirm(confirm *types.DPosProposalVoteSlot) error

type DataEntryPrefix

+ const CFGVersion

+ const DATABlockHash

+ const DATAConfirm

+ const DATAHeader

+ const DATATransaction

+ const DPOSIllegalProducer

+ const IXHeaderHashList

+ const IXSideChainTx

+ const IXUnspent

+ const IXUnspentUTXO

+ const STInfo

+ const SYSCurrentBlock

+ const SYSCurrentBookKeeper

type IChainStore

+ GetConfirm func(hash Uint256) (*DPosProposalVoteSlot, error)

+ InitProducerVotes func() error

+ SaveConfirm func(confirm *DPosProposalVoteSlot) error

+ type IChainStoreDpos interface

+ GetActiveRegisteredProducers func() []*PayloadRegisterProducer

+ GetCancelProducerHeight func(publicKey []byte) (uint32, error)

+ GetIllegalProducers func() map[string]struct{}

+ GetProducerStatus func(publicKey string) ProducerState

+ GetProducerVote func(publicKey []byte) Fixed64

+ GetRegisteredProducers func() []*PayloadRegisterProducer

+ GetRegisteredProducersSorted func() ([]*PayloadRegisterProducer, error)

type Ledger

+ Arbitrators interfaces.Arbitrators

+ HeightVersions interfaces.HeightVersions

+ func (l *Ledger) AppendDposBlocks(confirms []*DposBlock) error

+ func (l *Ledger) GetDposBlocks(start, end uint32) ([]*DposBlock, error)

+ type ProducerInfo struct

+ Payload *PayloadRegisterProducer

+ RegHeight uint32

+ Vote Fixed64

+ type ProducerState byte

+ const ProducerRegistered

+ const ProducerRegistering

+ const ProducerUnRegistered

v0.2.1

Dec 3, 2018

Changes in this version

type UTXO

+ TxID Uint256

v0.2.1-80ce

Dec 10, 2018

v0.2.0

Aug 20, 2018

Changes in this version

+ var InflationPerYear = OriginIssuanceAmount * 4 / 100

+ var RewardAmountPerBlock = common.Fixed64(float64(InflationPerYear) / float64(GeneratedBlocksPerYear))

+ func CheckBlockContext(block *Block) error

+ func CheckDestructionAddress(references map[*Input]*Output) error

+ func CheckTransactionCoinbaseOutputLock(txn *Transaction) error

+ func CheckTransactionFee(tx *Transaction, references map[*Input]*Output) error

v0.1.1

Jun 29, 2018

Changes in this version

+ const ValueExist

+ const ValueNone

+ var BlockGenerateInterval = int64(config.Parameters.ChainParam.TargetTimePerBlock / time.Second)

+ var GeneratedBlocksPerYear = 365 * 24 * 60 * 60 / BlockGenerateInterval

+ var IssuancePerYear = func(totalAmount int64) float64

+ var OriginIssuanceAmount = 3300 * 10000 * 100000000

+ func CheckDuplicateSidechainTx(txn *Transaction) error

+ func CheckOutputProgramHash(programHash Uint168) bool

+ func CheckSideChainPowConsensus(txn *Transaction, arbitrator []byte) error

+ func CheckTransferCrossChainAssetTransaction(txn *Transaction) error

+ func CheckWithdrawFromSideChainTransaction(txn *Transaction) error

+ func GetBlockRewardAmount(height uint32) common.Fixed64

+ func GetCurrentArbiter() ([]byte, error)

+ func SortPrograms(programs []*Program)

type ChainStore

+ func (c *ChainStore) GetSidechainTx(sidechainTxHash Uint256) (byte, error)

+ func (c *ChainStore) IsSidechainTxHashDuplicate(sidechainTxHash Uint256) bool

+ func (c *ChainStore) PersistSidechainTx(sidechainTxHash Uint256)

+ func (c *ChainStore) RollbackSidechainTx(sidechainTxHash Uint256) error

type DataEntryPrefix

+ const IX_SideChain_Tx

type IChainStore

+ GetSidechainTx func(sidechainTxHash Uint256) (byte, error)

+ IsSidechainTxHashDuplicate func(sidechainTxHash Uint256) bool

+ PersistSidechainTx func(sidechainTxHash Uint256)

type TxPool

+ func (pool *TxPool) GetTransactionPool(hasMaxCount bool) map[Uint256]*Transaction

+ func (pool *TxPool) IsDuplicateSidechainTx(sidechainTxHash Uint256) bool

v0.1.0

Jun 8, 2018

Changes in this version

+ const BITSPERKEY

+ const MaxBlockLocatorsPerMsg

+ const MaxTimeOffsetSeconds

+ const TaskChanCap

+ var ErrDBNotFound = errors.New("leveldb: not found")

+ var FoundationAddress string

+ var MinMemoryNodes = config.Parameters.ChainParam.MinMemoryNodes

+ func AddChildrenWork(node *BlockNode, work *big.Int)

+ func BigToCompact(n *big.Int) uint32

+ func CalcCurrentDifficulty(currentBits uint32) string

+ func CalcNextRequiredDifficulty(prevNode *BlockNode, newBlockTime time.Time) (uint32, error)

+ func CalcPastMedianTime(node *BlockNode) time.Time

+ func CalcWork(bits uint32) *big.Int

+ func CheckAssetPrecision(txn *Transaction) error

+ func CheckAttributeProgram(txn *Transaction) error

+ func CheckProofOfWork(header *Header, powLimit *big.Int) error

+ func CheckTransactionBalance(txn *Transaction) error

+ func CheckTransactionContext(txn *Transaction) ErrCode

+ func CheckTransactionInput(txn *Transaction) error

+ func CheckTransactionOutput(version uint32, txn *Transaction) error

+ func CheckTransactionPayload(txn *Transaction) error

+ func CheckTransactionSanity(version uint32, txn *Transaction) ErrCode

+ func CheckTransactionSignature(txn *Transaction) error

+ func CheckTransactionSize(txn *Transaction) error

+ func CheckTransactionUTXOLock(txn *Transaction) error

+ func CompactToBig(compact uint32) *big.Int

+ func DumpBlockNode(node *BlockNode)

+ func GetGenesisBlock() (*Block, error)

+ func GetTxFee(tx *Transaction, assetId Uint256) Fixed64

+ func GetTxFeeMap(tx *Transaction) (map[Uint256]Fixed64, error)

+ func GetTxProgramHashes(tx *Transaction) ([]common.Uint168, error)

+ func GetUint16Array(source []byte) ([]uint16, error)

+ func HashToBig(hash *Uint256) *big.Int

+ func Init(store IChainStore) error

+ func IsFinalizedTransaction(msgTx *Transaction, blockHeight uint32) bool

+ func NewCoinBaseTransaction(coinBasePayload *PayloadCoinBase, currentHeight uint32) *Transaction

+ func PowCheckBlockContext(block *Block, prevNode *BlockNode, ledger *Ledger) error

+ func PowCheckBlockSanity(block *Block, powLimit *big.Int, timeSource MedianTimeSource) error

+ func RunPrograms(data []byte, hashes []common.Uint168, programs []*Program) error

+ func ToByteArray(source []uint16) []byte

+ func VerifySignature(tx *Transaction) error

+ type BlockNode struct

+ Bits uint32

+ Children []*BlockNode

+ Hash *Uint256

+ Height uint32

+ InMainChain bool

+ Parent *BlockNode

+ ParentHash *Uint256

+ Timestamp uint32

+ Version uint32

+ WorkSum *big.Int

+ func NewBlockNode(header *Header, hash *Uint256) *BlockNode

+ func RemoveChildNode(children []*BlockNode, node *BlockNode) []*BlockNode

+ type Blockchain struct

+ AssetID Uint256

+ BCEvents *events.Event

+ BestChain *BlockNode

+ BlockCache map[Uint256]*Block

+ BlockHeight uint32

+ DepNodes map[Uint256][]*BlockNode

+ GenesisHash Uint256

+ Index map[Uint256]*BlockNode

+ IndexLock sync.RWMutex

+ MedianTimePast time.Time

+ OldestOrphan *OrphanBlock

+ OrphanLock sync.RWMutex

+ Orphans map[Uint256]*OrphanBlock

+ PrevOrphans map[Uint256][]*OrphanBlock

+ Root *BlockNode

+ TimeSource MedianTimeSource

+ func NewBlockchain(height uint32) *Blockchain

+ func (b *Blockchain) AddNodeToIndex(node *BlockNode)

+ func (b *Blockchain) BlockLocatorFromHash(inhash *Uint256) []*Uint256

+ func (b *Blockchain) LatestBlockLocator() ([]*Uint256, error)

+ func (b *Blockchain) LatestLocatorHash(locator []*Uint256) *Uint256

+ func (b *Blockchain) LookupNodeInIndex(hash *Uint256) (*BlockNode, bool)

+ func (b *Blockchain) MedianAdjustedTime() time.Time

+ func (b *Blockchain) RemoveNodeFromIndex(node *BlockNode)

+ func (bc *Blockchain) AddBlock(block *Block) (bool, bool, error)

+ func (bc *Blockchain) AddOrphanBlock(block *Block)

+ func (bc *Blockchain) BlockExists(hash *Uint256) bool

+ func (bc *Blockchain) ConnectBestChain(node *BlockNode, block *Block) (bool, error)

+ func (bc *Blockchain) ConnectBlock(node *BlockNode, block *Block) error

+ func (bc *Blockchain) ContainsTransaction(hash Uint256) bool

+ func (bc *Blockchain) CurrentBlockHash() Uint256

+ func (bc *Blockchain) DisconnectBlock(node *BlockNode, block *Block) error

+ func (bc *Blockchain) DumpState()

+ func (bc *Blockchain) GetBestHeight() uint32

+ func (bc *Blockchain) GetHeader(hash Uint256) (*Header, error)

+ func (bc *Blockchain) GetOrphanRoot(hash *Uint256) *Uint256

+ func (bc *Blockchain) GetPrevNodeFromBlock(block *Block) (*BlockNode, error)

+ func (bc *Blockchain) GetPrevNodeFromNode(node *BlockNode) (*BlockNode, error)

+ func (bc *Blockchain) GetReorganizeNodes(node *BlockNode) (*list.List, *list.List)

+ func (bc *Blockchain) IsKnownOrphan(hash *Uint256) bool

+ func (bc *Blockchain) LoadBlockNode(blockHeader *Header, hash *Uint256) (*BlockNode, error)

+ func (bc *Blockchain) ProcessBlock(block *Block) (bool, bool, error)

+ func (bc *Blockchain) ProcessOrphans(hash *Uint256) error

+ func (bc *Blockchain) PruneBlockNodes() error

+ func (bc *Blockchain) RemoveBlockNode(node *BlockNode) error

+ func (bc *Blockchain) RemoveOrphanBlock(orphan *OrphanBlock)

+ func (bc *Blockchain) ReorganizeChain(detachNodes, attachNodes *list.List) error

+ func (bc *Blockchain) UpdateBestHeight(val uint32)

+ type ChainStore struct

+ func (c *ChainStore) BlockInCache(hash Uint256) bool

+ func (c *ChainStore) Close()

+ func (c *ChainStore) ContainsUnspent(txid Uint256, index uint16) (bool, error)

+ func (c *ChainStore) GetAsset(hash Uint256) (*Asset, error)

+ func (c *ChainStore) GetAssets() map[Uint256]*Asset

+ func (c *ChainStore) GetBlock(hash Uint256) (*Block, error)

+ func (c *ChainStore) GetBlockHash(height uint32) (Uint256, error)

+ func (c *ChainStore) GetCurrentBlockHash() Uint256

+ func (c *ChainStore) GetHeader(hash Uint256) (*Header, error)

+ func (c *ChainStore) GetHeight() uint32

+ func (c *ChainStore) GetTransaction(txId Uint256) (*Transaction, uint32, error)

+ func (c *ChainStore) GetTxReference(tx *Transaction) (map[*Input]*Output, error)

+ func (c *ChainStore) GetUnspent(txid Uint256, index uint16) (*Output, error)

+ func (c *ChainStore) GetUnspentElementFromProgramHash(programHash Uint168, assetid Uint256, height uint32) ([]*UTXO, error)

+ func (c *ChainStore) GetUnspentFromProgramHash(programHash Uint168, assetid Uint256) ([]*UTXO, error)

+ func (c *ChainStore) GetUnspentsFromProgramHash(programHash Uint168) (map[Uint256][]*UTXO, error)

+ func (c *ChainStore) InitWithGenesisBlock(genesisBlock *Block) (uint32, error)

+ func (c *ChainStore) IsBlockInStore(hash Uint256) bool

+ func (c *ChainStore) IsDoubleSpend(txn *Transaction) bool

+ func (c *ChainStore) IsTxHashDuplicate(txhash Uint256) bool

+ func (c *ChainStore) PersistAsset(assetId Uint256, asset Asset) error

+ func (c *ChainStore) PersistBlockHash(b *Block) error

+ func (c *ChainStore) PersistCurrentBlock(b *Block) error

+ func (c *ChainStore) PersistTransaction(tx *Transaction, height uint32) error

+ func (c *ChainStore) PersistTransactions(b *Block) error

+ func (c *ChainStore) PersistTrimmedBlock(b *Block) error

+ func (c *ChainStore) PersistUnspend(b *Block) error

+ func (c *ChainStore) PersistUnspendUTXOs(b *Block) error

+ func (c *ChainStore) PersistUnspentWithProgramHash(programHash Uint168, assetid Uint256, height uint32, unspents []*UTXO) error

+ func (c *ChainStore) RemoveHeaderListElement(hash Uint256)

+ func (c *ChainStore) RollbackAsset(assetId Uint256) error

+ func (c *ChainStore) RollbackBlock(blockHash Uint256) error

+ func (c *ChainStore) RollbackBlockHash(b *Block) error

+ func (c *ChainStore) RollbackCurrentBlock(b *Block) error

+ func (c *ChainStore) RollbackTransaction(txn *Transaction) error

+ func (c *ChainStore) RollbackTransactions(b *Block) error

+ func (c *ChainStore) RollbackTrimmedBlock(b *Block) error

+ func (c *ChainStore) RollbackUnspend(b *Block) error

+ func (c *ChainStore) RollbackUnspendUTXOs(b *Block) error

+ func (c *ChainStore) SaveBlock(b *Block) error

+ type DataEntryPrefix byte

+ const CFG_Version

+ const DATA_BlockHash

+ const DATA_Header

+ const DATA_Transaction

+ const IX_HeaderHashList

+ const IX_Unspent

+ const IX_Unspent_UTXO

+ const ST_Info

+ const SYS_CurrentBlock

+ const SYS_CurrentBookKeeper

+ type IChainStore interface

+ BlockInCache func(hash Uint256) bool

+ Close func()

+ ContainsUnspent func(txid Uint256, index uint16) (bool, error)

+ GetAsset func(hash Uint256) (*Asset, error)

+ GetAssets func() map[Uint256]*Asset

+ GetBlock func(hash Uint256) (*Block, error)

+ GetBlockHash func(height uint32) (Uint256, error)

+ GetCurrentBlockHash func() Uint256

+ GetHeader func(hash Uint256) (*Header, error)

+ GetHeight func() uint32

+ GetTransaction func(txId Uint256) (*Transaction, uint32, error)

+ GetTxReference func(tx *Transaction) (map[*Input]*Output, error)

+ GetUnspent func(txid Uint256, index uint16) (*Output, error)

+ GetUnspentFromProgramHash func(programHash Uint168, assetid Uint256) ([]*UTXO, error)

+ GetUnspentsFromProgramHash func(programHash Uint168) (map[Uint256][]*UTXO, error)

+ InitWithGenesisBlock func(genesisblock *Block) (uint32, error)

+ IsBlockInStore func(hash Uint256) bool

+ IsDoubleSpend func(tx *Transaction) bool

+ IsTxHashDuplicate func(txhash Uint256) bool

+ PersistAsset func(assetid Uint256, asset Asset) error

+ RemoveHeaderListElement func(hash Uint256)

+ RollbackBlock func(hash Uint256) error

+ SaveBlock func(b *Block) error

+ func NewChainStore() (IChainStore, error)

+ type IIterator interface

+ First func() bool

+ Key func() []byte

+ Last func() bool

+ Next func() bool

+ Prev func() bool

+ Release func()

+ Seek func(key []byte) bool

+ Value func() []byte

+ type IStore interface

+ BatchCommit func() error

+ BatchDelete func(key []byte)

+ BatchPut func(key []byte, value []byte)

+ Close func() error

+ Delete func(key []byte) error

+ Get func(key []byte) ([]byte, error)

+ NewBatch func()

+ NewIterator func(prefix []byte) IIterator

+ Put func(key []byte, value []byte) error

+ type Iterator struct

+ func (it *Iterator) First() bool

+ func (it *Iterator) Key() []byte

+ func (it *Iterator) Last() bool

+ func (it *Iterator) Next() bool

+ func (it *Iterator) Prev() bool

+ func (it *Iterator) Release()

+ func (it *Iterator) Seek(key []byte) bool

+ func (it *Iterator) Value() []byte

+ type Ledger struct

+ Blockchain *Blockchain

+ Store IChainStore

+ var DefaultLedger *Ledger

+ func (l *Ledger) BlockInLedger(hash Uint256) bool

+ func (l *Ledger) GetAsset(assetId Uint256) (*Asset, error)

+ func (l *Ledger) GetBlockWithHash(hash Uint256) (*Block, error)

+ func (l *Ledger) GetBlockWithHeight(height uint32) (*Block, error)

+ func (l *Ledger) GetLocalBlockChainHeight() uint32

+ func (l *Ledger) GetTransactionWithHash(hash Uint256) (*Transaction, error)

+ func (l *Ledger) IsDoubleSpend(Tx *Transaction) bool

+ type LevelDB struct

+ func NewLevelDB(file string) (*LevelDB, error)

+ func (self *LevelDB) BatchCommit() error

+ func (self *LevelDB) BatchDelete(key []byte)

+ func (self *LevelDB) BatchPut(key []byte, value []byte)

+ func (self *LevelDB) Close() error

+ func (self *LevelDB) Delete(key []byte) error

+ func (self *LevelDB) Get(key []byte) ([]byte, error)

+ func (self *LevelDB) NewBatch()

+ func (self *LevelDB) NewIterator(prefix []byte) IIterator

+ func (self *LevelDB) Put(key []byte, value []byte) error

+ type MedianTimeSource interface

+ AddTimeSample func(id string, timeVal time.Time)

+ AdjustedTime func() time.Time

+ Offset func() time.Duration

+ func NewMedianTime() MedianTimeSource

+ type OrphanBlock struct

+ Block *Block

+ Expiration time.Time

+ type TxPool struct

+ func (pool *TxPool) AppendToTxnPool(txn *Transaction) ErrCode

+ func (pool *TxPool) CleanSubmittedTransactions(block *Block) error

+ func (pool *TxPool) GetTransaction(hash Uint256) *Transaction

+ func (pool *TxPool) GetTransactionCount() int

+ func (pool *TxPool) GetTxnPool(byCount bool) map[Uint256]*Transaction

+ func (pool *TxPool) Init()

+ func (pool *TxPool) MaybeAcceptTransaction(txn *Transaction) error

+ func (pool *TxPool) RemoveTransaction(txn *Transaction)

+ type UTXO struct

+ Index uint32

+ TxId Uint256

+ Value Fixed64

+ func (uu *UTXO) Deserialize(r io.Reader) error

+ func (uu *UTXO) Serialize(w io.Writer)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL