Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClockDistributor ¶
type ClockDistributor struct {
// contains filtered or unexported fields
}
func NewClockDistributor ¶
func NewClockDistributor( execOuts map[string]execout.FileReader, startBlock uint64, stopBlock uint64, outputModuleInputs []*pbsubstreams.Module_Input, moduleBlockIndexes map[string]*index.BlockIndex, ) *ClockDistributor
func (*ClockDistributor) Iter ¶
func (cd *ClockDistributor) Iter(ctx context.Context) iter.Seq2[*pbsubstreams.Clock, error]
Iter returns an iterator that yields clocks from the distributor. This allows using range loops: for clock, err := range distributor.Iter(ctx) { ... }
func (*ClockDistributor) Next ¶
func (cd *ClockDistributor) Next(ctx context.Context) (*pbsubstreams.Clock, error)
Source Files
Click to show internal directories.
Click to hide internal directories.