graph/db: let ForEachChannelCacheable take a reset param

This commit is contained in:
Elle Mouton committed 2025-07-15 11:25:10 +02:00
1 parent b3f3766fe6
commit 13d0bd5ef6
4 files changed
+8 -9

No files matched your search

+2 -1
View File
@@ -182,7 +182,8 @@ func (c *ChannelGraph) populateCache(ctx context.Context) error {
c.graphCache.AddChannel(info, policy1, policy2) c.graphCache.AddChannel(info, policy1, policy2)
return nil return nil
}) }, func() {},
)
if err != nil { if err != nil {
return err return err
} }
+2 -2
View File
@@ -177,8 +177,8 @@ type V1Store interface { //nolint:interfacebloat
// NOTE: this method is like ForEachChannel but fetches only the data // NOTE: this method is like ForEachChannel but fetches only the data
// required for the graph cache. // required for the graph cache.
ForEachChannelCacheable(cb func(*models.CachedEdgeInfo, ForEachChannelCacheable(cb func(*models.CachedEdgeInfo,
*models.CachedEdgePolicy, *models.CachedEdgePolicy, *models.CachedEdgePolicy) error,
*models.CachedEdgePolicy) error) error reset func()) error
// DisabledChannelIDs returns the channel ids of disabled channels. // DisabledChannelIDs returns the channel ids of disabled channels.
// A channel is disabled when two of the associated ChanelEdgePolicies // A channel is disabled when two of the associated ChanelEdgePolicies
+2 -3
View File
@@ -486,9 +486,8 @@ func forEachChannel(db kvdb.Backend, cb func(*models.ChannelEdgeInfo,
// NOTE: this method is like ForEachChannel but fetches only the data required // NOTE: this method is like ForEachChannel but fetches only the data required
// for the graph cache. // for the graph cache.
func (c *KVStore) ForEachChannelCacheable(cb func(*models.CachedEdgeInfo, func (c *KVStore) ForEachChannelCacheable(cb func(*models.CachedEdgeInfo,
*models.CachedEdgePolicy, *models.CachedEdgePolicy) error) error { *models.CachedEdgePolicy, *models.CachedEdgePolicy) error,
reset func()) error {
reset := func() {}
return c.db.View(func(tx kvdb.RTx) error { return c.db.View(func(tx kvdb.RTx) error {
edges := tx.ReadBucket(edgeBucket) edges := tx.ReadBucket(edgeBucket)
+2 -3
View File
@@ -1236,10 +1236,9 @@ func (s *SQLStore) ForEachNodeCached(ctx context.Context,
// NOTE: this method is like ForEachChannel but fetches only the data // NOTE: this method is like ForEachChannel but fetches only the data
// required for the graph cache. // required for the graph cache.
func (s *SQLStore) ForEachChannelCacheable(cb func(*models.CachedEdgeInfo, func (s *SQLStore) ForEachChannelCacheable(cb func(*models.CachedEdgeInfo,
*models.CachedEdgePolicy, *models.CachedEdgePolicy, *models.CachedEdgePolicy) error,
*models.CachedEdgePolicy) error) error { reset func()) error {
reset := func() {}
ctx := context.TODO() ctx := context.TODO()
handleChannel := func(db SQLQueries, handleChannel := func(db SQLQueries,