Skip to content
Merged
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
8 changes: 8 additions & 0 deletions block/public.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,14 @@ func DefaultBlockOptions() BlockOptions {
return common.DefaultBlockOptions()
}

// SetMaxBlobSize overrides the per-blob byte cap used by the executor
// and DA submitter when sizing batches and validating individual blobs.
// Intended for one-shot startup wiring (e.g. to lift Celestia's 5 MiB
// default to Fibre's 120 MiB headroom).
func SetMaxBlobSize(n uint64) {
common.DefaultMaxBlobSize = n
}

// Expose Metrics for constructor
type Metrics = common.Metrics

Expand Down
6 changes: 6 additions & 0 deletions go.work
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
go 1.25.7

use (
.
./core
)
637 changes: 637 additions & 0 deletions go.work.sum

Large diffs are not rendered by default.

27 changes: 27 additions & 0 deletions pkg/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -343,6 +343,33 @@ func (d *DAConfig) IsFiberEnabled() bool {
return d.Fiber.Enabled
}

// ApplyFiberDefaults flips the DA client to Fiber-friendly defaults
// when the Fiber profile is enabled — adaptive batching, a 1 s
// DA.BlockTime so inclusion-tracking keeps pace with Fibre's
// settlement, and a bounded pending-cache window so a Fibre stall
// can't grow memory unbounded. Caller-provided non-zero values for
// the tunables (BatchSizeThreshold, BatchMinItems) are preserved.
//
// Intended to be invoked once at runner startup, after parsing the
// usual config but before constructing the DA client.
func (c *Config) ApplyFiberDefaults() {
if !c.DA.IsFiberEnabled() {
return
}

c.DA.BatchingStrategy = "adaptive"
if c.DA.BatchSizeThreshold <= 0 || c.DA.BatchSizeThreshold > 1 {
c.DA.BatchSizeThreshold = 0.5
}
c.DA.BatchMaxDelay = DurationWrapper{Duration: 8 * time.Second}
if c.DA.BatchMinItems == 0 {
c.DA.BatchMinItems = 1
}

c.DA.BlockTime = DurationWrapper{Duration: 1 * time.Second}
c.Node.MaxPendingHeadersAndData = 50
}

// GetNamespace returns the namespace for header submissions.
func (d *DAConfig) GetNamespace() string {
return d.Namespace
Expand Down
Loading
Loading