segments

Documentation

Index

• type File
• type Segment
  • func New(file File) (*Segment, error)
  • func (s *Segment) Append(record records.Record) (int64, error)
  • func (s Segment) Offset() int64
  • func (s *Segment) Read(int64) (records.Record, error)

Types

type File

type File interface {
	fs.File
	io.Writer
}

type Segment

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

Segment is a data file

func New

func New(file File) (*Segment, error)

New segment

func (*Segment) Append

func (s *Segment) Append(record records.Record) (int64, error)

Append a record

func (Segment) Offset

func (s Segment) Offset() int64

Offset of next append

func (*Segment) Read

func (s *Segment) Read(int64) (records.Record, error)

Read a record at a given offset