dag

Jan 9, 2023

Changes in this version

+ var ErrTraversalDone = errors.New("traversal is done")

+ func ConeRootIndexes(ctx context.Context, parentsTraverserStorage ParentsTraverserStorage, ...) (youngestConeRootIndex milestone.Index, oldestConeRootIndex milestone.Index, ...)

+ func TraverseChildren(ctx context.Context, childrenTraverserStorage ChildrenTraverserStorage, ...) error

+ func TraverseParents(ctx context.Context, parentsTraverserStorage ParentsTraverserStorage, ...) error

+ func TraverseParentsOfMessage(ctx context.Context, parentsTraverserStorage ParentsTraverserStorage, ...) error

+ func UpdateConeRootIndexes(ctx context.Context, traverserStorage TraverserStorage, ...) error

+ type ChildrenTraverser struct

+ func NewChildrenTraverser(childrenTraverserStorage ChildrenTraverserStorage) *ChildrenTraverser

+ func (t *ChildrenTraverser) Traverse(ctx context.Context, startMessageID hornet.MessageID, condition Predicate, ...) error

+ type ChildrenTraverserStorage interface

+ CachedMessageMetadata func(messageID hornet.MessageID) (*storage.CachedMetadata, error)

+ ChildrenMessageIDs func(messageID hornet.MessageID, iteratorOptions ...storage.IteratorOption) (hornet.MessageIDs, error)

+ type ConcurrentParentsTraverser struct

+ func NewConcurrentParentsTraverser(parentsTraverserStorage ParentsTraverserStorage, parallelism ...int) *ConcurrentParentsTraverser

+ func (t *ConcurrentParentsTraverser) Traverse(ctx context.Context, parents hornet.MessageIDs, condition Predicate, ...) error

+ type MemcachedChildrenTraverserStorage struct

+ func NewMemcachedChildrenTraverserStorage(childrenTraverserStorage ChildrenTraverserStorage, ...) *MemcachedChildrenTraverserStorage

+ func (m *MemcachedChildrenTraverserStorage) CachedMessageMetadata(messageID hornet.MessageID) (*storage.CachedMetadata, error)

+ func (m *MemcachedChildrenTraverserStorage) ChildrenMessageIDs(messageID hornet.MessageID, iteratorOptions ...storage.IteratorOption) (hornet.MessageIDs, error)

+ func (m *MemcachedChildrenTraverserStorage) Cleanup(forceRelease bool)

+ type MemcachedParentsTraverserStorage struct

+ func NewMemcachedParentsTraverserStorage(parentsTraverserStorage ParentsTraverserStorage, ...) *MemcachedParentsTraverserStorage

+ func (m *MemcachedParentsTraverserStorage) CachedMessageMetadata(messageID hornet.MessageID) (*storage.CachedMetadata, error)

+ func (m *MemcachedParentsTraverserStorage) Cleanup(forceRelease bool)

+ func (m *MemcachedParentsTraverserStorage) SolidEntryPointsContain(messageID hornet.MessageID) (bool, error)

+ func (m *MemcachedParentsTraverserStorage) SolidEntryPointsIndex(messageID hornet.MessageID) (milestone.Index, bool, error)

+ type MemcachedTraverserStorage struct

+ func NewMemcachedTraverserStorage(traverserStorage TraverserStorage, metadataMemcache *storage.MetadataMemcache) *MemcachedTraverserStorage

+ func (m *MemcachedTraverserStorage) CachedMessageMetadata(messageID hornet.MessageID) (*storage.CachedMetadata, error)

+ func (m *MemcachedTraverserStorage) ChildrenMessageIDs(messageID hornet.MessageID, iteratorOptions ...storage.IteratorOption) (hornet.MessageIDs, error)

+ func (m *MemcachedTraverserStorage) Cleanup(forceRelease bool)

+ func (m *MemcachedTraverserStorage) SolidEntryPointsContain(messageID hornet.MessageID) (bool, error)

+ func (m *MemcachedTraverserStorage) SolidEntryPointsIndex(messageID hornet.MessageID) (milestone.Index, bool, error)

+ type OnMissingParent func(parentMessageID hornet.MessageID) error

+ type ParentsTraverser struct

+ func NewParentsTraverser(parentsTraverserStorage ParentsTraverserStorage) *ParentsTraverser

+ func (t *ParentsTraverser) Traverse(ctx context.Context, parents hornet.MessageIDs, condition Predicate, ...) error

+ type ParentsTraverserInterface interface

+ Traverse func(ctx context.Context, parents hornet.MessageIDs, condition Predicate, ...) error

+ type ParentsTraverserStorage interface

+ CachedMessageMetadata func(messageID hornet.MessageID) (*storage.CachedMetadata, error)

+ SolidEntryPointsContain func(messageID hornet.MessageID) (bool, error)

+ SolidEntryPointsIndex func(messageID hornet.MessageID) (milestone.Index, bool, error)

+ type TraverserStorage interface

Aug 4, 2023

Changes in this version

+ var ErrFindAllTailsFailed = errors.New("Unable to find all tails")

+ func FindAllTails(startTxHash hornet.Hash, skipStartTx bool) (map[string]struct{}, error)

+ func GetTransactionRootSnapshotIndexes(cachedTxMeta *tangle.CachedMetadata, lsmi milestone.Index) (youngestTxRootSnapshotIndex milestone.Index, ...)

+ func TraverseApprovees(startTxHash hornet.Hash, condition Predicate, consumer Consumer, ...) error

+ func TraverseApproveesTrunkBranch(trunkTxHash hornet.Hash, branchTxHash hornet.Hash, condition Predicate, ...) error

+ func TraverseApprovers(startTxHash hornet.Hash, condition Predicate, consumer Consumer, ...) error

+ func UpdateOutdatedRootSnapshotIndexes(outdatedTransactions hornet.Hashes, lsmi milestone.Index)

+ func UpdateTransactionRootSnapshotIndexes(txHashes hornet.Hashes, lsmi milestone.Index)

+ type ApproveesTraverser struct

+ func NewApproveesTraverser(condition Predicate, consumer Consumer, onMissingApprovee OnMissingApprovee, ...) *ApproveesTraverser

+ func (t *ApproveesTraverser) Traverse(startTxHash hornet.Hash, traverseSolidEntryPoints bool, traverseTailsOnly bool) error

+ func (t *ApproveesTraverser) TraverseTrunkAndBranch(trunkTxHash hornet.Hash, branchTxHash hornet.Hash, ...) error

+ type ApproversTraverser struct

+ func NewApproversTraverser(condition Predicate, consumer Consumer, walkAlreadyDiscovered bool, ...) *ApproversTraverser

+ func (t *ApproversTraverser) Traverse(startTxHash hornet.Hash) error

+ type Consumer func(cachedTxMeta *tangle.CachedMetadata) error

+ type OnMissingApprovee func(approveeHash hornet.Hash) error

+ type OnSolidEntryPoint func(txHash hornet.Hash)

+ type Predicate func(cachedTxMeta *tangle.CachedMetadata) (bool, error)