record

Documentation

Index

• type BaseReader
  • func (reader *BaseReader) NextChunk(expectNum int) error
  • func (reader *BaseReader) ReadRecord() ([]byte, error)
  • func (reader *BaseReader) Recover() error
• type BaseWriter

Types

type BaseReader

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

func (*BaseReader) NextChunk

func (reader *BaseReader) NextChunk(expectNum int) error

expectNum为期望这个chunk的内容大小，expectNum>=blockSize表示尽可能多的读取（在读取full和mid时候）

func (*BaseReader) ReadRecord

func (reader *BaseReader) ReadRecord() ([]byte, error)

func (*BaseReader) Recover

func (reader *BaseReader) Recover() error

type BaseWriter

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

BaseWriter 最基础的记录写入工具