Versions in this module Expand all Collapse all v0 v0.2.0 May 29, 2025 Changes in this version + func Entries[T any](bundles iter.Seq2[Bundle, error], bundleFn func([]byte) ([]T, error)) iter.Seq2[Entry[T], error] + func EntryBundles(ctx context.Context, numWorkers uint, getSize GetTreeSizeFn, ...) iter.Seq2[Bundle, error] + type Bundle struct + Data []byte + RangeInfo layout.RangeInfo + type Entry struct + Entry T + Index uint64 + type Follower interface + EntriesProcessed func(context.Context) (uint64, error) + Follow func(context.Context, Streamer) + Name func() string + type GetBundleFn func(ctx context.Context, bundleIdx uint64, partial uint8) ([]byte, error) + type GetTreeSizeFn func(ctx context.Context) (uint64, error) + type Streamer interface + IntegratedSize func(ctx context.Context) (uint64, error) + StreamEntries func(ctx context.Context, startEntryIdx, N uint64) iter.Seq2[Bundle, error]
Go to main page