wal

package

v0.0.0-...-1be9e8e Latest Latest Go to latest Published: May 13, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/danchia/ddb

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CleanUnusedFiles(dirname string, appliedUntil int64)
type Options
type Scanner
- func NewScanner(dirname string) (*Scanner, error)
type Writer
- func NewWriter(nextSeq int64, opts Options) (*Writer, error)
- func (w *Writer) Append(l *pb.LogRecord, cb func(error))
- func (w *Writer) Close() error

Constants ¶

View Source

const (
	// MaxRecordBytes is the largest size a single record can be.
	MaxRecordBytes uint32 = 100 * 1024 * 1024
)

Variables ¶

This section is empty.

Functions ¶

func CleanUnusedFiles ¶

func CleanUnusedFiles(dirname string, appliedUntil int64)

CleanUnusedFiles cleans unused log files, i.e those that have already been applied.

Types ¶

type Options ¶

type Options struct {
	Dirname    string
	TargetSize int64
}

type Scanner ¶

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

Scanner reads log records from a write ahead log directory. Not thread-safe.

func NewScanner ¶

func NewScanner(dirname string) (*Scanner, error)

NewScanner returns a log scanner over all the log files found in dirname. Returns ErrNotExist if there are no log files.

func (*Scanner) Err ¶

func (s *Scanner) Err() error

Err returns last error, if any.

func (*Scanner) Record ¶

func (s *Scanner) Record() *pb.LogRecord

Record returns the current record. Only valid until the next Scan() call. Caller should not modify returned proto.

func (*Scanner) Scan ¶

func (s *Scanner) Scan() bool

Scan advances the fileScanner to the next log record, which will then be available through the Record method. It returns false when the scan stops, either by reaching the end of all logs or on error.

type Writer ¶

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

Writer writes log entries to the write ahead log. Thread-safe.

func NewWriter ¶

func NewWriter(nextSeq int64, opts Options) (*Writer, error)

func (*Writer) Append ¶

func (w *Writer) Append(l *pb.LogRecord, cb func(error))

Append appends a log record to the WAL. The log record is modified with the log sequence number. cb is invoked serially, in log sequence number order.

func (*Writer) Close ¶

func (w *Writer) Close() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL