diff --git a/core/execution/execution.go b/core/execution/execution.go index f3ebe1da91..78ecf374f8 100644 --- a/core/execution/execution.go +++ b/core/execution/execution.go @@ -97,7 +97,7 @@ type Executor interface { // // The function marks transaction with a filter status. The sequencer knows how to proceed with it: // - Transactions passing all filters constraints and that can be included (FilterOK) - // - Invalid/unparseable force-included transactions (gibberish) (FilterRemove) + // - Invalid/unparsable force-included transactions (gibberish) (FilterRemove) // - Any transactions that would exceed the cumulative gas limit (FilterPostpone) // // For non-gas-based execution layers (maxGas=0) should not filter by gas. @@ -107,7 +107,7 @@ type Executor interface { // - txs: All transactions (force-included + mempool) // - maxBytes: Maximum cumulative size allowed (0 means no size limit) // - maxGas: Maximum cumulative gas allowed (0 means no gas limit) - // - hasForceIncludedTransaction: Boolean wether force included txs are present + // - hasForceIncludedTransaction: Boolean whether force included txs are present // // Returns: // - result: The filter status of all txs. The len(txs) == len(result). diff --git a/pkg/raft/node.go b/pkg/raft/node.go index b22ce92bed..de0c4b5292 100644 --- a/pkg/raft/node.go +++ b/pkg/raft/node.go @@ -153,7 +153,7 @@ func (n *Node) Start(_ context.Context) error { return nil } - n.logger.Info().Msg("Boostrap raft cluster") + n.logger.Info().Msg("Bootstrap raft cluster") thisNode := raft.Server{ID: raft.ServerID(n.config.NodeID), Address: raft.ServerAddress(n.config.RaftAddr)} cfg := raft.Configuration{ Servers: []raft.Server{ diff --git a/pkg/store/store_adapter.go b/pkg/store/store_adapter.go index 5b21ce1613..8b5fc7e182 100644 --- a/pkg/store/store_adapter.go +++ b/pkg/store/store_adapter.go @@ -434,7 +434,7 @@ func (a *StoreAdapter[H]) Tail(ctx context.Context) (H, error) { } } - // shoud never happen + // should never happen return zero, header.ErrEmptyStore } diff --git a/test/e2e/benchmark/config.go b/test/e2e/benchmark/config.go index e568068bfa..e860df2eed 100644 --- a/test/e2e/benchmark/config.go +++ b/test/e2e/benchmark/config.go @@ -74,7 +74,7 @@ func envOrDefault(key, fallback string) string { } // envInt returns the integer value of the given env var, or fallback if unset -// or unparseable. Invalid values silently fall back to the default. +// or unparsable. Invalid values silently fall back to the default. func envInt(key string, fallback int) int { v := os.Getenv(key) if v == "" { @@ -88,7 +88,7 @@ func envInt(key string, fallback int) int { } // envDuration returns the duration value of the given env var (e.g. "5m", "30s"), -// or fallback if unset or unparseable. +// or fallback if unset or unparsable. func envDuration(key string, fallback time.Duration) time.Duration { v := os.Getenv(key) if v == "" { diff --git a/test/e2e/failover_e2e_test.go b/test/e2e/failover_e2e_test.go index 2fc84e1b34..ed3656b133 100644 --- a/test/e2e/failover_e2e_test.go +++ b/test/e2e/failover_e2e_test.go @@ -792,7 +792,7 @@ func setupRaftSequencerNode( "--evnode.raft.peers="+strings.Join(raftPeers, ","), "--evnode.raft.snap_count=10", "--evnode.raft.send_timeout=100ms", - "--evnode.raft.leader_lease_timeout=500ms", // 5x heatbeat interval (we use block time) + "--evnode.raft.leader_lease_timeout=500ms", // 5x heartbeat interval (we use block time) "--evnode.raft.heartbeat_timeout=1000ms", // 2x lease timeout "--rollkit.p2p.peers", p2pPeers, diff --git a/tools/local-da/rpc.go b/tools/local-da/rpc.go index 024910c6bd..9d13294364 100644 --- a/tools/local-da/rpc.go +++ b/tools/local-da/rpc.go @@ -164,7 +164,6 @@ func (s *blobServer) Subscribe(ctx context.Context, namespace libshare.Namespace return out, nil } -// startBlobServer starts an HTTP JSON-RPC server on addr serving the blob namespace. // headerServer exposes a minimal Celestia-like header RPC surface backed by LocalDA. type headerServer struct { da *LocalDA