entry

Documentation

Index

• type Entry
  • func MockEntry() *Entry
  • func MockEntryWithPayload(payload []byte) *Entry
  • func NewEmptyEntry() *Entry
  • func NewEndEntry() *Entry
  • func NewEntry(e entry.Entry) *Entry
  • func (e *Entry) DoneWithErr(err error)
  • func (e *Entry) GetSize() int
  • func (e *Entry) IsEnd() bool
  • func (e *Entry) ReadAt(r *os.File, offset int) (int, error)
  • func (e *Entry) ReadFrom(r io.Reader) (n int64, err error)
  • func (e *Entry) SetInfo()
  • func (e *Entry) UnmarshalBinary(buf []byte) (n int64, err error)
  • func (e *Entry) WaitDone() error
  • func (e *Entry) WriteTo(w io.Writer) (int64, error)

Types

type Entry

type Entry struct {
	Entry entry.Entry
	Info  *entry.Info //for wal in post append
	Lsn   uint64
	Ctx   any //for addr in batchstore
	// contains filtered or unexported fields
}

func MockEntry

func MockEntry() *Entry

func MockEntryWithPayload

func MockEntryWithPayload(payload []byte) *Entry

func NewEmptyEntry

func NewEmptyEntry() *Entry

func NewEndEntry

func NewEndEntry() *Entry

func NewEntry

func NewEntry(e entry.Entry) *Entry

func (*Entry) DoneWithErr

func (e *Entry) DoneWithErr(err error)

func (*Entry) GetSize

func (e *Entry) GetSize() int

func (*Entry) IsEnd

func (e *Entry) IsEnd() bool

func (*Entry) ReadAt

func (e *Entry) ReadAt(r *os.File, offset int) (int, error)

func (*Entry) ReadFrom

func (e *Entry) ReadFrom(r io.Reader) (n int64, err error)

func (*Entry) SetInfo

func (e *Entry) SetInfo()

func (*Entry) UnmarshalBinary

func (e *Entry) UnmarshalBinary(buf []byte) (n int64, err error)

func (*Entry) WaitDone

func (e *Entry) WaitDone() error

func (*Entry) WriteTo

func (e *Entry) WriteTo(w io.Writer) (int64, error)