bufrecord

Documentation

Index

• type BufferedRecordReader
  • func NewBufferedRecordReader(stream io.ReadCloser, fixedLen int, hasVarFields bool, totalRecords int64) *BufferedRecordReader
  • func (r *BufferedRecordReader) Close() error
  • func (r *BufferedRecordReader) NextRecord() bool

Types

type BufferedRecordReader

type BufferedRecordReader struct {
	RecordBuffer []byte
	Err          error

	FixedLen     int
	HasVarFields bool
	// contains filtered or unexported fields
}

func NewBufferedRecordReader

func NewBufferedRecordReader(stream io.ReadCloser, fixedLen int, hasVarFields bool, totalRecords int64) *BufferedRecordReader

func (*BufferedRecordReader) Close

func (r *BufferedRecordReader) Close() error

func (*BufferedRecordReader) NextRecord

func (r *BufferedRecordReader) NextRecord() bool