commit

package

v0.4.3 Latest Latest Go to latest Published: Aug 11, 2016 License: Apache-2.0 Imports: 19 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/anacrolix/dgraph

Links

Open Source Insights

Documentation ¶

Overview ¶

commit package provides commit logs for storing mutations, as they arrive at the server. Mutations also get stored in memory within posting.List. So, commit logs are useful to handle machine crashes, and re-init of a posting list. This package provides functionality to write to a rotating log, and a way to quickly filter relevant entries corresponding to an attribute.

Index ¶

Variables
func FillCache(c *Cache, path string) error
type ByTimestamp
type Cache
type CurFile
- func (c *CurFile) Size() int64
type Header
type LogIterator
type Logger
- func NewLogger(dir string, fileprefix string, maxSize int64) *Logger
type Reader
- func NewReader(c *Cache) *Reader
- func (r *Reader) Discard(n int)
- func (r *Reader) Read(p []byte) (n int, err error)

Constants ¶

This section is empty.

Variables ¶

View Source

var E_READ = errors.New("Unable to read")

View Source

var E_WRITE = errors.New("Unable to write")

Functions ¶

func FillCache ¶

func FillCache(c *Cache, path string) error

Types ¶

type ByTimestamp ¶

type ByTimestamp []*logFile

func (ByTimestamp) Len ¶

func (b ByTimestamp) Len() int

func (ByTimestamp) Less ¶

func (b ByTimestamp) Less(i, j int) bool

func (ByTimestamp) Swap ¶

func (b ByTimestamp) Swap(i, j int)

type Cache ¶

type Cache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Cache) LastAccessedInSeconds ¶

func (c *Cache) LastAccessedInSeconds() int64

func (*Cache) Present ¶

func (c *Cache) Present(hash uint32) bool

func (*Cache) ReadAt ¶

func (c *Cache) ReadAt(pos int, p []byte) (n int, err error)

func (*Cache) Write ¶

func (c *Cache) Write(hash uint32, p []byte) (n int, err error)

type CurFile ¶

type CurFile struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*CurFile) Size ¶

func (c *CurFile) Size() int64

type Header ¶

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

type LogIterator ¶

type LogIterator func(hdr Header, record []byte)

type Logger ¶

type Logger struct {

	// Sync every N logs. A value of zero or less would mean
	// sync every append to file.
	SyncEvery int

	// Sync every d duration.
	SyncDur time.Duration

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewLogger ¶

func NewLogger(dir string, fileprefix string, maxSize int64) *Logger

func (*Logger) AddLog ¶

func (l *Logger) AddLog(hash uint32, value []byte) (int64, error)

func (*Logger) Close ¶

func (l *Logger) Close()

func (*Logger) DeleteCacheOlderThan ¶

func (l *Logger) DeleteCacheOlderThan(v time.Duration)

func (*Logger) Init ¶

func (l *Logger) Init()

func (*Logger) StreamEntries ¶

func (l *Logger) StreamEntries(afterTs int64, hash uint32,
	iter LogIterator) error

type Reader ¶

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

Reader isn't thread-safe. But multiple readers can be used to read the same cache.

func NewReader ¶

func NewReader(c *Cache) *Reader

func (*Reader) Discard ¶

func (r *Reader) Discard(n int)

func (*Reader) Read ¶

func (r *Reader) Read(p []byte) (n int, err error)

Source Files ¶

View all Source files

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