posting

Feb 22, 2017

Changes in this version

+ func TypeID(edge *task.DirectedEdge) types.TypeID

type List

+ func (l *List) Facets(param *facets.Param) (fs []*facets.Facet, ferr error)

+ func (l *List) FacetsForUids(opt ListOptions, param *facets.Param) []*facets.Facets

type ListOptions

+ ExcludeSet map[uint64]struct{}

Jan 27, 2017

Changes in this version

+ func DateIndex(val time.Time) ([]string, error)

+ func DefaultIndexKeys(val string) ([]string, error)

+ func FloatIndex(val float64) ([]string, error)

+ func IntIndex(val int32) ([]string, error)

+ func RebuildIndex(ctx context.Context, attr string) error

+ func SyncMarkFor(group uint32) *x.WaterMark

+ func TimeIndex(val time.Time) ([]string, error)

type List

+ func (l *List) SyncIfDirty(ctx context.Context) (committed bool, err error)

Dec 26, 2016

Changes in this version

+ func IndexTokens(attr string, src types.Val) ([]string, error)

+ func WaterMarkFor(group uint32) *x.WaterMark

type TokensTable

+ func (t *TokensTable) GetLast() string

+ func (t *TokensTable) GetNextOrEqual(s string) string

+ func (t *TokensTable) GetPrev(key string) string

+ func (t *TokensTable) GetPrevOrEqual(s string) string

Dec 8, 2016

Changes in this version

+ const Add

+ var ErrNoValue = fmt.Errorf("No value found")

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

+ func CommitLists(numRoutines int)

+ func KeysForTest(attr string) []string

+ func StartCommit()

type List

+ func (l *List) AddMutationWithIndex(ctx context.Context, t *task.DirectedEdge, op uint32) error

+ func (l *List) CommitIfDirty(ctx context.Context) (committed bool, err error)

+ func (l *List) Iterate(afterUid uint64, f func(obj *types.Posting) bool)

+ func (l *List) PostingList() *types.PostingList

+ func (l *List) WaitForCommit()

type ListOptions

+ AfterUID uint64

+ Intersect *task.List

+ type TokensTable struct

+ func GetTokensTable(attr string) *TokensTable

+ func NewTokensTable() *TokensTable

+ func (t *TokensTable) Add(s string)

+ func (t *TokensTable) Get(s string) int

+ func (t *TokensTable) GetFirst() string

+ func (t *TokensTable) GetNext(key string) string

+ func (t *TokensTable) Size() int

Aug 11, 2016

Changes in this version

+ func CheckMemoryUsage(ps1, ps2 *store.Store)

type List

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

+ type ListOptions struct

+ AfterUid uint64

+ Count int

+ Offset int

Jul 11, 2016

Changes in this version

+ const Del

+ const Set

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

+ var MAX_MEMORY uint64

+ var MIB uint64

+ func Init(log *commit.Logger)

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

+ func MergeLists(numRoutines int)

+ func NewCounters() *counters

+ type ByUid []*types.Posting

+ func (pa ByUid) Len() int

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

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

+ type List struct

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

+ func NewList() *List

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

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

+ func (l *List) GetUids(offset, count int) []uint64

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

+ func (l *List) Length() int

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

+ func (l *List) SetForDeletion()

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

+ type MutationLink struct