Commit cfd03b28 authored by pengin7384's avatar pengin7384

fix: typo

Rename 'ResetableStage' to 'ResettableStage'
parent b7fd37ee
...@@ -39,7 +39,7 @@ type ChannelBank struct { ...@@ -39,7 +39,7 @@ type ChannelBank struct {
fetcher L1Fetcher fetcher L1Fetcher
} }
var _ ResetableStage = (*ChannelBank)(nil) var _ ResettableStage = (*ChannelBank)(nil)
// NewChannelBank creates a ChannelBank, which should be Reset(origin) before use. // NewChannelBank creates a ChannelBank, which should be Reset(origin) before use.
func NewChannelBank(log log.Logger, cfg *rollup.Config, prev NextFrameProvider, fetcher L1Fetcher) *ChannelBank { func NewChannelBank(log log.Logger, cfg *rollup.Config, prev NextFrameProvider, fetcher L1Fetcher) *ChannelBank {
......
...@@ -24,7 +24,7 @@ type ChannelInReader struct { ...@@ -24,7 +24,7 @@ type ChannelInReader struct {
metrics Metrics metrics Metrics
} }
var _ ResetableStage = (*ChannelInReader)(nil) var _ ResettableStage = (*ChannelInReader)(nil)
// NewChannelInReader creates a ChannelInReader, which should be Reset(origin) before use. // NewChannelInReader creates a ChannelInReader, which should be Reset(origin) before use.
func NewChannelInReader(log log.Logger, prev *ChannelBank, metrics Metrics) *ChannelInReader { func NewChannelInReader(log log.Logger, prev *ChannelBank, metrics Metrics) *ChannelInReader {
......
...@@ -28,7 +28,7 @@ type L1Retrieval struct { ...@@ -28,7 +28,7 @@ type L1Retrieval struct {
datas DataIter datas DataIter
} }
var _ ResetableStage = (*L1Retrieval)(nil) var _ ResettableStage = (*L1Retrieval)(nil)
func NewL1Retrieval(log log.Logger, dataSrc DataAvailabilitySource, prev NextBlockProvider) *L1Retrieval { func NewL1Retrieval(log log.Logger, dataSrc DataAvailabilitySource, prev NextBlockProvider) *L1Retrieval {
return &L1Retrieval{ return &L1Retrieval{
......
...@@ -31,7 +31,7 @@ type L1Traversal struct { ...@@ -31,7 +31,7 @@ type L1Traversal struct {
cfg *rollup.Config cfg *rollup.Config
} }
var _ ResetableStage = (*L1Traversal)(nil) var _ ResettableStage = (*L1Traversal)(nil)
func NewL1Traversal(log log.Logger, cfg *rollup.Config, l1Blocks L1BlockRefByNumberFetcher) *L1Traversal { func NewL1Traversal(log log.Logger, cfg *rollup.Config, l1Blocks L1BlockRefByNumberFetcher) *L1Traversal {
return &L1Traversal{ return &L1Traversal{
......
...@@ -34,7 +34,7 @@ type ResettableEngineControl interface { ...@@ -34,7 +34,7 @@ type ResettableEngineControl interface {
Reset() Reset()
} }
type ResetableStage interface { type ResettableStage interface {
// Reset resets a pull stage. `base` refers to the L1 Block Reference to reset to, with corresponding configuration. // Reset resets a pull stage. `base` refers to the L1 Block Reference to reset to, with corresponding configuration.
Reset(ctx context.Context, base eth.L1BlockRef, baseCfg eth.SystemConfig) error Reset(ctx context.Context, base eth.L1BlockRef, baseCfg eth.SystemConfig) error
} }
...@@ -65,7 +65,7 @@ type DerivationPipeline struct { ...@@ -65,7 +65,7 @@ type DerivationPipeline struct {
// Index of the stage that is currently being reset. // Index of the stage that is currently being reset.
// >= len(stages) if no additional resetting is required // >= len(stages) if no additional resetting is required
resetting int resetting int
stages []ResetableStage stages []ResettableStage
// Special stages to keep track of // Special stages to keep track of
traversal *L1Traversal traversal *L1Traversal
...@@ -94,7 +94,7 @@ func NewDerivationPipeline(log log.Logger, cfg *rollup.Config, l1Fetcher L1Fetch ...@@ -94,7 +94,7 @@ func NewDerivationPipeline(log log.Logger, cfg *rollup.Config, l1Fetcher L1Fetch
// Reset from engine queue then up from L1 Traversal. The stages do not talk to each other during // Reset from engine queue then up from L1 Traversal. The stages do not talk to each other during
// the reset, but after the engine queue, this is the order in which the stages could talk to each other. // the reset, but after the engine queue, this is the order in which the stages could talk to each other.
// Note: The engine queue stage is the only reset that can fail. // Note: The engine queue stage is the only reset that can fail.
stages := []ResetableStage{eng, l1Traversal, l1Src, frameQueue, bank, chInReader, batchQueue, attributesQueue} stages := []ResettableStage{eng, l1Traversal, l1Src, frameQueue, bank, chInReader, batchQueue, attributesQueue}
return &DerivationPipeline{ return &DerivationPipeline{
log: log, log: log,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment