diff --git a/internal/etl/registry/block.go b/internal/etl/registry/block.go index d696d530..7d430da1 100644 --- a/internal/etl/registry/block.go +++ b/internal/etl/registry/block.go @@ -19,7 +19,7 @@ const ( notFoundMsg = "not found" ) -type BlockTraversal struct { +type HeaderTraversal struct { n core.Network cUUID core.CUUID pUUID core.PUUID @@ -31,7 +31,7 @@ type BlockTraversal struct { stats metrics.Metricer } -func NewBlockTraversal(ctx context.Context, cfg *core.ClientConfig, +func NewHeaderTraversal(ctx context.Context, cfg *core.ClientConfig, opts ...component.Option) (component.Component, error) { clients, err := client.FromContext(ctx) if err != nil { @@ -56,7 +56,7 @@ func NewBlockTraversal(ctx context.Context, cfg *core.ClientConfig, // TODO - Support network confirmation counts ht := ix_node.NewHeaderTraversal(node, startHeader, big.NewInt(0)) - bt := &BlockTraversal{ + bt := &HeaderTraversal{ n: cfg.Network, client: node, traversal: ht, @@ -73,11 +73,11 @@ func NewBlockTraversal(ctx context.Context, cfg *core.ClientConfig, return reader, nil } -func (bt *BlockTraversal) Height() (*big.Int, error) { +func (bt *HeaderTraversal) Height() (*big.Int, error) { return bt.traversal.LastHeader().Number, nil } -func (bt *BlockTraversal) Backfill(start, end *big.Int, consumer chan core.TransitData) error { +func (bt *HeaderTraversal) Backfill(start, end *big.Int, consumer chan core.TransitData) error { for i := start; i.Cmp(end) < 0; i.Add(i, big.NewInt(batchSize)) { end := big.NewInt(0).Add(i, big.NewInt(batchSize)) @@ -99,7 +99,7 @@ func (bt *BlockTraversal) Backfill(start, end *big.Int, consumer chan core.Trans } // Loop ... -func (bt *BlockTraversal) Loop(ctx context.Context, consumer chan core.TransitData) error { +func (bt *HeaderTraversal) Loop(ctx context.Context, consumer chan core.TransitData) error { ticker := time.NewTicker(1 * time.Second) recent, err := bt.client.BlockHeaderByNumber(nil) diff --git a/internal/etl/registry/registry.go b/internal/etl/registry/registry.go index 100f8899..7f31a0b8 100644 --- a/internal/etl/registry/registry.go +++ b/internal/etl/registry/registry.go @@ -29,7 +29,7 @@ func NewRegistry() Registry { Addressing: false, DataType: core.BlockHeader, ComponentType: core.Reader, - Constructor: NewBlockTraversal, + Constructor: NewHeaderTraversal, Dependencies: noDeps(), Sk: noState(),