graphcache

package

Go to main page

Versions in this module

v0

v0.17.0

Jul 6, 2026

v0.16.0

Jul 5, 2026

Changes in this version

+ type DegreeDirection uint8

+ const DegreeBoth

+ const DegreeIn

+ const DegreeOut

+ type DegreeEntry struct

+ Degree uint64

+ Key S

+ WeightedDegree float64

type GraphCache

+ func (c *GraphCache[S, T]) DeleteEdgesByPrefix(ctx context.Context, tailPrefix, headPrefix string, limit int) int

+ func (c *GraphCache[S, T]) DeleteEdgesByPrefixHLC(ctx context.Context, tailPrefix, headPrefix string, limit int, ...) (int, error)

+ func (c *GraphCache[S, T]) PutVertexWithExpirationIfAbsent(key S, value T, expiration time.Time) bool

+ func (c *GraphCache[S, T]) PutVerticesWithExpirationIfAbsent(items []VertexItem[S, T]) (written int, skipped []S)

+ func (c *GraphCache[S, T]) PutVerticesWithExpirationIfAbsentHLC(items []VertexItem[S, T], ts hlc.Timestamp) (writtenIdx []int, skipped []S)

+ func (c *GraphCache[S, T]) SearchVerticesMatch(query string, limit int, keyPrefix string, opts search.MatchOptions, ...) []search.Result[S]

+ func (c *GraphCache[S, T]) TopVerticesByDegree(prefix string, k int, dir DegreeDirection, weighted bool) []DegreeEntry[S]

+ type SearchIndexOption func(*searchIndexConfig)

+ func WithoutSearchPositions() SearchIndexOption

v0.15.0

Jul 2, 2026

Changes in this version

type GraphCache

+ func (c *GraphCache[S, T]) LocalCommunity(seed S, maxSize int, alpha, epsilon float64, weighting EdgeWeighting, ...) (*graph.Graph[S, T], map[S]map[S]time.Time)

+ func (c *GraphCache[S, T]) LocalCommunityContext(ctx context.Context, seed S, maxSize int, alpha, epsilon float64, ...) (*graph.Graph[S, T], map[S]map[S]time.Time, error)

+ func (c *GraphCache[S, T]) ScanByPrefixPage(ctx context.Context, prefix, after string, limit int, ...) (more, ok bool)

+ func (c *GraphCache[S, T]) ScanEdgesByPrefixPage(ctx context.Context, tailPrefix, headPrefix, afterTail, afterHead string, ...) (more, ok bool)

v0.14.1

Jun 26, 2026

v0.14.0

Jun 24, 2026

Changes in this version

+ const DefaultPPRAlpha

+ const DefaultPPREpsilon

+ type EdgeWeighting uint8

+ const WeightingBM25

+ const WeightingRaw

+ const WeightingTFIDF

type GraphCache

+ func (c *GraphCache[S, T]) PersonalizedPageRank(seed S, topN int, alpha, epsilon float64, weighting EdgeWeighting, ...) *graph.Graph[S, T]

+ func (c *GraphCache[S, T]) PersonalizedPageRankContext(ctx context.Context, seed S, topN int, alpha, epsilon float64, ...) (*graph.Graph[S, T], error)

v0.13.0

Jun 22, 2026

v0.12.0

Jun 20, 2026

v0.11.0

Jun 20, 2026

Changes in this version

type GraphCache

+ func (c *GraphCache[S, T]) GCSweepBacklog() int

+ func (c *GraphCache[S, T]) SetGCEdgeBudget(n int)

v0.10.0

Jun 19, 2026

Changes in this version

type GraphCache

+ func (c *GraphCache[S, T]) VertexHLCHighWater() int

v0.9.0

Jun 19, 2026

Changes in this version

type GraphCache

+ func (c *GraphCache[S, T]) AddEdgesWithExpirationContribHLC(items []EdgeItem[S], ts hlc.Timestamp) (deduped int)

+ func (c *GraphCache[S, T]) PutEdgesWithExpirationHLC(items []EdgeItem[S], ts hlc.Timestamp)

+ func (c *GraphCache[S, T]) PutVerticesWithExpirationHLC(items []VertexItem[S, T], ts hlc.Timestamp)

+ func (c *GraphCache[S, T]) SearchIndexStats() (terms, docs int)

+ func (c *GraphCache[S, T]) VertexHLCCount() int

v0.8.0

Jun 18, 2026

Changes in this version

type GraphCache

+ func (c *GraphCache[S, T]) SnapshotGraph() GraphSnapshot[S, T]

+ type GraphSnapshot struct

+ Edges []SnapshotEdge[S]

+ Vertices []SnapshotVertex[S, T]

v0.7.1

Jun 17, 2026

v0.7.0

Jun 16, 2026

Changes in this version

+ type ContribID [24]byte

+ func (c ContribID) IsZero() bool

+ type EdgeItem struct

+ ContribID ContribID

+ Expiration time.Time

+ Head S

+ Tail S

+ Weight float32

+ type EdgeKey struct

+ Head S

+ Tail S

+ type GraphCache struct

+ func NewGraphCache[S comparable, T any](defaultTTL time.Duration) *GraphCache[S, T]

+ func (c *GraphCache[S, T]) AddEdge(tail, head S, w float32)

+ func (c *GraphCache[S, T]) AddEdgeWithExpiration(tail, head S, w float32, expiration time.Time)

+ func (c *GraphCache[S, T]) AddEdgeWithExpirationContrib(tail, head S, w float32, expiration time.Time, contribID ContribID) bool

+ func (c *GraphCache[S, T]) AddEdgeWithExpirationContribHLC(tail, head S, w float32, expiration time.Time, contribID ContribID, ...) bool

+ func (c *GraphCache[S, T]) AddEdgeWithTTL(tail, head S, w float32, ttl time.Duration)

+ func (c *GraphCache[S, T]) AddEdgesWithExpiration(items []EdgeItem[S])

+ func (c *GraphCache[S, T]) AddEdgesWithExpirationContrib(items []EdgeItem[S]) (deduped int)

+ func (c *GraphCache[S, T]) CountByPrefix(prefix string) int

+ func (c *GraphCache[S, T]) DeleteByPrefix(ctx context.Context, prefix string, limit int) int

+ func (c *GraphCache[S, T]) DeleteByPrefixHLC(ctx context.Context, prefix string, limit uint32, ts hlc.Timestamp, ...) (int, error)

+ func (c *GraphCache[S, T]) DeleteEdge(tail, head S) bool

+ func (c *GraphCache[S, T]) DeleteEdgeHLC(tail, head S, ts hlc.Timestamp, expiration time.Time) bool

+ func (c *GraphCache[S, T]) DeleteEdges(keys []EdgeKey[S]) int

+ func (c *GraphCache[S, T]) DeleteEdgesHLC(keys []EdgeKey[S], ts hlc.Timestamp, expiration time.Time) int

+ func (c *GraphCache[S, T]) DeleteVertex(key S) bool

+ func (c *GraphCache[S, T]) DeleteVertexHLC(key S, ts hlc.Timestamp, expiration time.Time) bool

+ func (c *GraphCache[S, T]) DeleteVertices(keys []S) int

+ func (c *GraphCache[S, T]) DeleteVerticesHLC(keys []S, ts hlc.Timestamp, expiration time.Time) int

+ func (c *GraphCache[S, T]) EdgeCount() int

+ func (c *GraphCache[S, T]) EnablePrefixIndex(extract func(S) string)

+ func (c *GraphCache[S, T]) EnableSearchIndex(extract func(T) search.Document)

+ func (c *GraphCache[S, T]) GetEdgeDetail(tail, head S) (float32, time.Time, bool)

+ func (c *GraphCache[S, T]) GetVertex(key S) (T, bool)

+ func (c *GraphCache[S, T]) GetWeight(tail, head S) (float32, bool)

+ func (c *GraphCache[S, T]) Neighbor(seed S, step int, k int, tfidf bool, selectSmallest bool, keep func(S) bool) *graph.Graph[S, T]

+ func (c *GraphCache[S, T]) NeighborContext(ctx context.Context, seed S, step int, k int, tfidf bool, selectSmallest bool, ...) (*graph.Graph[S, T], error)

+ func (c *GraphCache[S, T]) NeighborWithExpirationsContext(ctx context.Context, seed S, step int, k int, tfidf bool, selectSmallest bool, ...) (*graph.Graph[S, T], map[S]map[S]time.Time, error)

+ func (c *GraphCache[S, T]) PutEdgeWithExpiration(tail, head S, w float32, expiration time.Time)

+ func (c *GraphCache[S, T]) PutEdgeWithExpirationHLC(tail, head S, w float32, expiration time.Time, ts hlc.Timestamp) bool

+ func (c *GraphCache[S, T]) PutEdgesWithExpiration(items []EdgeItem[S])

+ func (c *GraphCache[S, T]) PutVertex(key S, value T)

+ func (c *GraphCache[S, T]) PutVertexWithExpiration(key S, value T, expiration time.Time)

+ func (c *GraphCache[S, T]) PutVertexWithExpirationHLC(key S, value T, expiration time.Time, ts hlc.Timestamp) bool

+ func (c *GraphCache[S, T]) PutVertexWithTTL(key S, value T, ttl time.Duration)

+ func (c *GraphCache[S, T]) PutVerticesWithExpiration(items []VertexItem[S, T])

+ func (c *GraphCache[S, T]) ScanByPrefix(ctx context.Context, prefix string, ...) bool

+ func (c *GraphCache[S, T]) ScanEdgesByPrefix(ctx context.Context, tailPrefix, headPrefix string, ...) bool

+ func (c *GraphCache[S, T]) SearchVertices(query string, limit int, keyPrefix string) []search.Result[S]

+ func (c *GraphCache[S, T]) SetGCHooks(onExpire func(kind string, n int), onGCDuration func(d time.Duration))

+ func (c *GraphCache[S, T]) SnapshotEdges() []SnapshotEdge[S]

+ func (c *GraphCache[S, T]) SnapshotVertices() []SnapshotVertex[S, T]

+ func (c *GraphCache[S, T]) VertexCount() int

+ func (c *GraphCache[S, T]) Watch(ctx context.Context, interval time.Duration)

+ type SnapshotContribution struct

+ ContribID ContribID

+ Expiration time.Time

+ Weight float32

+ type SnapshotEdge struct

+ Contributions []SnapshotContribution

+ HLC hlc.Timestamp

+ Head S

+ Tail S

+ type SnapshotVertex struct

+ Expiration time.Time

+ HLC hlc.Timestamp

+ Key S

+ Value T

+ type VertexItem struct

+ Expiration time.Time

+ Key S

+ Value T

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