ndjson

Documentation

Index

• func NewPeerRecordsIter(r io.Reader) iter.Iter[iter.Result[*types.PeerRecord]]
• func NewRecordsIter(r io.Reader) iter.Iter[iter.Result[types.Record]]

Functions

func NewPeerRecordsIter

func NewPeerRecordsIter(r io.Reader) iter.Iter[iter.Result[*types.PeerRecord]]

NewPeerRecordsIter returns an iterator that reads types.PeerRecord from the given io.Reader. Records with a different schema are safely ignored. If you want to read all records, use NewRecordsIter instead.

func NewRecordsIter

func NewRecordsIter(r io.Reader) iter.Iter[iter.Result[types.Record]]

NewRecordsIter returns an iterator that reads types.Record from the given io.Reader.