blockchain

package

Go to main page

Versions in this module

v0

v0.3.3

Dec 10, 2018

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