writelogger

Documentation

Overview

Package writelogger provides the writelogger structs.

Index

• type Writelogger
  • func New(dir string, log logger.Logger) *Writelogger
  • func (w *Writelogger) AppendMessage(bucket string, key string, version int, message []byte) error
  • func (w *Writelogger) DeleteLog(bucket string, key string, version int) error
  • func (w *Writelogger) DeleteTable(qtid dax.QualifiedTableID) error
  • func (w *Writelogger) List(bucket, key string) ([]computer.WriteLogInfo, error)
  • func (w *Writelogger) Lock(bucket, key string) error
  • func (w *Writelogger) LogReader(bucket, key string, version int) (io.ReadCloser, error)
  • func (w *Writelogger) LogReaderFrom(bucket string, key string, version int, offset int) (io.ReadCloser, error)
  • func (w *Writelogger) SetLogger(l logger.Logger)
  • func (w *Writelogger) Unlock(bucket, key string) error

Types

type Writelogger

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

func New

func New(dir string, log logger.Logger) *Writelogger

func (*Writelogger) AppendMessage

func (w *Writelogger) AppendMessage(bucket string, key string, version int, message []byte) error

func (*Writelogger) DeleteLog

func (w *Writelogger) DeleteLog(bucket string, key string, version int) error

func (*Writelogger) DeleteTable

func (w *Writelogger) DeleteTable(qtid dax.QualifiedTableID) error

func (*Writelogger) List

func (w *Writelogger) List(bucket, key string) ([]computer.WriteLogInfo, error)

func (*Writelogger) Lock

func (w *Writelogger) Lock(bucket, key string) error

func (*Writelogger) LogReader

func (w *Writelogger) LogReader(bucket, key string, version int) (io.ReadCloser, error)

func (*Writelogger) LogReaderFrom

func (w *Writelogger) LogReaderFrom(bucket string, key string, version int, offset int) (io.ReadCloser, error)

func (*Writelogger) SetLogger

func (w *Writelogger) SetLogger(l logger.Logger)

SetLogger sets the logger used for logging messages. Note, this is not the same "logger" that the Writelogger represents, which logs data writes.

func (*Writelogger) Unlock

func (w *Writelogger) Unlock(bucket, key string) error