core

package

Go to main page

Versions in this module

v0

v0.6.1

Dec 2, 2022

v0.6.0

Jul 23, 2021

v0.5.9

Nov 22, 2021

v0.5.1

Jul 30, 2021

v0.5.0

May 17, 2021

v0.4.6

May 25, 2021

v0.4.5

May 11, 2021

v0.4.4

Apr 25, 2021

v0.4.3

Apr 21, 2021

v0.4.2

Apr 15, 2021

v0.3.3

Mar 18, 2021

v0.3.2

Feb 4, 2021

v0.1.3

Aug 20, 2019

v0.1.2

Nov 1, 2018

Changes in this version

+ const BlockCacheLRUCacheLimit

+ const ContractTxouputIndex

+ const ForkCacheLRUCacheLimit

+ const LengthForBlockToBeConsideredHistory

+ var ErrDuplicatedBlock = errors.New("ERROR: Block already exists in blockchain")

+ var ErrEmptyPublicKeyHash = errors.New("Empty public key hash")

+ var ErrIncorrectPublicKey = errors.New("Public key is not correct")

+ var ErrInvalidAddress = errors.New("Invalid Address")

+ var ErrInvalidPubKeyHashVersion = errors.New("Invalid Public Key Hash Version ")

+ var ErrNewUserPubKeyHash = errors.New("transaction: create pubkeyhash error")

+ var ErrTXInputNotFound = errors.New("transaction: transaction input not found")

+ var MetricsTxDoubleSpend = dapmetrics.NewCounter("dap.txpool.doublespend")

+ func Checksum(payload []byte) []byte

+ func GetAddressPayloadLength() int

+ func IsHashEqual(h1 Hash, h2 Hash) bool

+ func WaitDoneOrTimeout(done Done, timeOut int)

type Address

+ func (a Address) GetPubKeyHash() ([]byte, bool)

+ func (a Address) IsContract() (bool, error)

+ func (a Address) String() string

type Block

+ func GenerateBlockWithCbtx(addr Address, lastblock *Block) *Block

+ func (b *Block) CalculateHashWithoutNonce() Hash

+ func (b *Block) GetHeader() *BlockHeader

+ func (b *Block) GetSign() Hash

+ func (b *Block) SignBlock(key string, data []byte) bool

+ func (parent *Block) IsParentBlock(child *Block) bool

type BlockHeaderStream

+ Height uint64

+ Sign Hash

type BlockPool

+ func (pool *BlockPool) GetSyncState() bool

+ func (pool *BlockPool) SetSyncState(sync bool)

+ type BlockPoolInterface interface

+ BlockRequestCh func() chan BlockRequestPars

+ GetBlockchain func() *Blockchain

+ GetSyncState func() bool

+ Push func(block *Block, pid peer.ID)

+ SetBlockchain func(bc *Blockchain)

+ SetSyncState func(bool)

+ VerifyTransactions func(utxo UTXOIndex, forkBlks []*Block) bool

type Blockchain

+ func (bc *Blockchain) GetBlockByHeight(height uint64) (*Block, error)

+ func (bc *Blockchain) SetBlockPool(blockPool BlockPoolInterface)

type Consensus

+ AddProducer func(string) error

+ GetProducers func() []string

+ IsProducingBlock func() bool

+ SetKey func(string)

+ type Done func() bool

type KeyPair

+ func GetKeyPairByString(privateKey string) *KeyPair

type NetService

+ BroadcastBlock func(block *Block) error

+ type PubKeyHash struct

+ PubKeyHash []byte

+ func NewContractPubKeyHash() PubKeyHash

+ func NewUserPubKeyHash(pubKey []byte) (PubKeyHash, error)

+ func (pkh PubKeyHash) GenerateAddress() Address

+ func (pkh PubKeyHash) GetPubKeyHash() []byte

+ func (pkh PubKeyHash) IsContract() (bool, error)

+ type ScEngine interface

+ Execute func()

+ ImportSourceCode func(source string)

type TXInput

+ func MockTxInputsWithPubkey(pubkey []byte) []TXInput

type TXOutput

+ Contract string

+ func NewContractTXOutput(contract string) *TXOutput

type Transaction

+ func (tx *Transaction) Execute(index UTXOIndex, sc ScEngine)

+ func (tx *Transaction) GetContract() string

+ func (tx *Transaction) GetContractAddress() Address

+ func (tx *Transaction) GetToHashBytes() []byte

type TransactionPool

+ func (txPool *TransactionPool) Push(tx Transaction)

+ func (txPool *TransactionPool) ValidTxns(filter filterTx) []*Transaction

+ type UTXO struct

+ TxIndex int

+ Txid []byte

+ type UTXOIndex struct

+ func GetUTXOIndexAtBlockHash(db storage.Storage, bc *Blockchain, hash Hash) (UTXOIndex, error)

+ func LoadUTXOIndex(db storage.Storage) UTXOIndex

+ func NewUTXOIndex() UTXOIndex

+ func (utxos *UTXOIndex) ApplyTransaction(tx *Transaction) error

+ func (utxos *UTXOIndex) UpdateUtxoState(txs []*Transaction, db storage.Storage) ([]*Transaction, error)

+ func (utxos UTXOIndex) DeepCopy() UTXOIndex

+ func (utxos UTXOIndex) FindUTXO(txid []byte, vout int) *UTXO

+ func (utxos UTXOIndex) FindUTXOByVin(pubkeyHash []byte, txid []byte, vout int) *UTXO

+ func (utxos UTXOIndex) GetAllUTXOsByPubKeyHash(pubkeyHash []byte) []*UTXO

+ func (utxos UTXOIndex) GetUTXOsByAmount(pubkeyHash []byte, amount *common.Amount) ([]*UTXO, error)

+ func (utxos UTXOIndex) Save(mapkey string, db storage.Storage) error

v0.1.1

Sep 8, 2018

Changes in this version

+ var ErrInvalidAmount = errors.New("ERROR: Amount is invalid (must be > 0)")

type Blockchain

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

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

+ func (bc *Blockchain) GetBlockPool() *BlockPool

+ func (bc *Blockchain) GetConsensus() Consensus

+ func (bc *Blockchain) GetDb() storage.Storage

+ func (bc *Blockchain) GetTailBlockHash() Hash

+ func (bc *Blockchain) GetTxPool() *TransactionPool

+ func (bc *Blockchain) IsHigherThanBlockchain(block *Block) bool

+ func (bc *Blockchain) Rollback(targetHash Hash) bool

+ func (bc *Blockchain) SetConsensus(consensus Consensus)

+ func (bc *Blockchain) SetTailBlockHash(tailBlockHash Hash)

type Transaction

+ func (tx *Transaction) GetPrevTransactions(bc *Blockchain) map[string]Transaction

type TransactionPool

+ func (txPool *TransactionPool) PopSortedTransactions() []*Transaction

v0.1.0

Aug 27, 2018

Changes in this version

+ const BlockPoolMaxSize

+ const TransactionPoolLimit

+ const UtxoForkMapKey

+ const UtxoMapKey

+ var ErrBlockDoesNotExist = errors.New("ERROR: Block does not exist in blockchain")

+ var ErrInsufficientFund = errors.New("ERROR: The balance is insufficient")

+ var ErrInvalidAddAmount = errors.New("ERROR: Amount is invalid (must be > 0)")

+ var ErrNotAbleToGetLastBlockHash = errors.New("ERROR: Not able to get last block hash in blockchain")

+ var ErrTransactionNotFound = errors.New("ERROR: Transaction not found")

+ func CompareTransactionTips(a interface{}, b interface{}) int

+ func DeserializeUTXO(d []byte) *utxoIndex

+ func GetStoredUtxoMap(db storage.Storage, mapkey string) utxoIndex

+ func HashAddress(address []byte) []byte

+ func HashPubKey(pubKey []byte) ([]byte, error)

+ func IsParentBlock(parentBlk, childBlk *Block) bool

+ func IsParentBlockHash(parentBlk, childBlk *Block) bool

+ func IsParentBlockHeight(parentBlk, childBlk *Block) bool

+ type Address struct

+ Address string

+ func NewAddress(addressString string) Address

+ func (a Address) ValidateAddress() bool

+ type Addresses struct

+ Addresses []Address

+ type Block struct

+ func Deserialize(d []byte) *Block

+ func FakeNewBlockWithTimestamp(t int64, transactions []*Transaction, parent *Block) *Block

+ func GenerateMockBlock() *Block

+ func GenerateMockFork(size int, parent *Block) []*Block

+ func GenerateMockForkWithInvalidTx(size int, parent *Block) []*Block

+ func GenerateMockForkWithValidTx(size int, parent *Block) []*Block

+ func NewBlock(transactions []*Transaction, parent *Block) *Block

+ func NewGenesisBlock(address string) *Block

+ func (b *Block) CalculateHash() Hash

+ func (b *Block) CalculateHashWithNonce(nonce int64) Hash

+ func (b *Block) FindTransactionById(txid []byte) *Transaction

+ func (b *Block) FromProto(pb proto.Message)

+ func (b *Block) GetCoinbaseTransaction() *Transaction

+ func (b *Block) GetHash() Hash

+ func (b *Block) GetHeight() uint64

+ func (b *Block) GetNonce() int64

+ func (b *Block) GetPrevHash() Hash

+ func (b *Block) GetTimestamp() int64

+ func (b *Block) GetTransactions() []*Transaction

+ func (b *Block) HashTransactions() []byte

+ func (b *Block) Rollback(txPool *TransactionPool)

+ func (b *Block) Serialize() []byte

+ func (b *Block) SetHash(hash Hash)

+ func (b *Block) SetNonce(nonce int64)

+ func (b *Block) ToProto() proto.Message

+ func (b *Block) VerifyHash() bool

+ func (b *Block) VerifyTransactions(utxo utxoIndex) bool

+ func (blk Block) AddSpendableOutputsAfterNewBlock(mapkey string, db storage.Storage)

+ func (blk Block) ConsumeSpendableOutputsAfterNewBlock(mapkey string, db storage.Storage)

+ func (blk Block) UpdateUtxoIndexAfterNewBlock(mapkey string, db storage.Storage)

+ type BlockHeader struct

+ func (bh *BlockHeader) FromProto(pb proto.Message)

+ func (bh *BlockHeader) ToProto() proto.Message

+ type BlockHeaderStream struct

+ Hash Hash

+ Nonce int64

+ PrevHash Hash

+ Timestamp int64

+ type BlockPool struct

+ func NewBlockPool(size int) *BlockPool

+ func (pool *BlockPool) BlockRequestCh() chan BlockRequestPars

+ func (pool *BlockPool) GetBlockchain() *Blockchain

+ func (pool *BlockPool) GetForkPoolHeadBlk() *Block

+ func (pool *BlockPool) GetForkPoolTailBlk() *Block

+ func (pool *BlockPool) IsHigherThanFork(block *Block) bool

+ func (pool *BlockPool) IsParentOfFork(blk *Block) bool

+ func (pool *BlockPool) IsTailOfFork(blk *Block) bool

+ func (pool *BlockPool) Push(block *Block, pid peer.ID)

+ func (pool *BlockPool) ReInitializeForkPool(blk *Block)

+ func (pool *BlockPool) ResetForkPool()

+ func (pool *BlockPool) SetBlockchain(bc *Blockchain)

+ func (pool *BlockPool) VerifyTransactions(utxo utxoIndex) bool

+ type BlockRequestPars struct

+ BlockHash Hash

+ Pid peer.ID

+ type BlockStream struct

+ Header *BlockHeaderStream

+ Height uint64

+ Transactions []*Transaction

+ type Blockchain struct

+ DB storage.Storage

+ func CreateBlockchain(address Address, db storage.Storage, consensus Consensus) *Blockchain

+ func GenerateMockBlockchain(size int) *Blockchain

+ func GenerateMockBlockchainWithCoinbaseTxOnly(size int) *Blockchain

+ func GenerateMockBlockchainWithCoinbaseTxOnlyWithConsensus(size int, consensus Consensus) *Blockchain

+ func GetBlockchain(db storage.Storage, consensus Consensus) (*Blockchain, error)

+ func (bc *Blockchain) BlockPool() *BlockPool

+ func (bc *Blockchain) FindTransaction(ID []byte) (Transaction, error)

+ func (bc *Blockchain) FindTransactionFromIndexBlock(txID []byte, blockId []byte) (Transaction, error)

+ func (bc *Blockchain) FindUTXO(pubKeyHash []byte) ([]TXOutput, error)

+ func (bc *Blockchain) FindUnspentTransactions(pubKeyHash []byte) ([]Transaction, error)

+ func (bc *Blockchain) GetBlockByHash(hash Hash) (*Block, error)

+ func (bc *Blockchain) GetMaxHeight() uint64

+ func (bc *Blockchain) GetPrevTransactions(tx Transaction) map[string]Transaction

+ func (bc *Blockchain) GetTailBlock() (*Block, error)

+ func (bc *Blockchain) GetTailHash() ([]byte, error)

+ func (bc *Blockchain) HigherThanBlockchain(blk *Block) bool

+ func (bc *Blockchain) IsInBlockchain(hash Hash) bool

+ func (bc *Blockchain) Iterator() *Blockchain

+ func (bc *Blockchain) MergeFork()

+ func (bc *Blockchain) Next() (*Block, error)

+ func (bc *Blockchain) NextFromIndex(indexHash []byte) (*Block, error)

+ func (bc *Blockchain) RollbackToABlockHeight(hash Hash) bool

+ func (bc *Blockchain) String() string

+ func (bc *Blockchain) TxPool() *TransactionPool

+ func (bc *Blockchain) UpdateNewBlock(newBlock *Block)

+ func (bc Blockchain) GetUtxoStateAtBlockHash(db storage.Storage, hash []byte) (utxoIndex, error)

+ type Consensus interface

+ SetTargetBit func(int)

+ Setup func(NetService, string)

+ Start func()

+ StartNewBlockMinting func()

+ Stop func()

+ Validate func(block *Block) bool

+ type Hash []byte

+ type KeyPair struct

+ PrivateKey ecdsa.PrivateKey

+ PublicKey []byte

+ func NewKeyPair() *KeyPair

+ func (w KeyPair) GenerateAddress() Address

+ type NetService interface

+ GetBlockchain func() *Blockchain

+ GetPeerID func() peer.ID

+ SendBlock func(block *Block) error

+ type RcvedBlock struct

+ Block *Block

+ Pid peer.ID

+ type TXInput struct

+ PubKey []byte

+ Signature []byte

+ Txid []byte

+ Vout int

+ func MockTxInputs() []TXInput

+ func (in *TXInput) FromProto(pb proto.Message)

+ func (in *TXInput) ToProto() proto.Message

+ func (in *TXInput) UsesKey(pubKeyHash []byte) bool

+ type TXOutput struct

+ PubKeyHash []byte

+ Value int

+ func MockTxOutputs() []TXOutput

+ func NewTXOutput(value int, address string) *TXOutput

+ func (out *TXOutput) FromProto(pb proto.Message)

+ func (out *TXOutput) IsLockedWithKey(pubKeyHash []byte) bool

+ func (out *TXOutput) Lock(address []byte)

+ func (out *TXOutput) ToProto() proto.Message

+ type Transaction struct

+ ID []byte

+ Tip uint64

+ Vin []TXInput

+ Vout []TXOutput

+ func MockTransaction() *Transaction

+ func NewCoinbaseTX(to, data string) Transaction

+ func NewUTXOTransaction(db storage.Storage, from, to Address, amount int, senderKeyPair KeyPair, ...) (Transaction, error)

+ func NewUTXOTransactionforAddBalance(to Address, amount int, keyPair KeyPair, bc *Blockchain) (Transaction, error)

+ func (tx *Transaction) FindAllTxinsInUtxoPool(utxoPool utxoIndex) map[string]TXOutput

+ func (tx *Transaction) FromProto(pb proto.Message)

+ func (tx *Transaction) Hash() []byte

+ func (tx *Transaction) Sign(privKey ecdsa.PrivateKey, prevTXs map[string]Transaction)

+ func (tx *Transaction) ToProto() proto.Message

+ func (tx *Transaction) TrimmedCopy() Transaction

+ func (tx *Transaction) Verify(utxo utxoIndex) bool

+ func (tx *Transaction) VerifySignatures(prevTXs map[string]TXOutput) bool

+ func (tx Transaction) IsCoinbase() bool

+ func (tx Transaction) Serialize() []byte

+ func (tx Transaction) String() string

+ type TransactionPool struct

+ Transactions sorted.Slice

+ func GenerateMockTransactionPool(numOfTxs int) *TransactionPool

+ func NewTransactionPool() *TransactionPool

+ func (txPool *TransactionPool) ConditionalAdd(tx Transaction)

+ func (txPool *TransactionPool) FilterAllTransactions(utxoPool utxoIndex)

+ func (txPool *TransactionPool) GetSortedTransactions() []*Transaction

+ func (txPool *TransactionPool) PushTransaction(msg string)

+ func (txPool *TransactionPool) RemoveMultipleTransactions(txs []*Transaction)

+ func (txPool *TransactionPool) Start()

+ func (txPool *TransactionPool) Stop()

+ func (txPool *TransactionPool) StructDelete(tx interface{})

+ func (txPool *TransactionPool) StructPush(val interface{})

+ func (txPool *TransactionPool) Traverse(txHandler func(tx Transaction) bool)

+ type TxIndex struct

+ BlockId []byte

+ BlockIndex int

+ type UTXOutputStored struct

+ PubKeyHash []byte

+ TxIndex int

+ Txid []byte

+ Value int

+ func GetAddressUTXOs(mapkey string, pubkey []byte, db storage.Storage) []UTXOutputStored

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