protoio

type Iterator ¶

type Iterator[T proto.Message] struct {
	Item T
	// contains filtered or unexported fields
}

func NewIterator[T proto.Message](reader *Reader, newItem func() T) *Iterator[T]

func (i *Iterator[T]) Next() error

type RandomAccessReader ¶

type RandomAccessReader interface {
	ReadAt(entry proto.Message, offset int64) (int, error)
}

RandomAccessReader is an interface for reading protobuf messages from a seekable source.

type Reader ¶

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

func NewReader(source io.ReaderAt) *Reader

func (r *Reader) Offset() int64

func (r *Reader) ReadAt(msg proto.Message, offset int64) (int, error)

func (r *Reader) ReadNext(msg proto.Message) (int, error)

func (r *Reader) Skip() error

func (r *Reader) SkipN(n int) error

type SequentialReader ¶

type SequentialReader interface {
	ReadNext(entry proto.Message) (int, error)
	SkipN(n int) error
	Skip() error
	Offset() int64
}

SequentialReader is an interface for reading protobuf messages sequentially from a source that does not support seeking.

type SequentialWriter ¶

type SequentialWriter interface {
	Append(entry proto.Message) (int, error)
	Offset() int64
}

SequentialWriter is an interface for writing protobuf messages to a sequential source. The offset of the next write can be queried with the Offset method.

type Writer ¶

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

func NewWriter(file io.Writer) *Writer

func (w *Writer) Append(entry proto.Message) (int, error)

func (w *Writer) Offset() int64