posting

package

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

Index ¶

Constants
Variables
func CheckMemoryUsage(ps1, ps2 *store.Store)
func Init(log *commit.Logger)
func Key(uid uint64, attr string) []byte
func MergeLists(numRoutines int)
func NewCounters() *counters
type ByUid
type List
- func GetOrCreate(key []byte, pstore *store.Store) *List
- func NewList() *List
type ListOptions
type MutationLink

Constants ¶

View Source

const Del = 0x02

View Source

const Set = 0x01

Variables ¶

View Source

var E_TMP_ERROR = fmt.Errorf("Temporary Error. Please retry.")

View Source

var MIB, MAX_MEMORY uint64

Functions ¶

func CheckMemoryUsage ¶ added in v0.4.3

func CheckMemoryUsage(ps1, ps2 *store.Store)

func Init ¶

func Init(log *commit.Logger)

func Key ¶

func Key(uid uint64, attr string) []byte

key = (entity uid, attribute)

func MergeLists ¶

func MergeLists(numRoutines int)

func NewCounters ¶

func NewCounters() *counters

Types ¶

type ByUid ¶

type ByUid []*types.Posting

func (ByUid) Len ¶

func (pa ByUid) Len() int

func (ByUid) Less ¶

func (pa ByUid) Less(i, j int) bool

func (ByUid) Swap ¶

func (pa ByUid) Swap(i, j int)

type List ¶

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

func GetOrCreate ¶

func GetOrCreate(key []byte, pstore *store.Store) *List

func NewList ¶

func NewList() *List

func (*List) AddMutation ¶

func (l *List) AddMutation(ctx context.Context, t x.DirectedEdge, op byte) error

In benchmarks, the time taken per AddMutation before was plateauing at 2.5 ms with sync per 10 log entries, and increasing for sync per 100 log entries (to 3 ms per AddMutation), largely because of how index generation was being done.

With this change, the benchmarks perform as good as benchmarks for commit.Logger, where the less frequently file sync happens, the faster AddMutations run.

PASS BenchmarkAddMutations_SyncEveryLogEntry-6 100 24712455 ns/op BenchmarkAddMutations_SyncEvery10LogEntry-6 500 2485961 ns/op BenchmarkAddMutations_SyncEvery100LogEntry-6 10000 298352 ns/op BenchmarkAddMutations_SyncEvery1000LogEntry-6 30000 63544 ns/op ok github.com/dgraph-io/dgraph/posting 10.291s

func (*List) Get ¶

func (l *List) Get(p *types.Posting, i int) bool

func (*List) LastCompactionTs ¶

func (l *List) LastCompactionTs() time.Time

func (*List) Length ¶

func (l *List) Length() int

func (*List) MergeIfDirty ¶

func (l *List) MergeIfDirty(ctx context.Context) (merged bool, err error)

func (*List) SetForDeletion ¶

func (l *List) SetForDeletion()

func (*List) Uids ¶ added in v0.4.3

func (l *List) Uids(opt ListOptions) []uint64

func (*List) Value ¶

func (l *List) Value() (result []byte, rerr error)

type ListOptions ¶ added in v0.4.3

type ListOptions struct {
	Offset   int
	Count    int
	AfterUid uint64
}

type MutationLink ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
types

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