graph

Jan 5, 2026

Changes in this version

type GraphDatabase — darwin/amd64, linux/amd64, windows/amd64

+ CollectInboundRefs func(result GraphResultI, depth int, kinds []uint16) error

+ CollectOutboundRefs func(result GraphResultI, depth int, kinds []uint16) error

type GraphResultI — darwin/amd64, linux/amd64, windows/amd64

+ GetInboundRefs func() map[uint16]map[string][]string

+ GetOutboundRefs func() map[uint16]map[string][]string

+ type RefSummary struct — darwin/amd64, linux/amd64, windows/amd64

+ Count int

+ Kind uint16

+ Refs []string

+ Target string

type ResponseContent — darwin/amd64, linux/amd64, windows/amd64

+ InboundRefs []RefSummary

+ OutboundRefs []RefSummary

Dec 4, 2025

Changes in this version

+ const KindGraphFollows — darwin/amd64, linux/amd64, windows/amd64

+ const KindGraphMentions — darwin/amd64, linux/amd64, windows/amd64

+ const KindGraphThread — darwin/amd64, linux/amd64, windows/amd64

+ var ErrDepthTooHigh = errors.New("_graph.depth cannot exceed 16")

+ var ErrEmptyRefSpecKinds = errors.New("ref spec kinds array cannot be empty")

+ var ErrInvalidMethod = errors.New("_graph.method must be one of: follows, followers, mentions, thread")

+ var ErrInvalidSeed = errors.New("_graph.seed must be a 64-character hex string")

+ var ErrMissingMethod = errors.New("_graph.method is required")

+ var ErrMissingSeed = errors.New("_graph.seed is required")

+ func IsGraphQuery(f *filter.F) bool

+ type Executor struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewExecutor(db GraphDatabase, secretKey []byte) (*Executor, error)

+ func (e *Executor) Execute(q *Query) (*event.E, error)

+ type GraphDatabase interface — darwin/amd64, linux/amd64, windows/amd64

+ FindMentions func(pubkey []byte, kinds []uint16) (GraphResultI, error)

+ TraverseFollowers func(seedPubkey []byte, maxDepth int) (GraphResultI, error)

+ TraverseFollows func(seedPubkey []byte, maxDepth int) (GraphResultI, error)

+ TraverseThread func(seedEventID []byte, maxDepth int, direction string) (GraphResultI, error)

+ type GraphResultI interface — darwin/amd64, linux/amd64, windows/amd64

+ GetAllEvents func() []string

+ GetAllPubkeys func() []string

+ GetEventsByDepth func() map[int][]string

+ GetPubkeysByDepth func() map[int][]string

+ GetTotalEvents func() int

+ GetTotalPubkeys func() int

+ ToDepthArrays func() [][]string

+ ToEventDepthArrays func() [][]string

+ type Query struct

+ Depth int

+ InboundRefs []RefSpec

+ Method string

+ OutboundRefs []RefSpec

+ Seed string

+ func ExtractFromFilter(f *filter.F) (*Query, error)

+ func (q *Query) HasInboundRefs() bool

+ func (q *Query) HasOutboundRefs() bool

+ func (q *Query) HasRefs() bool

+ func (q *Query) InboundKindsAtDepth(depth int) map[int]bool

+ func (q *Query) OutboundKindsAtDepth(depth int) map[int]bool

+ func (q *Query) Validate() error

+ type RateLimiter struct

+ func NewRateLimiter(cfg RateLimiterConfig) *RateLimiter

+ func (rl *RateLimiter) Acquire(ctx context.Context, cost float64) (time.Duration, error)

+ func (rl *RateLimiter) AvailableTokens() float64

+ func (rl *RateLimiter) OperationCost(depth int, nodesAtDepth int) float64

+ func (rl *RateLimiter) Pause(ctx context.Context, depth int, itemsProcessed int) error

+ func (rl *RateLimiter) QueryCost(q *Query) float64

+ func (rl *RateLimiter) TryAcquire(cost float64) bool

+ type RateLimiterConfig struct

+ BaseDelay time.Duration

+ DepthFactor float64

+ LimitFactor float64

+ MaxDelay time.Duration

+ MaxTokens float64

+ RefillRate float64

+ func DefaultRateLimiterConfig() RateLimiterConfig

+ type RefSpec struct

+ FromDepth int

+ Kinds []int

+ type ResponseContent struct — darwin/amd64, linux/amd64, windows/amd64

+ EventsByDepth [][]string

+ PubkeysByDepth [][]string

+ TotalEvents int

+ TotalPubkeys int

+ type Throttler struct

+ func NewThrottler(rl *RateLimiter, depth int) *Throttler

+ func (t *Throttler) Complete() (itemsProcessed int)

+ func (t *Throttler) Tick(ctx context.Context) error