feeder

Documentation

Index

• type Feeder
  • func FromWAL(reader WALReader) *Feeder
  • func (f *Feeder) Update() (*ledger.TrieUpdate, error)
• type WALReader

Types

type Feeder

type Feeder struct {
	// contains filtered or unexported fields
}

Feeder is a component that retrieves trie updates and feeds them to its consumer.

func FromWAL

func FromWAL(reader WALReader) *Feeder

FromWAL creates a trie update feeder that sources state deltas from a WAL reader.

func (*Feeder) Update

func (f *Feeder) Update() (*ledger.TrieUpdate, error)

Update returns the next trie update.

type WALReader

type WALReader interface {
	Next() bool
	Err() error
	Record() []byte
}

WALReader represents something that can read write-ahead log records.