tangle

package
v0.4.0-rc11 Latest Latest
Warning

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

 Go to latest Published: May 26, 2020 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetadataSolid                = 0
	MetadataValid                = 1
	MetadataConfirmed            = 2
	MetadataIsMilestone          = 3
	MetadataIsValueSpam          = 4
	MetadataValidStrictSemantics = 5
)
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 = 1
)
View Source 
const (
	SnapshotMetadataSpentAddressesEnabled = 0
)

Variables

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 (
	ErrOperationAborted = errors.New("operation was aborted")
)
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[trinary.Hash]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 string, cooSecLvl int, cooMerkleTreeDepth uint64)

func ContainsBundle 

func ContainsBundle(tailTxHash trinary.Hash) bool

bundle +-0

func ContainsBundleTransaction 

func ContainsBundleTransaction(bundleHash trinary.Hash, transactionHash trinary.Hash, isTail bool) bool

bundleTx +-0

func ContainsMilestone 

func ContainsMilestone(milestoneIndex milestone.Index) bool

milestone +-0

func ContainsTransaction 

func ContainsTransaction(transactionHash trinary.Hash) bool

tx +-0

func DatabaseSupportsCleanup 

func DatabaseSupportsCleanup() bool

func DeleteAddress 

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

address +-0

func DeleteApprover 

func DeleteApprover(transactionHash trinary.Hash, approverHash trinary.Hash)

approvers +-0

func DeleteApprovers 

func DeleteApprovers(transactionHash trinary.Hash)

approvers +-0

func DeleteBundle 

func DeleteBundle(tailTxHash trinary.Hash)

bundle +-0

func DeleteBundleTransaction 

func DeleteBundleTransaction(bundleHash trinary.Hash, transactionHash trinary.Hash, isTail bool)

bundleTx +-0

func DeleteLedgerBalancesInDatabase 

func DeleteLedgerBalancesInDatabase() error

func DeleteLedgerDiffForMilestone 

func DeleteLedgerDiffForMilestone(index milestone.Index) error

func DeleteMilestone 

func DeleteMilestone(milestoneIndex milestone.Index)

+-0

func DeleteTag 

func DeleteTag(txTag trinary.Trytes, txHash trinary.Hash)

tag +-0

func DeleteTags 

func DeleteTags(txTag trinary.Trytes)

tag +-0

func DeleteTransaction 

func DeleteTransaction(transactionHash trinary.Hash)

tx +-0

func DeleteUnconfirmedTxs 

func DeleteUnconfirmedTxs(msIndex milestone.Index)

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 FlushTagsStorage 

func FlushTagsStorage()

func FlushTransactionStorage 

func FlushTransactionStorage()

func FlushUnconfirmedTxsStorage 

func FlushUnconfirmedTxsStorage()

func ForEachMilestone 

func ForEachMilestone(consumer MilestoneConsumer)

func ForEachMilestoneIndex 

func ForEachMilestoneIndex(consumer MilestoneIndexConsumer, skipCache bool)

ForEachMilestoneIndex loops though all milestones in the persistence layer.

func ForEachTransaction 

func ForEachTransaction(consumer TransactionConsumer)

func ForEachTransactionHashBytes 

func ForEachTransactionHashBytes(consumer TransactionHashBytesConsumer)

ForEachTransactionHashBytes loops over all transaction hashes (binary representation). Transaction that only exist in the cache are ignored.

func GetAddressesStorageSize 

func GetAddressesStorageSize() int

func GetAllSnapshotBalances 

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

GetAllSnapshotBalances returns all balances for the snapshot milestone.

func GetApproverHashes 

func GetApproverHashes(transactionHash trinary.Hash, forceRelease bool, maxFind ...int) []trinary.Hash

approvers +-0

func GetApproversStorageSize 

func GetApproversStorageSize() int

func GetBalanceForAddress 

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

func GetBalanceForAddressWithoutLocking 

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

func GetBundleStorageSize 

func GetBundleStorageSize() int

func GetBundleTailTransactionHashes 

func GetBundleTailTransactionHashes(bundleHash trinary.Hash, forceRelease bool, maxFind ...int) []trinary.Hash

bundleTx +1

func GetBundleTransactionHashes 

func GetBundleTransactionHashes(bundleHash trinary.Hash, forceRelease bool, maxFind ...int) []trinary.Hash

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[trinary.Hash]int64, error)

func GetLedgerDiffForMilestoneWithoutLocking 

func GetLedgerDiffForMilestoneWithoutLocking(index milestone.Index, abortSignal <-chan struct{}) (map[trinary.Hash]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[trinary.Hash]uint64, milestone.Index, error)

GetLedgerStateForLSMI returns all balances for the current solid milestone.

func GetLedgerStateForLSMIWithoutLocking 

func GetLedgerStateForLSMIWithoutLocking(abortSignal <-chan struct{}) (map[trinary.Hash]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[trinary.Hash]uint64, milestone.Index, error)

func GetLedgerStateForMilestoneWithoutLocking 

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

func GetMilestoneStorageSize 

func GetMilestoneStorageSize() int

func GetSolidEntryPointsHashes 

func GetSolidEntryPointsHashes() []trinary.Hash

func GetSolidMilestoneIndex 

func GetSolidMilestoneIndex() milestone.Index

GetSolidMilestoneIndex returns the latest solid milestone index.

func GetSpentAddressesStorageSize 

func GetSpentAddressesStorageSize() int

func GetStoredMetadataOrNil 

func GetStoredMetadataOrNil(txHashBytes []byte) *hornet.TransactionMetadata

GetStoredMetadataOrNil returns a metadata object without accessing the cache layer.

func GetStoredTransactionOrNil 

func GetStoredTransactionOrNil(txHashBytes []byte) *hornet.Transaction

GetStoredTransactionOrNil returns a transaction object without accessing the cache layer.

func GetTagHashes 

func GetTagHashes(txTag trinary.Trytes, forceRelease bool, maxFind ...int) []trinary.Hash

tag +-0

func GetTagsStorageSize 

func GetTagsStorageSize() int

func GetTransactionHashesForAddress 

func GetTransactionHashesForAddress(address trinary.Hash, valueOnly bool, forceRelease bool, maxFind ...int) []trinary.Hash

address +-0

func GetTransactionStorageSize 

func GetTransactionStorageSize() int

func GetUnconfirmedTxHashBytes 

func GetUnconfirmedTxHashBytes(msIndex milestone.Index, forceRelease bool) [][]byte

GetUnconfirmedTxHashBytes 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 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 trinary.Trytes) bool

spentAddress +-0

func MarkAddressAsSpentBinaryWithoutLocking 

func MarkAddressAsSpentBinaryWithoutLocking(address []byte) bool

spentAddress +-0

func MarkDatabaseCorrupted 

func MarkDatabaseCorrupted()

func MarkDatabaseHealthy 

func MarkDatabaseHealthy()

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(tx *transaction.Transaction) map[trinary.Hash]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 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 trinary.Hash, milestoneHash trinary.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 ShutdownTagsStorage 

func ShutdownTagsStorage()

func ShutdownTransactionStorage 

func ShutdownTransactionStorage()

func ShutdownUnconfirmedTxsStorage 

func ShutdownUnconfirmedTxsStorage()

func SolidEntryPointsAdd 

func SolidEntryPointsAdd(transactionHash trinary.Hash, milestoneIndex milestone.Index)

WriteLockSolidEntryPoints must be held while entering this function

func SolidEntryPointsContain 

func SolidEntryPointsContain(transactionHash trinary.Hash) bool

func StoreLedgerBalancesInDatabase 

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

func StoreSnapshotBalancesInDatabase 

func StoreSnapshotBalancesInDatabase(balances map[trinary.Hash]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 WasAddressSpentFrom 

func WasAddressSpentFrom(address trinary.Trytes) 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 Bundle 

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

Storable Object

func (*Bundle) ApplySpentAddresses 

func (bundle *Bundle) ApplySpentAddresses()

func (*Bundle) GetBranch 

func (bundle *Bundle) GetBranch(forceRelease bool) trinary.Hash

func (*Bundle) GetHash 

func (bundle *Bundle) GetHash() trinary.Hash

func (*Bundle) GetHead 

func (bundle *Bundle) GetHead() *CachedTransaction

func (*Bundle) GetLedgerChanges 

func (bundle *Bundle) GetLedgerChanges() map[trinary.Trytes]int64

func (*Bundle) GetMetadata 

func (bundle *Bundle) GetMetadata() byte

func (*Bundle) GetMilestoneHash 

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

func (*Bundle) GetMilestoneIndex 

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

func (*Bundle) GetTail 

func (bundle *Bundle) GetTail() *CachedTransaction

func (*Bundle) GetTailHash 

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

func (*Bundle) GetTransactionHashes 

func (bundle *Bundle) GetTransactionHashes() []trinary.Hash

func (*Bundle) GetTransactions 

func (bundle *Bundle) GetTransactions() CachedTransactions

func (*Bundle) GetTrunk 

func (bundle *Bundle) GetTrunk(forceRelease bool) trinary.Hash

func (*Bundle) IsConfirmed 

func (bundle *Bundle) IsConfirmed() 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) ResetSolidAndConfirmed 

func (bundle *Bundle) ResetSolidAndConfirmed()

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 BundleTransaction 

type BundleTransaction struct {
	objectstorage.StorableObjectFlags

	// Key
	BundleHash []byte
	IsTail     bool
	TxHash     []byte
}

Storable Object

func (*BundleTransaction) GetBundleHash 

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

func (*BundleTransaction) GetTransactionHash 

func (bt *BundleTransaction) GetTransactionHash() trinary.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 CachedAddress 

type CachedAddress struct {
	objectstorage.CachedObject
}

func StoreAddress 

func StoreAddress(address trinary.Hash, txHash trinary.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(transactionHash trinary.Hash, approverHash trinary.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 trinary.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 trinary.Hash, transactionHash trinary.Hash, isTail bool) *CachedBundleTransaction

bundleTx +1

func StoreBundleTransaction 

func StoreBundleTransaction(bundleHash trinary.Hash, transactionHash trinary.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 trinary.Hash, forceRelease bool, maxFind ...int) CachedBundles

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

func GetBundlesOfTransactionOrNil 

func GetBundlesOfTransactionOrNil(txHash trinary.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 CachedMilestone 

type CachedMilestone struct {
	objectstorage.CachedObject
}

Cached Object

func GetCachedMilestoneOrNil 

func GetCachedMilestoneOrNil(milestoneIndex milestone.Index) *CachedMilestone

milestone +1

func StoreMilestone 

func StoreMilestone(bndl *Bundle) (bool, *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 trinary.Trytes, txHash trinary.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(transactionHash trinary.Hash) *CachedTransaction

tx +1

func StoreTransactionIfAbsent 

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

tx +1

func (*CachedTransaction) ConsumeTransaction 

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

tx -1

func (*CachedTransaction) Exists 

func (c *CachedTransaction) Exists() bool

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 trinary.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 Milestone 

type Milestone struct {
	objectstorage.StorableObjectFlags

	Index milestone.Index
	Hash  trinary.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 MilestoneConsumer 

type MilestoneConsumer func(cachedMs objectstorage.CachedObject)

type MilestoneIndexConsumer 

type MilestoneIndexConsumer func(index milestone.Index)

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

type SnapshotInfo 

type SnapshotInfo struct {
	CoordinatorAddress trinary.Hash
	Hash               trinary.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 TransactionConsumer 

type TransactionConsumer func(cachedTx objectstorage.CachedObject, cachedTxMeta objectstorage.CachedObject)

type TransactionHashBytesConsumer 

type TransactionHashBytesConsumer func(txHash []byte)

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.