Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions core/execution/execution.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand All @@ -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).
Expand Down
2 changes: 1 addition & 1 deletion pkg/raft/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -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{
Expand Down
2 changes: 1 addition & 1 deletion pkg/store/store_adapter.go
Original file line number Diff line number Diff line change
Expand Up @@ -434,7 +434,7 @@ func (a *StoreAdapter[H]) Tail(ctx context.Context) (H, error) {
}
}

// shoud never happen
// should never happen
return zero, header.ErrEmptyStore
}

Expand Down
4 changes: 2 additions & 2 deletions test/e2e/benchmark/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 == "" {
Expand All @@ -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 == "" {
Expand Down
2 changes: 1 addition & 1 deletion test/e2e/failover_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
1 change: 0 additions & 1 deletion tools/local-da/rpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down