jobs

Documentation

Index

• func CertificateSync()
• func ClaimTrieSync()
• func ClaimTrieSyncAsync()
• func GetIsExpiredAtHeight(height, blockHeight uint) bool
• func MempoolSync()
• func SetControllingClaimForNames(claims model.ClaimSlice, atHeight uint64) error
• func SyncAddressBalances() (int64, error)
• func SyncAddressBalancesJob()
• func SyncClaims(claims model.ClaimSlice) error
• func SyncTransactionValue() (int64, error)
• func SyncTransactionValueJob()
• func ValidateChain()
• type BlockData
  • func ValidateChainRange(from, to *uint64) ([]BlockData, error)

Functions

func CertificateSync

func CertificateSync()

CertificateSync processed all claims that have not been processed yet and verifies that any claims for channels, are signed by the channels certificate. This ensure that the channel owner actually published this claim.

func ClaimTrieSync

func ClaimTrieSync()

ClaimTrieSync syncs the claim trie bidstate, effective amount and effective height

func ClaimTrieSyncAsync

func ClaimTrieSyncAsync()

ClaimTrieSyncAsync synchronizes claimtrie information that is calculated and enforced by lbrycrd.

func GetIsExpiredAtHeight

func GetIsExpiredAtHeight(height, blockHeight uint) bool

GetIsExpiredAtHeight checks the claim height compared to the current height to determine expiration.

func MempoolSync

func MempoolSync()

MempoolSync synchronizes the memory pool of lbrycrd. Transactions are processed against a special block with the Hash of the mempool constant. Transactions are processed recursively since transactions in the pool can be dependent on one another. The dependent transactions are always processed first.

func SetControllingClaimForNames

func SetControllingClaimForNames(claims model.ClaimSlice, atHeight uint64) error

SetControllingClaimForNames sets the bid state for claims with these names.

func SyncAddressBalances

func SyncAddressBalances() (int64, error)

SyncAddressBalances will update the balance for every address if needed based on the transaction address table and returns the number of rows changed.

func SyncAddressBalancesJob

func SyncAddressBalancesJob()

SyncAddressBalancesJob runs the SyncAddressBalances as a background job.

func SyncClaims

func SyncClaims(claims model.ClaimSlice) error

SyncClaims syncs the claims' with these names effective amount and valid at height with the lbrycrd claimtrie.

func SyncTransactionValue

func SyncTransactionValue() (int64, error)

SyncTransactionValue will sync up the value column of all transactions based on the transaction address table and returns the number of rows affected.

func SyncTransactionValueJob

func SyncTransactionValueJob()

SyncTransactionValueJob runs the SyncAddressBalances as a background job.

func ValidateChain

func ValidateChain()

ValidateChain goes through the entire chain to make sure the data matches what is in the block chain. If there are differences it will log an error message identifying the magnitude of the difference.

Types

type BlockData

type BlockData struct {
	Block          uint64
	TxHash         string
	MissingOutputs int
	MissingInputs  int
}

BlockData type holds information about where differences are in Chainquery vs the Blockchain.

func ValidateChainRange

func ValidateChainRange(from, to *uint64) ([]BlockData, error)

ValidateChainRange validates a range of blocks and returns the differences.