tree

Nov 6, 2025

Changes in this version

type LeafVariantSlice

+ func (lvs LeafVariantSlice) ToPathAndUpdateSlice() []*types.PathAndUpdate

Oct 28, 2025

Changes in this version

+ var ValidationError = errors.New("validation error")

Sep 25, 2025

Changes in this version

type LeafEntry

+ func (l *LeafEntry) GetUpdate() *types.Update

type LeafVariantSlice

+ func (lvs LeafVariantSlice) ToSdcpbUpdateSlice() []*sdcpb.Update

Sep 3, 2025

Changes in this version

+ func FilterDeletedNotExplicitDelete(l *LeafEntry) bool

+ type BaseVisitor struct

+ func (b *BaseVisitor) DescendMethod() DescendMethod

+ func (b *BaseVisitor) Up()

+ type BlameConfigVisitor struct

+ func NewBlameConfigVisitor(includeDefaults bool) *BlameConfigVisitor

+ func (b *BlameConfigVisitor) GetResult() *sdcpb.BlameTreeElement

+ func (b *BlameConfigVisitor) Up()

+ func (b *BlameConfigVisitor) Visit(ctx context.Context, e Entry) error

+ func (o *BlameConfigVisitor) DescendMethod() DescendMethod

+ type DeletePathPrio struct

+ func NewDeletePathPrio(owner string, prio int32) *DeletePathPrio

+ func (ddp *DeletePathPrio) DeepCopy() *DeletePathPrio

+ func (dpp *DeletePathPrio) GetOwner() string

+ func (dpp *DeletePathPrio) GetPathSet() *sdcpb.PathSet

+ func (dpp *DeletePathPrio) GetPrio() int32

+ func (dpp *DeletePathPrio) PathItems() iter.Seq[*sdcpb.Path]

+ type DeletePathSet struct

+ func NewDeletePaths() *DeletePathSet

+ func (dp *DeletePathSet) Add(intentName string, prio int32, pathset *sdcpb.PathSet)

+ func (dp *DeletePathSet) DeepCopy() *DeletePathSet

+ func (dp *DeletePathSet) GetByIntentName(intentName string) *sdcpb.PathSet

+ func (dp *DeletePathSet) Items() iter.Seq[*DeletePathPrio]

+ func (dp *DeletePathSet) RemoveIntentDeletes(intentName string) *sdcpb.PathSet

+ type DescendMethod int

+ const DescendMethodActiveChilds

+ const DescendMethodAll

type Entry

+ GetChilds func(DescendMethod) EntryMap

+ GetLeafVariantEntries func() LeafVariantEntries

+ HoldsLeafvariants func() bool

+ type EntryMap map[string]Entry

type EntryVisitor

+ DescendMethod func() DescendMethod

+ type ExplicitDeleteVisitor struct

+ func NewExplicitDeleteVisitor(owner string, priority int32) *ExplicitDeleteVisitor

+ func (edv *ExplicitDeleteVisitor) GetCreatedExplicitDeleteLeafEntries() LeafVariantSlice

+ func (edv *ExplicitDeleteVisitor) GetExplicitDeleteCreationCount() int

+ func (edv *ExplicitDeleteVisitor) Visit(ctx context.Context, e Entry) error

+ type ExplicitDeleteVisitors map[string]*ExplicitDeleteVisitor

+ func (e ExplicitDeleteVisitors) Stats() map[string]int

type LeafEntry

+ IsExplicitDelete bool

+ func (l *LeafEntry) Compare(other *LeafEntry) int

+ func (l *LeafEntry) Equal(other *LeafEntry) bool

+ func (l *LeafEntry) GetExplicitDeleteFlag() bool

+ func (l *LeafEntry) MarkExpliciteDelete()

+ type LeafVariantEntries interface

+ AddExplicitDeleteEntry func(owner string, priority int32) *LeafEntry

+ DeleteByOwner func(owner string) *LeafEntry

+ GetByOwner func(owner string) *LeafEntry

+ GetHighestPrecedence func(onlyNewOrUpdated bool, includeDefaults bool, includeExplicitDeletes bool) *LeafEntry

+ GetRunning func() *LeafEntry

+ MarkOwnerForDeletion func(owner string, onlyIntended bool) *LeafEntry

+ type LeafVariantEntry interface

+ GetEntry func() Entry

+ MarkDelete func(onlyIntended bool) *LeafEntry

+ String func() string

type LeafVariantSlice

+ func (lvs LeafVariantSlice) Equal(otherLvs LeafVariantSlice) (bool, error)

+ func (lvs LeafVariantSlice) String() string

type LeafVariants

+ func (lv *LeafVariants) AddExplicitDeleteEntry(intentName string, priority int32) *LeafEntry

+ type MarkOwnerDeleteVisitor struct

+ func NewMarkOwnerDeleteVisitor(owner string, onlyIntended bool) *MarkOwnerDeleteVisitor

+ func (o *MarkOwnerDeleteVisitor) GetHitCount() int

+ func (o *MarkOwnerDeleteVisitor) GetMatches() LeafVariantSlice

+ func (o *MarkOwnerDeleteVisitor) Visit(ctx context.Context, e Entry) error

type RootEntry

+ func (r *RootEntry) AddExplicitDeletes(intentName string, priority int32, pathset *sdcpb.PathSet)

+ func (r *RootEntry) RemoveExplicitDeletes(intentName string) *sdcpb.PathSet

+ func (s RootEntry) GetChilds(d DescendMethod) EntryMap

+ func (s RootEntry) GetLeafVariantEntries() LeafVariantEntries

+ func (s RootEntry) HoldsLeafvariants() bool

Aug 11, 2025

Changes in this version

type Entry

+ DeleteBranch func(ctx context.Context, relativePath types.PathSlice, owner string) (err error)

type EntryImpl

+ func (s EntryImpl) DeleteBranch(ctx context.Context, relativePath types.PathSlice, owner string) error

type EntryVisitor

+ Up func()

+ Visit func(ctx context.Context, s *sharedEntryAttributes) error

type RootEntry

+ func (r *RootEntry) DeleteBranchPaths(ctx context.Context, deletes types.DeleteEntriesList, intentName string) error

+ func (s RootEntry) DeleteBranch(ctx context.Context, relativePath types.PathSlice, owner string) error

Jun 26, 2025

Changes in this version

type LeafEntry

+ func (l *LeafEntry) RemoveDeleteFlag()

Jun 18, 2025

Changes in this version

type Entry

+ BlameConfig func(includeDefaults bool) (*sdcpb.BlameTreeElement, error)

type EntryImpl

+ func (s EntryImpl) BlameConfig(includeDefaults bool) (*sdcpb.BlameTreeElement, error)

type LeafVariants

+ func (lv *LeafVariants) GetRunning() *LeafEntry

type RootEntry

+ func (s RootEntry) BlameConfig(includeDefaults bool) (*sdcpb.BlameTreeElement, error)

May 9, 2025

Changes in this version

+ var ErrorIntentNotPresent = fmt.Errorf("intent not present")

+ func DefaultValueExists(schema *sdcpb.SchemaElem) bool

+ func DefaultValueRetrieve(schema *sdcpb.SchemaElem, path []string, prio int32, intent string) (*types.Update, error)

+ func HighestPrecedenceFilterAll(le *LeafEntry) bool

+ func HighestPrecedenceFilterWithoutDeleted(le *LeafEntry) bool

+ func HighestPrecedenceFilterWithoutNew(le *LeafEntry) bool

+ func LeafEntriesToUpdates(l []*LeafEntry) []*types.Update

type Entry

+ AddUpdateRecursive func(ctx context.Context, u *types.Update, flags *types.UpdateInsertFlags) (Entry, error)

+ BreadthSearch func(ctx context.Context, path string) ([]Entry, error)

+ DeepCopy func(tc *TreeContext, parent Entry) (Entry, error)

+ DeleteSubtree func(relativePath types.PathSlice, owner string) (remainsToExist bool, err error)

+ GetDeviations func(ch chan<- *types.DeviationEntry, activeCase bool)

+ GetLevel func() int

+ GetListChilds func() ([]Entry, error)

+ MarkOwnerDelete func(o string, onlyIntended bool)

+ TreeExport func(owner string) ([]*tree_persist.TreeElement, error)

type EntryImpl

+ func (s EntryImpl) AddUpdateRecursive(ctx context.Context, u *types.Update, flags *types.UpdateInsertFlags) (Entry, error)

+ func (s EntryImpl) BreadthSearch(ctx context.Context, path string) ([]Entry, error)

+ func (s EntryImpl) DeepCopy(tc *TreeContext, parent Entry) (Entry, error)

+ func (s EntryImpl) DeleteSubtree(relativePath types.PathSlice, owner string) (bool, error)

+ func (s EntryImpl) GetDeviations(ch chan<- *types.DeviationEntry, activeCase bool)

+ func (s EntryImpl) GetListChilds() ([]Entry, error)

+ func (s EntryImpl) MarkOwnerDelete(o string, onlyIntended bool)

+ func (s EntryImpl) TreeExport(owner string) ([]*tree_persist.TreeElement, error)

+ type HighestPrecedenceFilter func(le *LeafEntry) bool

type LeafEntry

+ func (l *LeafEntry) DeepCopy(parentEntry Entry) *LeafEntry

type LeafVariantSlice

+ func (lvs LeafVariantSlice) ToUpdateSlice() types.UpdateSlice

type LeafVariants

+ func (lv *LeafVariants) DeepCopy(tc *TreeContext, parent Entry) *LeafVariants

+ func (lv *LeafVariants) DeleteByOwner(owner string) (remainsToExist bool)

+ func (lv *LeafVariants) GetDeviations(ch chan<- *types.DeviationEntry, isActiveCase bool)

+ func (lv *LeafVariants) MarkOwnerForDeletion(owner string, onlyIntended bool)

type RootEntry

+ func (r *RootEntry) AddUpdatesRecursive(ctx context.Context, us types.UpdateSlice, flags *types.UpdateInsertFlags) error

+ func (r *RootEntry) DeleteSubtreePaths(deletes types.DeleteEntriesList, intentName string)

+ func (r *RootEntry) GetDeviations(ch chan<- *types.DeviationEntry)

+ func (r *RootEntry) TreeExport(owner string, priority int32) (*tree_persist.Intent, error)

+ func (s RootEntry) AddUpdateRecursive(ctx context.Context, u *types.Update, flags *types.UpdateInsertFlags) (Entry, error)

+ func (s RootEntry) BreadthSearch(ctx context.Context, path string) ([]Entry, error)

+ func (s RootEntry) DeleteSubtree(relativePath types.PathSlice, owner string) (bool, error)

+ func (s RootEntry) GetListChilds() ([]Entry, error)

+ func (s RootEntry) MarkOwnerDelete(o string, onlyIntended bool)

Feb 27, 2025

Changes in this version

+ const ReplaceIntentName

+ const ReplaceValuesPrio

+ type DeleteEntriesList []DeleteEntry

+ func (d DeleteEntriesList) PathSlices() PathSlices

type LeafEntry

+ DeleteOnlyIntended bool

+ func (l *LeafEntry) GetDeleteOnlyIntendedFlag() bool

+ func (l *LeafEntry) MarkNew()

type RootEntry

+ func (r *RootEntry) AddCacheUpdatesRecursive(ctx context.Context, us UpdateSlice, flags *UpdateInsertFlags) error

+ func (r *RootEntry) DeepCopy(ctx context.Context) (*RootEntry, error)

+ type TreeCacheClient interface

+ GetBranchesHighesPrecedence func(ctx context.Context, path []string, filters ...CacheUpdateFilter) int32

+ IntendedPathExists func(ctx context.Context, path []string) (bool, error)

+ Read func(ctx context.Context, opts *cache.Opts, paths [][]string) []*cache.Update

+ ReadCurrentUpdatesHighestPriorities func(ctx context.Context, ccp PathSlices, count uint64) UpdateSlice

+ ReadRunningFull func(ctx context.Context) ([]*cache.Update, error)

+ ReadRunningPath func(ctx context.Context, path PathSlice) (*cache.Update, error)

+ ReadUpdatesOwner func(ctx context.Context, owner string) UpdateSlice

+ RefreshCaches func(ctx context.Context) error

+ type TreeCacheClientImpl struct

+ func NewTreeCacheClient(datastore string, cc cache.Client) *TreeCacheClientImpl

+ func (c *TreeCacheClientImpl) GetBranchesHighesPrecedence(ctx context.Context, path []string, filters ...CacheUpdateFilter) int32

+ func (c *TreeCacheClientImpl) Read(ctx context.Context, opts *cache.Opts, paths [][]string) []*cache.Update

+ func (c *TreeCacheClientImpl) ReadCurrentUpdatesHighestPriorities(ctx context.Context, ccp PathSlices, count uint64) UpdateSlice

+ func (c *TreeCacheClientImpl) ReadRunningFull(ctx context.Context) ([]*cache.Update, error)

+ func (c *TreeCacheClientImpl) ReadRunningPath(ctx context.Context, path PathSlice) (*cache.Update, error)

+ func (c *TreeCacheClientImpl) ReadUpdatesOwner(ctx context.Context, owner string) UpdateSlice

+ func (c *TreeCacheClientImpl) RefreshCaches(ctx context.Context) error

+ func (t *TreeCacheClientImpl) IntendedPathExists(ctx context.Context, path []string) (bool, error)

type TreeContext

+ func (t *TreeContext) GetTreeSchemaCacheClient() TreeCacheClient

+ func (t *TreeContext) SetActualOwner(owner string)

+ type UpdateInsertFlags struct

+ func NewUpdateInsertFlags() *UpdateInsertFlags

+ func (f *UpdateInsertFlags) Apply(le *LeafEntry)

+ func (f *UpdateInsertFlags) GetDeleteFlag() bool

+ func (f *UpdateInsertFlags) GetDeleteOnlyIntendedFlag() bool

+ func (f *UpdateInsertFlags) GetNewFlag() bool

+ func (f *UpdateInsertFlags) SetDeleteFlag()

+ func (f *UpdateInsertFlags) SetDeleteOnlyUpdatedFlag()

+ func (f *UpdateInsertFlags) SetNewFlag()

type UpdateSlice

+ func (u UpdateSlice) GetFirstPriorityValue() int32

+ func (u UpdateSlice) ToPathSet() *PathSet

Jan 30, 2025

Changes in this version

+ func NewSchemaIndexEntry(schemaRsp *sdcpb.GetSchemaResponse, err error) *schemaIndexEntry

Dec 9, 2024

Changes in this version

+ type OrderingMethod uint

+ const Alphabetical

+ const None

+ const SchemaBound

Nov 29, 2024

Changes in this version

type LeafEntry

+ func (l *LeafEntry) DropDeleteFlag()

+ func (l *LeafEntry) GetDeleteFlag() bool

+ func (l *LeafEntry) GetNewFlag() bool

+ func (l *LeafEntry) GetUpdateFlag() bool

type LeafVariants

+ func (lv *LeafVariants) Add(le *LeafEntry)

Nov 15, 2024

Changes in this version

type LeafVariants

+ func (lv *LeafVariants) Append(le *LeafEntry)

+ func (lv *LeafVariants) Items() iter.Seq[*LeafEntry]

+ func (lv *LeafVariants) Length() int

Oct 30, 2024

Changes in this version

+ type DeleteEntry interface

+ Path func() PathSlice

+ SdcpbPath func() (*sdcpb.Path, error)

+ type DeleteEntryImpl struct

+ func NewDeleteEntryImpl(sdcpbPath *sdcpb.Path, pathslice PathSlice) *DeleteEntryImpl

+ func (d *DeleteEntryImpl) Path() PathSlice

+ func (d *DeleteEntryImpl) SdcpbPath() (*sdcpb.Path, error)

type Entry

+ ImportConfig func(ctx context.Context, t importer.ImportConfigAdapter, intentName string, ...) error

+ ToJson func(onlyNewOrUpdated bool) (any, error)

+ ToJsonIETF func(onlyNewOrUpdated bool) (any, error)

+ ToXML func(onlyNewOrUpdated bool, honorNamespace bool, operationWithNamespace bool, ...) (*etree.Document, error)

type EntryImpl

+ func (s EntryImpl) ImportConfig(ctx context.Context, t importer.ImportConfigAdapter, intentName string, ...) error

+ func (s EntryImpl) ToJson(onlyNewOrUpdated bool) (any, error)

+ func (s EntryImpl) ToJsonIETF(onlyNewOrUpdated bool) (any, error)

+ func (s EntryImpl) ToXML(...) (*etree.Document, error)

+ type EntrySlice []Entry

type RootEntry

+ func (r *RootEntry) ToProtoDeletes(ctx context.Context) ([]*sdcpb.Path, error)

+ func (r *RootEntry) ToProtoUpdates(ctx context.Context, onlyNewOrUpdated bool) ([]*sdcpb.Update, error)

+ func (s RootEntry) ImportConfig(ctx context.Context, t importer.ImportConfigAdapter, intentName string, ...) error

+ func (s RootEntry) ToJson(onlyNewOrUpdated bool) (any, error)

+ func (s RootEntry) ToJsonIETF(onlyNewOrUpdated bool) (any, error)

+ func (s RootEntry) ToXML(...) (*etree.Document, error)

type TreeContext

+ func (t *TreeContext) ReadRunningFull(ctx context.Context) ([]*cache.Update, error)

Sep 17, 2024

Changes in this version

type Entry

+ FilterChilds func(keys map[string]string) ([]Entry, error)

+ NavigateLeafRef func(ctx context.Context) ([]Entry, error)

type EntryImpl

+ func (s EntryImpl) FilterChilds(keys map[string]string) ([]Entry, error)

+ func (s EntryImpl) NavigateLeafRef(ctx context.Context) ([]Entry, error)

type RootEntry

+ func (s RootEntry) FilterChilds(keys map[string]string) ([]Entry, error)

+ func (s RootEntry) NavigateLeafRef(ctx context.Context) ([]Entry, error)

Sep 2, 2024

Changes in this version

+ const DefaultValuesPrio

+ const DefaultsIntentName

+ const PATHSEP

+ const RunningIntentName

+ const RunningValuesPrio

type Entry

+ GetRoot func() Entry

+ GetRootBasedEntryChain func() []Entry

+ NavigateSdcpbPath func(ctx context.Context, path []*sdcpb.PathElem, isRootPath bool) (Entry, error)

type EntryImpl

+ func (s EntryImpl) GetRoot() Entry

+ func (s EntryImpl) GetRootBasedEntryChain() []Entry

+ func (s EntryImpl) NavigateSdcpbPath(ctx context.Context, pathElems []*sdcpb.PathElem, isRootPath bool) (Entry, error)

type LeafEntry

+ func (l *LeafEntry) GetEntry() Entry

+ func (l *LeafEntry) GetRootBasedEntryChain() []Entry

+ type LeafVariantSlice []*LeafEntry

+ func (lvs LeafVariantSlice) ToCacheUpdateSlice() []*cache.Update

type RootEntry

+ func (s RootEntry) GetRoot() Entry

+ func (s RootEntry) GetRootBasedEntryChain() []Entry

+ func (s RootEntry) NavigateSdcpbPath(ctx context.Context, pathElems []*sdcpb.PathElem, isRootPath bool) (Entry, error)

type TreeContext

+ func (t *TreeContext) ReadRunningMultiple(ctx context.Context, paths [][]string) ([]*cache.Update, error)

Aug 2, 2024

Changes in this version

type PathSlice

+ func (p PathSlice) String() string

+ func (p PathSlice) ToStringSlice() []string

+ type PathSlices []PathSlice

+ func (p PathSlices) StringSlice() []string

+ func (p PathSlices) ToStringSlice() [][]string

Jun 24, 2024

Changes in this version

+ const KeysIndexSep

+ func ApplyCacheUpdateFilters(u *cache.Update, fs []CacheUpdateFilter) bool

+ func CacheUpdateFilterExcludeOwner(owner string) func(u *cache.Update) bool

+ func FilterDeleted(l *LeafEntry) bool

+ func FilterNew(l *LeafEntry) bool

+ func FilterNonDeleted(l *LeafEntry) bool

+ func FilterNonDeletedButNewOrUpdated(l *LeafEntry) bool

+ func FilterUpdated(l *LeafEntry) bool

+ func LeafEntriesToCacheUpdates(l []*LeafEntry) []*cache.Update

+ func Map[T any](u UpdateSlice, f func(*cache.Update) T) []T

+ func Unfiltered(l *LeafEntry) bool

+ type CacheUpdateFilter func(u *cache.Update) bool

+ type Entry interface

+ AddCacheUpdateRecursive func(ctx context.Context, u *cache.Update, new bool) error

+ FinishInsertionPhase func()

+ GetByOwner func(owner string, result []*LeafEntry) []*LeafEntry

+ GetDeletes func(PathSlice) PathSlice

+ GetFirstAncestorWithSchema func() (ancestor Entry, levelUp int)

+ GetHighestPrecedence func(u UpdateSlice, onlyNewOrUpdated bool) UpdateSlice

+ GetParent func() Entry

+ GetSchema func() *sdcpb.SchemaElem

+ GetSchemaKeys func() []string

+ IsRoot func() bool

+ Navigate func(ctx context.Context, path []string) (Entry, error)

+ Path func() []string

+ PathName func() string

+ SdcpbPath func() (*sdcpb.Path, error)

+ SdcpbPathInternal func(spath []string) (*sdcpb.Path, error)

+ StringIndent func(result []string) []string

+ Validate func(errchan chan<- error)

+ Walk func(f EntryVisitor) error

+ type EntryImpl struct

+ func (s EntryImpl) AddCacheUpdateRecursive(ctx context.Context, c *cache.Update, new bool) error

+ func (s EntryImpl) FinishInsertionPhase()

+ func (s EntryImpl) GetByOwner(owner string, result []*LeafEntry) []*LeafEntry

+ func (s EntryImpl) GetDeletes(deletes PathSlice) PathSlice

+ func (s EntryImpl) GetFirstAncestorWithSchema() (Entry, int)

+ func (s EntryImpl) GetHighestPrecedence(result UpdateSlice, onlyNewOrUpdated bool) UpdateSlice

+ func (s EntryImpl) GetLevel() int

+ func (s EntryImpl) GetParent() Entry

+ func (s EntryImpl) GetSchema() *sdcpb.SchemaElem

+ func (s EntryImpl) GetSchemaKeys() []string

+ func (s EntryImpl) IsRoot() bool

+ func (s EntryImpl) Navigate(ctx context.Context, path []string) (Entry, error)

+ func (s EntryImpl) Path() []string

+ func (s EntryImpl) PathName() string

+ func (s EntryImpl) SdcpbPath() (*sdcpb.Path, error)

+ func (s EntryImpl) SdcpbPathInternal(spath []string) (*sdcpb.Path, error)

+ func (s EntryImpl) String() string

+ func (s EntryImpl) StringIndent(result []string) []string

+ func (s EntryImpl) Validate(errchan chan<- error)

+ func (s EntryImpl) Walk(f EntryVisitor) error

+ type EntryVisitor func(s *sharedEntryAttributes) error

+ type LeafEntry struct

+ Delete bool

+ IsNew bool

+ IsUpdated bool

+ func NewLeafEntry(c *cache.Update, new bool) *LeafEntry

+ func (l *LeafEntry) MarkDelete()

+ func (l *LeafEntry) MarkUpdate(u *cache.Update)

+ func (l *LeafEntry) String() string

+ type LeafEntryFilter func(*LeafEntry) bool

+ type LeafVariants []*LeafEntry

+ func (lv LeafVariants) GetByOwner(owner string) *LeafEntry

+ func (lv LeafVariants) GetHighestPrecedence(onlyIfPrioChanged bool) *LeafEntry

+ func (lv LeafVariants) GetHighestPrecedenceValue() int32

+ type PathSet struct

+ func NewPathSet() *PathSet

+ func (p *PathSet) AddPath(path []string)

+ func (p *PathSet) GetPaths() [][]string

+ func (p *PathSet) Join(other *PathSet)

+ type PathSlice [][]string

+ func (p PathSlice) StringSlice() []string

+ type ResultDelete struct

+ type ResultUpdate struct

+ func (r *ResultUpdate) GetTreeEntry() Entry

+ func (r *ResultUpdate) GetUpdate() *cache.Update

+ type RootEntry struct

+ func NewTreeRoot(ctx context.Context, tc *TreeContext) (*RootEntry, error)

+ func (r *RootEntry) GetAncestorSchema() (*sdcpb.SchemaElem, int)

+ func (r *RootEntry) GetDeletes() PathSlice

+ func (r *RootEntry) GetDeletesForOwner(owner string) PathSlice

+ func (r *RootEntry) GetHighestPrecedence(onlyNewOrUpdated bool) UpdateSlice

+ func (r *RootEntry) GetUpdatesForOwner(owner string) UpdateSlice

+ func (r *RootEntry) LoadIntendedStoreOwnerData(ctx context.Context, owner string, pathKeySet *PathSet)

+ func (r *RootEntry) String() string

+ func (s RootEntry) AddCacheUpdateRecursive(ctx context.Context, c *cache.Update, new bool) error

+ func (s RootEntry) FinishInsertionPhase()

+ func (s RootEntry) GetByOwner(owner string, result []*LeafEntry) []*LeafEntry

+ func (s RootEntry) GetFirstAncestorWithSchema() (Entry, int)

+ func (s RootEntry) GetLevel() int

+ func (s RootEntry) GetParent() Entry

+ func (s RootEntry) GetSchema() *sdcpb.SchemaElem

+ func (s RootEntry) GetSchemaKeys() []string

+ func (s RootEntry) IsRoot() bool

+ func (s RootEntry) Navigate(ctx context.Context, path []string) (Entry, error)

+ func (s RootEntry) Path() []string

+ func (s RootEntry) PathName() string

+ func (s RootEntry) SdcpbPath() (*sdcpb.Path, error)

+ func (s RootEntry) SdcpbPathInternal(spath []string) (*sdcpb.Path, error)

+ func (s RootEntry) StringIndent(result []string) []string

+ func (s RootEntry) Validate(errchan chan<- error)

+ func (s RootEntry) Walk(f EntryVisitor) error

+ type TreeContext struct

+ IntendedStoreIndex map[string]UpdateSlice

+ RunningStoreIndex map[string]*cache.Update

+ func NewTreeContext(tscc TreeSchemaCacheClient, actualOwner string) *TreeContext

+ func (t *TreeContext) GetActualOwner() string

+ func (t *TreeContext) GetBranchesHighesPrecedence(path []string, filters ...CacheUpdateFilter) int32

+ func (t *TreeContext) GetPathsOfOwner(owner string) *PathSet

+ func (t *TreeContext) PathExists(path []string) bool

+ func (t *TreeContext) ReadRunning(ctx context.Context, path []string) (*cache.Update, error)

+ func (t *TreeContext) SetRoot(e Entry) error

+ func (t *TreeContext) SetStoreIndex(si map[string]UpdateSlice)

+ func (tc *TreeContext) ReadCurrentUpdatesHighestPriorities(ctx context.Context, ccp PathSlice, count uint64) UpdateSlice

+ type TreeSchemaCacheClient interface

+ GetSchema func(ctx context.Context, path []string) (*sdcpb.GetSchemaResponse, error)

+ Read func(ctx context.Context, opts *cache.Opts, paths PathSlice) []*cache.Update

+ ToPath func(ctx context.Context, path []string) (*sdcpb.Path, error)

+ type TreeSchemaCacheClientImpl struct

+ func NewTreeSchemaCacheClient(datastore string, cc cache.Client, scb SchemaClient.SchemaClientBound) *TreeSchemaCacheClientImpl

+ func (c *TreeSchemaCacheClientImpl) GetSchema(ctx context.Context, path []string) (*sdcpb.GetSchemaResponse, error)

+ func (c *TreeSchemaCacheClientImpl) Read(ctx context.Context, opts *cache.Opts, paths PathSlice) []*cache.Update

+ func (c *TreeSchemaCacheClientImpl) ToPath(ctx context.Context, path []string) (*sdcpb.Path, error)

+ type UpdateSlice []*cache.Update

+ func (u UpdateSlice) GetLowestPriorityValue(filters []CacheUpdateFilter) int32