Internal

Documentation

Index

• func TestIndex(t *testing.T)
• func TestStoreAppendRead(t *testing.T)
• func TestStoreClose(t *testing.T)
• type Config
• type Log
  • func NewLog(dir string, c Config) (*Log, error)
  • func (l *Log) Append(record *api.Record) (uint64, error)
  • func (l *Log) Close() error
  • func (l *Log) HighestOffset() (uint64, error)
  • func (l *Log) LowestOffset() (uint64, error)
  • func (l *Log) Read(off uint64) (*api.Record, error)
  • func (l *Log) Reader() io.Reader
  • func (l *Log) Remove() error
  • func (l *Log) Reset() error
  • func (l *Log) Truncate(lowest uint64) error

Functions

func TestIndex

func TestIndex(t *testing.T)

func TestStoreAppendRead

func TestStoreAppendRead(t *testing.T)

func TestStoreClose

func TestStoreClose(t *testing.T)

Types

type Config

type Config struct {
	Segment struct {
		MaxStoreBytes uint64
		MaxIndexBytes uint64
		InitialOffset uint64
	}
}

type Log

type Log struct {
	Dir    string
	Config Config
	// contains filtered or unexported fields
}

func NewLog

func NewLog(dir string, c Config) (*Log, error)

START: newlog

func (*Log) Append

func (l *Log) Append(record *api.Record) (uint64, error)

START: append

func (*Log) Close

func (l *Log) Close() error

START: close

func (*Log) HighestOffset

func (l *Log) HighestOffset() (uint64, error)

func (*Log) LowestOffset

func (l *Log) LowestOffset() (uint64, error)

START: offsets

func (*Log) Read

func (l *Log) Read(off uint64) (*api.Record, error)

START: read

func (*Log) Reader

func (l *Log) Reader() io.Reader

START: reader

func (*Log) Remove

func (l *Log) Remove() error

func (*Log) Reset

func (l *Log) Reset() error

func (*Log) Truncate

func (l *Log) Truncate(lowest uint64) error

START: truncate