blockchain

package

Go to main page

Versions in this module

v0

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

Jul 4, 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