tangle

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 27, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetadataSolid                = 0
	MetadataValid                = 1
	MetadataConfirmed            = 2
	MetadataIsMilestone          = 3
	MetadataIsValueSpam          = 4
	MetadataValidStrictSemantics = 5
	MetadataConflicting          = 6
	MetadataInvalidPastCone      = 7
)
View Source 
const (
	StorePrefixHealth                  byte = 0
	StorePrefixTransactions            byte = 1
	StorePrefixTransactionMetadata     byte = 2
	StorePrefixBundleTransactions      byte = 3
	StorePrefixBundles                 byte = 4
	StorePrefixAddresses               byte = 5
	StorePrefixMilestones              byte = 6
	StorePrefixLedgerState             byte = 7
	StorePrefixLedgerBalance           byte = 8
	StorePrefixLedgerDiff              byte = 9
	StorePrefixApprovers               byte = 10
	StorePrefixTags                    byte = 11
	StorePrefixSnapshot                byte = 12
	StorePrefixSnapshotLedger          byte = 13
	StorePrefixUnconfirmedTransactions byte = 14
	StorePrefixSpentAddresses          byte = 15
	StorePrefixAutopeering             byte = 16
)
View Source 
const (
	TangleDbFilename         = "tangle.db"
	SnapshotDbFilename       = "snapshot.db"
	SpentAddressesDbFilename = "spent.db"
)
View Source 
const (
	BundleTxIsTail = 1
)
View Source 
const (
	DbVersion = 2
)
View Source 
const (
	SnapshotMetadataSpentAddressesEnabled = 0
)

Variables

View Source 
var (
	// ErrOperationAborted is returned when the operation was aborted e.g. by a shutdown signal.
	ErrOperationAborted = errors.New("operation was aborted")
	// ErrTransactionNotFound is returned when a transaction was not found.
	ErrTransactionNotFound = errors.New("transaction not found")
	// ErrBundleNotFound is returned when a bundle was not found.
	ErrBundleNotFound = errors.New("bundle not found")
	// ErrNodeNotSynced is returned when the node is not synchronized.
	ErrNodeNotSynced = errors.New("node is not synchronized")
)
View Source 
var (
	ErrSolidEntryPointsAlreadyInitialized = errors.New("solidEntryPoints already initialized")
	ErrSolidEntryPointsNotInitialized     = errors.New("solidEntryPoints not initialized")
)
View Source 
var (
	ErrInvalidMilestone = errors.New("invalid milestone")
)
View Source 
var (
	ErrNothingToCleanUp = errors.New("Nothing to clean up in the databases")
)
View Source 
var (
	ErrParseSnapshotInfoFailed = errors.New("Parsing of snapshot info failed")
)
View Source 
var Events = packageEvents{
	ReceivedValidMilestone:   events.NewEvent(BundleCaller),
	ReceivedInvalidMilestone: events.NewEvent(events.ErrorCaller),
	AddressSpent:             events.NewEvent(events.StringCaller),
}

Functions

func ApplyLedgerDiffWithoutLocking 

func ApplyLedgerDiffWithoutLocking(diff map[string]int64, index milestone.Index) error

ApplyLedgerDiffWithoutLocking applies the changes to the ledger. WriteLockLedger must be held while entering this function.

func BundleCaller 

func BundleCaller(handler interface{}, params ...interface{})

func CheckIfMilestone 

func CheckIfMilestone(bndl *Bundle) (result bool, err error)

func CleanupDatabases 

func CleanupDatabases() error

func CloseDatabases 

func CloseDatabases() error

func ConfigureDatabases 

func ConfigureDatabases(directory string)

func ConfigureMilestones 

func ConfigureMilestones(cooAddr hornet.Hash, cooSecLvl int, cooMerkleTreeDepth uint64, cooMilestoneMerkleHashFunc crypto.Hash)

func ConfigureStorages added in v0.5.0 

func ConfigureStorages(tangleStore kvstore.KVStore, snapshotStore kvstore.KVStore, spentStore kvstore.KVStore, caches profile.Caches)

func ContainsAddress added in v0.5.1 

func ContainsAddress(address hornet.Hash, txHash hornet.Hash, valueOnly bool) bool

ContainsAddress returns if the given address exists in the cache/persistence layer.

func ContainsApprover added in v0.5.1 

func ContainsApprover(txHash hornet.Hash, approverHash hornet.Hash) bool

ContainsApprover returns if the given approver exists in the cache/persistence layer.

func ContainsBundle 

func ContainsBundle(tailTxHash hornet.Hash) bool

bundle +-0

func ContainsBundleTransaction 

func ContainsBundleTransaction(bundleHash hornet.Hash, txHash hornet.Hash, isTail bool) bool

bundleTx +-0

func ContainsMilestone 

func ContainsMilestone(milestoneIndex milestone.Index) bool

milestone +-0

func ContainsTag added in v0.5.1 

func ContainsTag(txTag hornet.Hash, txHash hornet.Hash) bool

ContainsTag returns if the given tag exists in the cache/persistence layer.

func ContainsTransaction 

func ContainsTransaction(txHash hornet.Hash) bool

ContainsTransaction returns if the given transaction exists in the cache/persistence layer.

func DatabaseSupportsCleanup 

func DatabaseSupportsCleanup() bool

func DeleteAddress 

func DeleteAddress(address hornet.Hash, txHash hornet.Hash)

address +-0

func DeleteApprover 

func DeleteApprover(txHash hornet.Hash, approverHash hornet.Hash)

approvers +-0

func DeleteApprovers 

func DeleteApprovers(txHash hornet.Hash)

approvers +-0

func DeleteBundle 

func DeleteBundle(tailTxHash hornet.Hash)

bundle +-0

func DeleteBundleTransaction 

func DeleteBundleTransaction(bundleHash hornet.Hash, txHash hornet.Hash, isTail bool)

bundleTx +-0

func DeleteLedgerDiffForMilestone 

func DeleteLedgerDiffForMilestone(index milestone.Index) error

func DeleteMilestone 

func DeleteMilestone(milestoneIndex milestone.Index)

+-0

func DeleteTag 

func DeleteTag(txTag hornet.Hash, txHash hornet.Hash)

tag +-0

func DeleteTransaction 

func DeleteTransaction(txHash hornet.Hash)

DeleteTransaction deletes the transaction and metadata in the cache/persistence layer.

func DeleteTransactionMetadata added in v0.5.0 

func DeleteTransactionMetadata(txHash hornet.Hash)

DeleteTransactionMetadata deletes the metadata in the cache/persistence layer.

func DeleteUnconfirmedTxs 

func DeleteUnconfirmedTxs(msIndex milestone.Index) int

DeleteUnconfirmedTxs deletes unconfirmed transaction entries.

func FlushAddressStorage 

func FlushAddressStorage()

func FlushApproversStorage 

func FlushApproversStorage()

func FlushBundleStorage 

func FlushBundleStorage()

func FlushBundleTransactionsStorage 

func FlushBundleTransactionsStorage()

func FlushMilestoneStorage 

func FlushMilestoneStorage()

func FlushSpentAddressesStorage added in v0.5.0 

func FlushSpentAddressesStorage()

func FlushStorages added in v0.5.0 

func FlushStorages()

func FlushTagsStorage 

func FlushTagsStorage()

func FlushTransactionStorage 

func FlushTransactionStorage()

func FlushUnconfirmedTxsStorage 

func FlushUnconfirmedTxsStorage()

func ForEachAddress added in v0.5.0 

func ForEachAddress(consumer AddressConsumer, skipCache bool)

ForEachAddress loops over all addresses.

func ForEachApprover added in v0.5.0 

func ForEachApprover(consumer ApproverConsumer, skipCache bool)

ForEachApprover loops over all approvers.

func ForEachBundleHash added in v0.5.0 

func ForEachBundleHash(consumer BundleHashConsumer, skipCache bool)

ForEachBundleHash loops over all bundle hashes.

func ForEachBundleTransaction added in v0.5.0 

func ForEachBundleTransaction(consumer BundleTransactionConsumer, skipCache bool)

ForEachBundleTransaction loops over all bundle transactions.

func ForEachLedgerDiffHash added in v0.5.0 

func ForEachLedgerDiffHash(consumer LedgerDiffHashConsumer, skipCache bool)

ForEachLedgerDiffHash loops over all ledger diffs.

func ForEachMilestoneIndex 

func ForEachMilestoneIndex(consumer MilestoneIndexConsumer, skipCache bool)

ForEachMilestoneIndex loops through all milestones in the persistence layer.

func ForEachTag added in v0.5.0 

func ForEachTag(consumer TagConsumer, skipCache bool)

ForEachTag loops over all tags.

func ForEachTransactionHash 

func ForEachTransactionHash(consumer TransactionHashConsumer, skipCache bool)

ForEachTransactionHash loops over all transaction hashes.

func ForEachTransactionMetadataHash added in v0.5.0 

func ForEachTransactionMetadataHash(consumer TransactionHashConsumer, skipCache bool)

ForEachTransactionMetadataHash loops over all transaction metadata hashes.

func ForEachUnconfirmedTx added in v0.5.0 

func ForEachUnconfirmedTx(consumer UnconfirmedTxConsumer, skipCache bool)

ForEachUnconfirmedTx loops over all unconfirmed transactions.

func GetAddressesStorageSize 

func GetAddressesStorageSize() int

func GetAllBundleTransactionHashes added in v0.5.0 

func GetAllBundleTransactionHashes(maxFind ...int) hornet.Hashes

bundleTx +1

func GetAllSnapshotBalances 

func GetAllSnapshotBalances(abortSignal <-chan struct{}) (map[string]uint64, milestone.Index, error)

GetAllSnapshotBalances returns all balances for the snapshot milestone.

func GetApproverHashes 

func GetApproverHashes(txHash hornet.Hash, maxFind ...int) hornet.Hashes

approvers +-0

func GetApproversStorageSize 

func GetApproversStorageSize() int

func GetBalanceForAddress 

func GetBalanceForAddress(address hornet.Hash) (uint64, milestone.Index, error)

func GetBalanceForAddressWithoutLocking 

func GetBalanceForAddressWithoutLocking(address hornet.Hash) (uint64, milestone.Index, error)

func GetBundleStorageSize 

func GetBundleStorageSize() int

func GetBundleTailTransactionHashes 

func GetBundleTailTransactionHashes(bundleHash hornet.Hash, forceRelease bool, maxFind ...int) hornet.Hashes

bundleTx +1

func GetBundleTransactionHashes 

func GetBundleTransactionHashes(bundleHash hornet.Hash, forceRelease bool, maxFind ...int) hornet.Hashes

bundleTx +-0

func GetBundleTransactionsStorageSize 

func GetBundleTransactionsStorageSize() int

func GetDatabaseSizes 

func GetDatabaseSizes() (tangle int64, snapshot int64, spent int64)

GetDatabaseSizes returns the size of the different databases.

func GetLatestMilestoneIndex 

func GetLatestMilestoneIndex() milestone.Index

GetLatestMilestoneIndex returns the latest milestone index.

func GetLatestSeenMilestoneIndexFromSnapshot 

func GetLatestSeenMilestoneIndexFromSnapshot() milestone.Index

func GetLedgerDiffForMilestone 

func GetLedgerDiffForMilestone(index milestone.Index, abortSignal <-chan struct{}) (map[string]int64, error)

func GetLedgerDiffForMilestoneWithoutLocking 

func GetLedgerDiffForMilestoneWithoutLocking(index milestone.Index, abortSignal <-chan struct{}) (map[string]int64, error)

GetLedgerDiffForMilestoneWithoutLocking returns the ledger changes of that specific milestone. ReadLockLedger must be held while entering this function.

func GetLedgerStateForLSMI 

func GetLedgerStateForLSMI(abortSignal <-chan struct{}) (map[string]uint64, milestone.Index, error)

GetLedgerStateForLSMI returns all balances for the current solid milestone.

func GetLedgerStateForLSMIWithoutLocking 

func GetLedgerStateForLSMIWithoutLocking(abortSignal <-chan struct{}) (map[string]uint64, milestone.Index, error)

GetLedgerStateForLSMIWithoutLocking returns all balances for the current solid milestone. ReadLockLedger must be held while entering this function.

func GetLedgerStateForMilestone 

func GetLedgerStateForMilestone(targetIndex milestone.Index, abortSignal <-chan struct{}) (map[string]uint64, milestone.Index, error)

func GetLedgerStateForMilestoneWithoutLocking 

func GetLedgerStateForMilestoneWithoutLocking(targetIndex milestone.Index, abortSignal <-chan struct{}) (map[string]uint64, milestone.Index, error)

func GetMilestoneMerkleHashFunc added in v0.5.0 

func GetMilestoneMerkleHashFunc() crypto.Hash

func GetMilestoneStorageSize 

func GetMilestoneStorageSize() int

func GetSolidMilestoneIndex 

func GetSolidMilestoneIndex() milestone.Index

GetSolidMilestoneIndex returns the latest solid milestone index.

func GetSpentAddressesStorageSize 

func GetSpentAddressesStorageSize() int

func GetStoredMetadataOrNil 

func GetStoredMetadataOrNil(txHash hornet.Hash) *hornet.TransactionMetadata

GetStoredMetadataOrNil returns a metadata object without accessing the cache layer.

func GetTagHashes 

func GetTagHashes(txTag hornet.Hash, forceRelease bool, maxFind ...int) hornet.Hashes

tag +-0

func GetTagsStorageSize 

func GetTagsStorageSize() int

func GetTransactionHashesForAddress 

func GetTransactionHashesForAddress(address hornet.Hash, valueOnly bool, forceRelease bool, maxFind ...int) hornet.Hashes

address +-0

func GetTransactionStorageSize 

func GetTransactionStorageSize() int

func GetUnconfirmedTxHashes 

func GetUnconfirmedTxHashes(msIndex milestone.Index, forceRelease bool) hornet.Hashes

GetUnconfirmedTxHashes returns all hashes of unconfirmed transactions for that milestone.

func GetUnconfirmedTxStorageSize 

func GetUnconfirmedTxStorageSize() int

func IsCorrectDatabaseVersion 

func IsCorrectDatabaseVersion() bool

func IsDatabaseCorrupted 

func IsDatabaseCorrupted() bool

func IsDatabaseTainted added in v0.5.0 

func IsDatabaseTainted() bool

func IsMaybeMilestone 

func IsMaybeMilestone(cachedTx *CachedTransaction) bool

Checks if the the tx could be part of a milestone.

func IsMaybeMilestoneTx 

func IsMaybeMilestoneTx(cachedTx *CachedTransaction) bool

Checks if the the tx could be part of a milestone.

func IsNodeSynced 

func IsNodeSynced() bool

IsNodeSynced returns whether the node is synced.

func IsNodeSyncedWithThreshold 

func IsNodeSyncedWithThreshold() bool

IsNodeSyncedWithThreshold returns whether the node is synced within a certain threshold.

func LoadInitialValuesFromDatabase 

func LoadInitialValuesFromDatabase()

func MarkAddressAsSpent 

func MarkAddressAsSpent(address hornet.Hash) bool

spentAddress +-0

func MarkAddressAsSpentWithoutLocking 

func MarkAddressAsSpentWithoutLocking(address hornet.Hash) bool

spentAddress +-0

func MarkDatabaseCorrupted 

func MarkDatabaseCorrupted()

func MarkDatabaseHealthy 

func MarkDatabaseHealthy()

func MarkDatabaseTainted added in v0.5.0 

func MarkDatabaseTainted()

func NewTransactionCaller 

func NewTransactionCaller(handler interface{}, params ...interface{})

func OnTailTransactionSolid 

func OnTailTransactionSolid(cachedTx *CachedTransaction)

Create a new bundle instance as soon as a tailTx gets solid

func OverwriteSolidMilestoneIndex 

func OverwriteSolidMilestoneIndex(index milestone.Index)

OverwriteSolidMilestoneIndex is used to set older solid milestones (revalidation).

func ReadLockLedger 

func ReadLockLedger()

func ReadLockSolidEntryPoints 

func ReadLockSolidEntryPoints()

func ReadLockSpentAddresses 

func ReadLockSpentAddresses()

func ReadUnlockLedger 

func ReadUnlockLedger()

func ReadUnlockSolidEntryPoints 

func ReadUnlockSolidEntryPoints()

func ReadUnlockSpentAddresses 

func ReadUnlockSpentAddresses()

func RemoveTransactionFromBundle 

func RemoveTransactionFromBundle(txMeta *hornet.TransactionMetadata) map[string]struct{}

RemoveTransactionFromBundle removes the transaction if non-tail and not associated to a bundle instance or if tail, it removes all the transactions of the bundle from the storage that are not used in another bundle instance.

func ResetMilestoneIndexes added in v0.5.0 

func ResetMilestoneIndexes()

func ResetSolidEntryPoints 

func ResetSolidEntryPoints()

WriteLockSolidEntryPoints must be held while entering this function

func SearchLatestMilestoneIndexInStore 

func SearchLatestMilestoneIndexInStore() milestone.Index

SearchLatestMilestoneIndexInStore searches the latest milestone without accessing the cache layer.

func SetLatestMilestoneIndex 

func SetLatestMilestoneIndex(index milestone.Index, updateSynced ...bool) bool

SetLatestMilestoneIndex sets the latest milestone index.

func SetLatestSeenMilestoneIndexFromSnapshot 

func SetLatestSeenMilestoneIndexFromSnapshot(milestoneIndex milestone.Index)

func SetSnapshotInfo 

func SetSnapshotInfo(sn *SnapshotInfo)

func SetSnapshotMilestone 

func SetSnapshotMilestone(coordinatorAddress hornet.Hash, milestoneHash hornet.Hash, snapshotIndex milestone.Index, entryPointIndex milestone.Index, pruningIndex milestone.Index, timestamp int64, spentAddressesEnabled bool)

func SetSolidMilestoneIndex 

func SetSolidMilestoneIndex(index milestone.Index, updateSynced ...bool)

SetSolidMilestoneIndex sets the solid milestone index.

func ShutdownAddressStorage 

func ShutdownAddressStorage()

func ShutdownApproversStorage 

func ShutdownApproversStorage()

func ShutdownBundleStorage 

func ShutdownBundleStorage()

func ShutdownBundleTransactionsStorage 

func ShutdownBundleTransactionsStorage()

func ShutdownMilestoneStorage 

func ShutdownMilestoneStorage()

func ShutdownSpentAddressesStorage 

func ShutdownSpentAddressesStorage()

func ShutdownStorages added in v0.5.0 

func ShutdownStorages()

func ShutdownTagsStorage 

func ShutdownTagsStorage()

func ShutdownTransactionStorage 

func ShutdownTransactionStorage()

func ShutdownUnconfirmedTxsStorage 

func ShutdownUnconfirmedTxsStorage()

func SolidEntryPointsAdd 

func SolidEntryPointsAdd(txHash hornet.Hash, milestoneIndex milestone.Index)

WriteLockSolidEntryPoints must be held while entering this function

func SolidEntryPointsContain 

func SolidEntryPointsContain(txHash hornet.Hash) bool

func SolidEntryPointsIndex added in v0.4.1 

func SolidEntryPointsIndex(txHash hornet.Hash) (milestone.Index, bool)

func StoreLedgerBalancesInDatabase 

func StoreLedgerBalancesInDatabase(balances map[string]uint64, index milestone.Index) error

func StoreSnapshotBalancesInDatabase 

func StoreSnapshotBalancesInDatabase(balances map[string]uint64, index milestone.Index) error

StoreSnapshotBalancesInDatabase deletes all old entries and stores the ledger state of the snapshot index

func StoreSolidEntryPoints 

func StoreSolidEntryPoints()

WriteLockSolidEntryPoints must be held while entering this function

func StreamSpentAddressesToWriter 

func StreamSpentAddressesToWriter(buf io.Writer, abortSignal <-chan struct{}) (int32, error)

StreamSpentAddressesToWriter streams all spent addresses directly to an io.Writer.

func TransactionCaller 

func TransactionCaller(handler interface{}, params ...interface{})

func TransactionConfirmedCaller 

func TransactionConfirmedCaller(handler interface{}, params ...interface{})

func TransactionExistsInStore added in v0.5.0 

func TransactionExistsInStore(txHash hornet.Hash) bool

TransactionExistsInStore returns if the given transaction exists in the persistence layer.

func TransactionHashCaller added in v0.4.1 

func TransactionHashCaller(handler interface{}, params ...interface{})

func UpdateDatabaseVersion added in v0.5.0 

func UpdateDatabaseVersion() bool

UpdateDatabaseVersion tries to migrate the existing data to the new database version.

func WasAddressSpentFrom 

func WasAddressSpentFrom(address hornet.Hash) bool

spentAddress +-0

func WriteLockLedger 

func WriteLockLedger()

func WriteLockSolidEntryPoints 

func WriteLockSolidEntryPoints()

func WriteLockSpentAddresses 

func WriteLockSpentAddresses()

func WriteUnlockLedger 

func WriteUnlockLedger()

func WriteUnlockSolidEntryPoints 

func WriteUnlockSolidEntryPoints()

func WriteUnlockSpentAddresses 

func WriteUnlockSpentAddresses()

Types

type AddressConsumer added in v0.5.0 

type AddressConsumer func(address hornet.Hash, txHash hornet.Hash, isValue bool) bool

AddressConsumer consumes the given address during looping through all addresses in the persistence layer.

type ApproverConsumer added in v0.5.0 

type ApproverConsumer func(txHash hornet.Hash, approverHash hornet.Hash) bool

ApproverConsumer consumes the given approver during looping through all approvers in the persistence layer.

type Bundle 

type Bundle struct {
	objectstorage.StorableObjectFlags
	syncutils.RWMutex
	// contains filtered or unexported fields
}

Storable Object

func GetStoredBundleOrNil added in v0.5.0 

func GetStoredBundleOrNil(tailTxHash hornet.Hash) *Bundle

GetStoredBundleOrNil returns a bundle object without accessing the cache layer.

func (*Bundle) ApplySpentAddresses 

func (bundle *Bundle) ApplySpentAddresses()

func (*Bundle) GetBranchHash added in v0.5.0 

func (bundle *Bundle) GetBranchHash(forceRelease bool) hornet.Hash

func (*Bundle) GetBundleHash 

func (bundle *Bundle) GetBundleHash() hornet.Hash

func (*Bundle) GetHead 

func (bundle *Bundle) GetHead() *CachedTransaction

func (*Bundle) GetHeadMetadata added in v0.5.0 

func (bundle *Bundle) GetHeadMetadata() *CachedMetadata

func (*Bundle) GetLedgerChanges 

func (bundle *Bundle) GetLedgerChanges() map[string]int64

func (*Bundle) GetMetadata 

func (bundle *Bundle) GetMetadata() byte

func (*Bundle) GetMilestoneHash 

func (bundle *Bundle) GetMilestoneHash() hornet.Hash

func (*Bundle) GetMilestoneIndex 

func (bundle *Bundle) GetMilestoneIndex() milestone.Index

func (*Bundle) GetMilestoneMerkleTreeHash added in v0.5.0 

func (bundle *Bundle) GetMilestoneMerkleTreeHash() []byte

func (*Bundle) GetTail 

func (bundle *Bundle) GetTail() *CachedTransaction

func (*Bundle) GetTailHash 

func (bundle *Bundle) GetTailHash() hornet.Hash

func (*Bundle) GetTailMetadata added in v0.5.0 

func (bundle *Bundle) GetTailMetadata() *CachedMetadata

func (*Bundle) GetTransactions 

func (bundle *Bundle) GetTransactions() CachedTransactions

func (*Bundle) GetTrunkHash added in v0.5.0 

func (bundle *Bundle) GetTrunkHash(forceRelease bool) hornet.Hash

func (*Bundle) GetTxHashes 

func (bundle *Bundle) GetTxHashes() hornet.Hashes

func (*Bundle) IsConfirmed 

func (bundle *Bundle) IsConfirmed() bool

func (*Bundle) IsConflicting added in v0.5.0 

func (bundle *Bundle) IsConflicting() bool

func (*Bundle) IsInvalidPastCone added in v0.5.0 

func (bundle *Bundle) IsInvalidPastCone() bool

func (*Bundle) IsMilestone 

func (bundle *Bundle) IsMilestone() bool

func (*Bundle) IsSolid 

func (bundle *Bundle) IsSolid() bool

func (*Bundle) IsValid 

func (bundle *Bundle) IsValid() bool

func (*Bundle) IsValueSpam 

func (bundle *Bundle) IsValueSpam() bool

func (*Bundle) ObjectStorageKey 

func (bundle *Bundle) ObjectStorageKey() []byte

func (*Bundle) ObjectStorageValue 

func (bundle *Bundle) ObjectStorageValue() (data []byte)

func (*Bundle) SetInvalidPastCone added in v0.5.0 

func (bundle *Bundle) SetInvalidPastCone(invalidPastCone bool)

func (*Bundle) UnmarshalObjectStorageValue 

func (bundle *Bundle) UnmarshalObjectStorageValue(data []byte) (consumedBytes int, err error)

func (*Bundle) Update 

func (bundle *Bundle) Update(_ objectstorage.StorableObject)

ObjectStorage interface

func (*Bundle) ValidStrictSemantics 

func (bundle *Bundle) ValidStrictSemantics() bool

type BundleHashConsumer added in v0.5.0 

type BundleHashConsumer func(txHash hornet.Hash) bool

BundleHashConsumer consumes the given tailTxHash during looping through all bundles in the persistence layer.

type BundleTransaction 

type BundleTransaction struct {
	objectstorage.StorableObjectFlags

	// Key
	BundleHash hornet.Hash
	IsTail     bool
	TxHash     hornet.Hash
}

Storable Object

func (*BundleTransaction) GetBundleHash 

func (bt *BundleTransaction) GetBundleHash() hornet.Hash

func (*BundleTransaction) GetTxHash 

func (bt *BundleTransaction) GetTxHash() hornet.Hash

func (*BundleTransaction) ObjectStorageKey 

func (bt *BundleTransaction) ObjectStorageKey() []byte

func (*BundleTransaction) ObjectStorageValue 

func (bt *BundleTransaction) ObjectStorageValue() (_ []byte)

func (*BundleTransaction) UnmarshalObjectStorageValue 

func (bt *BundleTransaction) UnmarshalObjectStorageValue(_ []byte) (consumedBytes int, err error)

func (*BundleTransaction) Update 

func (bt *BundleTransaction) Update(_ objectstorage.StorableObject)

ObjectStorage interface

type BundleTransactionConsumer added in v0.5.0 

type BundleTransactionConsumer func(bundleHash hornet.Hash, txHash hornet.Hash, isTail bool) bool

BundleTransactionConsumer consumes the given bundle transaction during looping through all bundle transactions in the persistence layer.

type CachedAddress 

type CachedAddress struct {
	objectstorage.CachedObject
}

func StoreAddress 

func StoreAddress(address hornet.Hash, txHash hornet.Hash, isValue bool) *CachedAddress

address +1

func (*CachedAddress) GetAddress 

func (c *CachedAddress) GetAddress() *hornet.Address

type CachedAddresses 

type CachedAddresses []*CachedAddress

func (CachedAddresses) Release 

func (cachedAddresses CachedAddresses) Release(force ...bool)

type CachedAppprovers 

type CachedAppprovers []*CachedApprover

func (CachedAppprovers) Release 

func (cachedApprovers CachedAppprovers) Release(force ...bool)

type CachedApprover 

type CachedApprover struct {
	objectstorage.CachedObject
}

func StoreApprover 

func StoreApprover(txHash hornet.Hash, approverHash hornet.Hash) *CachedApprover

approvers +1

func (*CachedApprover) GetApprover 

func (c *CachedApprover) GetApprover() *hornet.Approver

type CachedBundle 

type CachedBundle struct {
	objectstorage.CachedObject
}

Cached Object

func FindClosestNextMilestoneOrNil 

func FindClosestNextMilestoneOrNil(index milestone.Index) *CachedBundle

bundle +1

func GetCachedBundleOrNil 

func GetCachedBundleOrNil(tailTxHash hornet.Hash) *CachedBundle

bundle +1

func GetMilestoneOrNil 

func GetMilestoneOrNil(milestoneIndex milestone.Index) *CachedBundle

GetMilestoneOrNil returns the CachedBundle of a milestone index or nil if it doesn't exist. bundle +1

func (*CachedBundle) ConsumeBundle 

func (c *CachedBundle) ConsumeBundle(consumer func(*Bundle))

func (*CachedBundle) GetBundle 

func (c *CachedBundle) GetBundle() *Bundle

func (*CachedBundle) Retain 

func (c *CachedBundle) Retain() *CachedBundle

type CachedBundleTransaction 

type CachedBundleTransaction struct {
	objectstorage.CachedObject
}

Cached Object

func GetCachedBundleTransactionOrNil 

func GetCachedBundleTransactionOrNil(bundleHash hornet.Hash, txHash hornet.Hash, isTail bool) *CachedBundleTransaction

bundleTx +1

func StoreBundleTransaction 

func StoreBundleTransaction(bundleHash hornet.Hash, txHash hornet.Hash, isTail bool) *CachedBundleTransaction

bundleTx +1

func (*CachedBundleTransaction) GetBundleTransaction 

func (c *CachedBundleTransaction) GetBundleTransaction() *BundleTransaction

type CachedBundleTransactions 

type CachedBundleTransactions []*CachedBundleTransaction

func (CachedBundleTransactions) Release 

func (cachedBundleTransactions CachedBundleTransactions) Release(force ...bool)

func (CachedBundleTransactions) Retain 

func (cachedBundleTransactions CachedBundleTransactions) Retain() CachedBundleTransactions

type CachedBundles 

type CachedBundles []*CachedBundle

func GetBundles 

func GetBundles(bundleHash hornet.Hash, forceRelease bool, maxFind ...int) CachedBundles

GetBundles returns all existing bundle instances for that bundle hash bundle +1

func GetBundlesOfTransactionOrNil 

func GetBundlesOfTransactionOrNil(txHash hornet.Hash, forceRelease bool) CachedBundles

GetBundlesOfTransactionOrNil gets all bundle instances in which this transaction is present. A transaction can be in multiple bundle instances simultaneously due to the nature of reattached transactions being able to form infinite amount of bundles which attach to the same underlying bundle transaction. For example it is possible to reattach a bundle's tail transaction directly "on top" of the origin one. bundle +1

func (CachedBundles) Release 

func (cachedBundles CachedBundles) Release(force ...bool)

func (CachedBundles) Retain 

func (cachedBundles CachedBundles) Retain() CachedBundles

type CachedMetadata added in v0.5.0 

type CachedMetadata struct {
	objectstorage.CachedObject
}

CachedMetadata contains the cached object only for metadata.

func GetCachedTxMetadataOrNil added in v0.5.0 

func GetCachedTxMetadataOrNil(txHash hornet.Hash) *CachedMetadata

metadata +1

func (*CachedMetadata) ConsumeMetadata added in v0.5.0 

func (c *CachedMetadata) ConsumeMetadata(consumer func(*hornet.TransactionMetadata))

meta -1

func (*CachedMetadata) GetMetadata added in v0.5.0 

func (c *CachedMetadata) GetMetadata() *hornet.TransactionMetadata

func (*CachedMetadata) Retain added in v0.5.0 

func (c *CachedMetadata) Retain() *CachedMetadata

type CachedMilestone 

type CachedMilestone struct {
	objectstorage.CachedObject
}

Cached Object

func GetCachedMilestoneOrNil 

func GetCachedMilestoneOrNil(milestoneIndex milestone.Index) *CachedMilestone

milestone +1

func StoreMilestone 

func StoreMilestone(bndl *Bundle) *CachedMilestone

milestone +1

func (*CachedMilestone) GetMilestone 

func (c *CachedMilestone) GetMilestone() *Milestone

type CachedSpentAddress 

type CachedSpentAddress struct {
	objectstorage.CachedObject
}

func (*CachedSpentAddress) GetSpentAddress 

func (c *CachedSpentAddress) GetSpentAddress() *hornet.SpentAddress

type CachedTag 

type CachedTag struct {
	objectstorage.CachedObject
}

func StoreTag 

func StoreTag(txTag hornet.Hash, txHash hornet.Hash) *CachedTag

tag +1

func (*CachedTag) GetTag 

func (c *CachedTag) GetTag() *hornet.Tag

type CachedTags 

type CachedTags []*CachedTag

func (CachedTags) Release 

func (cachedTags CachedTags) Release(force ...bool)

tag -1

type CachedTransaction 

type CachedTransaction struct {
	// contains filtered or unexported fields
}

CachedTransaction contains two cached objects, one for transaction data and one for metadata.

func AddTransactionToStorage 

func AddTransactionToStorage(hornetTx *hornet.Transaction, latestMilestoneIndex milestone.Index, requested bool, forceRelease bool, reapply bool) (cachedTx *CachedTransaction, alreadyAdded bool)

tx +1

func GetCachedTransactionOrNil 

func GetCachedTransactionOrNil(txHash hornet.Hash) *CachedTransaction

tx +1

func StoreTransactionIfAbsent 

func StoreTransactionIfAbsent(transaction *hornet.Transaction) (cachedTx *CachedTransaction, newlyAdded bool)

tx +1

func (*CachedTransaction) ConsumeMetadata added in v0.5.0 

func (c *CachedTransaction) ConsumeMetadata(consumer func(*hornet.TransactionMetadata))

tx -1 meta -1

func (*CachedTransaction) ConsumeTransaction 

func (c *CachedTransaction) ConsumeTransaction(consumer func(*hornet.Transaction))

tx -1 meta -1

func (*CachedTransaction) ConsumeTransactionAndMetadata added in v0.5.0 

func (c *CachedTransaction) ConsumeTransactionAndMetadata(consumer func(*hornet.Transaction, *hornet.TransactionMetadata))

tx -1 meta -1

func (*CachedTransaction) Exists 

func (c *CachedTransaction) Exists() bool

func (*CachedTransaction) GetCachedMetadata added in v0.5.0 

func (c *CachedTransaction) GetCachedMetadata() *CachedMetadata

meta +1

func (*CachedTransaction) GetMetadata 

func (c *CachedTransaction) GetMetadata() *hornet.TransactionMetadata

func (*CachedTransaction) GetTransaction 

func (c *CachedTransaction) GetTransaction() *hornet.Transaction

func (*CachedTransaction) Release 

func (c *CachedTransaction) Release(force ...bool)

tx -1

func (*CachedTransaction) Retain 

func (c *CachedTransaction) Retain() *CachedTransaction

tx +1

type CachedTransactions 

type CachedTransactions []*CachedTransaction

func (CachedTransactions) Release 

func (cachedTxs CachedTransactions) Release(force ...bool)

tx -1

func (CachedTransactions) Retain 

func (cachedTxs CachedTransactions) Retain() CachedTransactions

tx +1

type CachedUnconfirmedTx 

type CachedUnconfirmedTx struct {
	objectstorage.CachedObject
}

func StoreUnconfirmedTx 

func StoreUnconfirmedTx(msIndex milestone.Index, txHash hornet.Hash) *CachedUnconfirmedTx

unconfirmedTx +1

func (*CachedUnconfirmedTx) GetUnconfirmedTx 

func (c *CachedUnconfirmedTx) GetUnconfirmedTx() *hornet.UnconfirmedTx

type CachedUnconfirmedTxs 

type CachedUnconfirmedTxs []*CachedUnconfirmedTx

func (CachedUnconfirmedTxs) Release 

func (cachedUnconfirmedTxs CachedUnconfirmedTxs) Release(force ...bool)

type ErrDatabaseError 

type ErrDatabaseError struct {
	Inner error
}

func NewDatabaseError 

func NewDatabaseError(cause error) *ErrDatabaseError

func (ErrDatabaseError) Cause 

func (e ErrDatabaseError) Cause() error

func (ErrDatabaseError) Error 

func (e ErrDatabaseError) Error() string

type LedgerDiffHashConsumer added in v0.5.0 

type LedgerDiffHashConsumer func(msIndex milestone.Index, address hornet.Hash) bool

LedgerDiffHashConsumer consumes the given ledger diff addresses during looping through all ledger diffs in the persistence layer.

type Milestone 

type Milestone struct {
	objectstorage.StorableObjectFlags

	Index milestone.Index
	Hash  hornet.Hash
}

Storable Object

func (*Milestone) ObjectStorageKey 

func (ms *Milestone) ObjectStorageKey() []byte

func (*Milestone) ObjectStorageValue 

func (ms *Milestone) ObjectStorageValue() (data []byte)

func (*Milestone) UnmarshalObjectStorageValue 

func (ms *Milestone) UnmarshalObjectStorageValue(data []byte) (consumedBytes int, err error)

func (*Milestone) Update 

func (ms *Milestone) Update(_ objectstorage.StorableObject)

type MilestoneIndexConsumer 

type MilestoneIndexConsumer func(index milestone.Index) bool

MilestoneIndexConsumer consumes the given index during looping through all milestones in the persistence layer.

type SnapshotInfo 

type SnapshotInfo struct {
	CoordinatorAddress hornet.Hash
	Hash               hornet.Hash
	SnapshotIndex      milestone.Index
	EntryPointIndex    milestone.Index
	PruningIndex       milestone.Index
	Timestamp          int64
	Metadata           bitmask.BitMask
}

func GetSnapshotInfo 

func GetSnapshotInfo() *SnapshotInfo

func SnapshotInfoFromBytes 

func SnapshotInfoFromBytes(bytes []byte) (*SnapshotInfo, error)

func (*SnapshotInfo) GetBytes 

func (i *SnapshotInfo) GetBytes() []byte

func (*SnapshotInfo) IsSpentAddressesEnabled 

func (i *SnapshotInfo) IsSpentAddressesEnabled() bool

func (*SnapshotInfo) SetSpentAddressesEnabled 

func (i *SnapshotInfo) SetSpentAddressesEnabled(enabled bool)

type TagConsumer added in v0.5.0 

type TagConsumer func(txTag hornet.Hash, txHash hornet.Hash) bool

TagConsumer consumes the given tag during looping through all tags in the persistence layer.

type TransactionHashConsumer added in v0.5.0 

type TransactionHashConsumer func(txHash hornet.Hash) bool

TransactionHashConsumer consumes the given transaction hash during looping through all transactions in the persistence layer.

type UnconfirmedTxConsumer added in v0.5.0 

type UnconfirmedTxConsumer func(msIndex milestone.Index, txHash hornet.Hash) bool

UnconfirmedTxConsumer consumes the given unconfirmed transaction during looping through all unconfirmed transactions in the persistence layer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.