effects

package

Go to main page

Versions in this module

v0

v0.17.0

May 7, 2026

v0.16.2

May 6, 2026

v0.16.1

May 6, 2026

v0.16.0

May 6, 2026

v0.15.2

May 5, 2026

Changes in this version

type AIContext

+ func (c *AIContext) Step(model string, messages []ai.Message, tools []ai.ToolSchema) (*ai.Response, error)

type AIHandler

+ Step func(model string, messages []ai.Message, tools []ai.ToolSchema) (*ai.Response, error)

type StubAIHandler

+ func (h *StubAIHandler) Step(model string, messages []ai.Message, tools []ai.ToolSchema) (*ai.Response, error)

v0.15.1

May 5, 2026

Changes in this version

+ type SSEEventInfo struct

+ BinaryData []byte

+ CloseCode int

+ CloseReason string

+ Data string

+ ErrType string

+ EventType string

+ Kind string

+ SourceName string

type StreamConnection

+ func (sc *StreamConnection) DrainEventsToFunc(cb func(SSEEventInfo) bool) error

v0.15.0

May 4, 2026

Changes in this version

type AIContext

+ func (c *AIContext) LastRoutingMetadata() *trace.ResolvedRoute

+ type AIHandlerWithRouting interface

+ LastRoutingMetadata func() *trace.ResolvedRoute

type EffContext

+ func (ctx *EffContext) RecordAIEffect(opName string, args []string, result string, route *trace.ResolvedRoute)

v0.14.3

May 2, 2026

v0.14.2

Apr 26, 2026

Changes in this version

type SQLiteSharedCache

+ func (c *SQLiteSharedCache) DeleteNamespace(namespace string) (int64, error)

v0.14.1

Apr 21, 2026

Changes in this version

+ var ErrNoAIHandler = errors.New(...)

+ var Registry = map[string]map[string]EffOp

+ func Call(ctx *EffContext, effectName, opName string, args []eval.Value) (eval.Value, error)

+ func ClearGlobalTraces()

+ func ExportFrameRecord(f BrainFrame, tier string) map[string]interface

+ func FormatEnvError(varName string, err error) string

+ func FormatReport(br *BudgetReport) string

+ func FormatReportForError(br *BudgetReport) string

+ func FormatReportJSON(br *BudgetReport) ([]byte, error)

+ func ImportFrameEmbedding(record map[string]interface{}, f *BrainFrame)

+ func IsSensitiveVarName(name string) bool

+ func NetHTTPRequest(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func NewManagedProcess(parentCtx context.Context, cmdPath string, args []string) (*managedProcess, error) — darwin/amd64, linux/amd64, windows/amd64

+ func ProcessCloseStdin(ctx *EffContext, args []eval.Value) (eval.Value, error) — darwin/amd64, linux/amd64, windows/amd64

+ func ProcessSpawn(ctx *EffContext, args []eval.Value) (eval.Value, error) — darwin/amd64, linux/amd64, windows/amd64

+ func ProcessWriteStdin(ctx *EffContext, args []eval.Value) (eval.Value, error) — darwin/amd64, linux/amd64, windows/amd64

+ func RecordTrace(name string)

+ func RedactEnvSnapshot(snapshot map[string]string) map[string]string

+ func RedactEnvValue(name, value string) string

+ func RedactErrorMessage(message string) string

+ func RegisterOp(effectName, opName string, op EffOp)

+ func StreamAsyncExecProcess(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamAsyncReadStdinLines(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamClose(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamConnect(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamGetStatus(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamOnEvent(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamRunEventLoop(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamSSEConnect(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamSSEPost(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamSelectEvents(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamSend(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func StreamSourceOfConn(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ func TraceCheckImpl(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ type AIContext struct

+ func NewAIContext(handler AIHandler) *AIContext

+ func (c *AIContext) Call(input string) (string, error)

+ func (c *AIContext) CallImage(prompt, outputPath, options string) (string, error)

+ func (c *AIContext) CallImageBase64(prompt, options string) (string, error)

+ func (c *AIContext) CallJson(input string, schema string) (string, error)

+ type AIHandler interface

+ Call func(input string) (string, error)

+ CallImage func(prompt string, outputPath string, options string) (string, error)

+ CallImageBase64 func(prompt string, options string) (string, error)

+ CallJson func(input string, schema string) (string, error)

+ type AssertionResult struct

+ Location string

+ Message string

+ Passed bool

+ type BrainFrame struct

+ Content string

+ CreatedAt int64

+ EmbedModel string

+ Embedding []float32

+ EmbeddingDim int

+ ExpiresAt *int64

+ Key string

+ Namespace string

+ SimHash int64

+ Source string

+ UpdatedAt int64

+ Value []byte

+ Version int

+ type BrainScope string

+ const ScopeBoth

+ const ScopeProject

+ const ScopeUser

+ type BrainSearchResult struct

+ Frame BrainFrame

+ Score float64

+ Tier string

+ type BrainStats struct

+ Namespaces map[string]int

+ NewestFrame int64

+ OldestFrame int64

+ TotalFrames int

+ type BrainStore struct

+ Project *SQLiteSharedCache

+ User *SQLiteSharedCache

+ func NewBrainStore(userDBPath, projectDBPath string, opts ...CacheOption) (*BrainStore, error)

+ func (b *BrainStore) Close() error

+ func (b *BrainStore) EmbeddingStats() map[string]struct{ ... }

+ func (b *BrainStore) Promote(key string) bool

+ func (b *BrainStore) Put(f BrainFrame, scope BrainScope) error

+ func (b *BrainStore) Search(namespace string, queryHash int64, limit int, scope BrainScope) []BrainSearchResult

+ func (b *BrainStore) SearchByEmbedding(query []float32, namespace string, limit int, scope BrainScope) []BrainSearchResult

+ func (b *BrainStore) SearchText(query string, namespace string, limit int, scope BrainScope) []BrainSearchResult

+ func (b *BrainStore) SearchThreeTier(query string, queryHash int64, queryEmbedding []float32, namespace string, ...) []BrainSearchResult

+ func (b *BrainStore) Stats() map[string]BrainStats

+ type BudgetContext struct

+ func NewBudgetContext(limits map[string]*int) *BudgetContext

+ func NewBudgetContextWithMin(limits map[string]*int, minLimits map[string]*int) *BudgetContext

+ func (bc *BudgetContext) ChargeSemanticOnly(effect string, count int)

+ func (bc *BudgetContext) CheckAndConsume(effect, position string) error

+ func (bc *BudgetContext) CheckMinimum(position string) error

+ func (bc *BudgetContext) Clone() *BudgetContext

+ func (bc *BudgetContext) HasBudget(effect string) bool

+ func (bc *BudgetContext) HasMinimum(effect string) bool

+ func (bc *BudgetContext) Limit(effect string) (int, bool)

+ func (bc *BudgetContext) LimitsMap() map[string]int

+ func (bc *BudgetContext) Merge(other *BudgetContext) *BudgetContext

+ func (bc *BudgetContext) MinLimitsMap() map[string]int

+ func (bc *BudgetContext) Minimum(effect string) (int, bool)

+ func (bc *BudgetContext) PhysicalUsageMap() map[string]int

+ func (bc *BudgetContext) PhysicalUsed(effect string) int

+ func (bc *BudgetContext) Remaining(effect string) int

+ func (bc *BudgetContext) Reset()

+ func (bc *BudgetContext) UsageMap() map[string]int

+ func (bc *BudgetContext) Used(effect string) int

+ type BudgetExhaustedError struct

+ Effect string

+ Limit int

+ Physical int

+ Position string

+ Used int

+ func NewBudgetExhaustedError(effect string, limit, used int, position string, physical int) *BudgetExhaustedError

+ func (e *BudgetExhaustedError) Error() string

+ type BudgetReport struct

+ CurrentFunction string

+ FunctionLimits map[string]map[string]*int

+ FunctionPhysicalUsage map[string]map[string]int

+ FunctionUsage map[string]map[string]int

+ TotalPhysicalUsage map[string]int

+ TotalUsage map[string]int

+ func NewBudgetReport() *BudgetReport

+ func (br *BudgetReport) EnterFunction(name string, limits map[string]int)

+ func (br *BudgetReport) ExitFunction(name string, budget *BudgetContext)

+ func (br *BudgetReport) HasUsage() bool

+ func (br *BudgetReport) RecordUsage(effect string, count int)

+ type BudgetReportJSON struct

+ Functions map[string]FunctionBudgetJSON

+ Total map[string]int

+ TotalPhysical map[string]int

+ type BudgetUnderrunError struct

+ Actual int

+ Effect string

+ Min int

+ Position string

+ func NewBudgetUnderrunError(effect string, min, actual int, position string) *BudgetUnderrunError

+ func (e *BudgetUnderrunError) Error() string

+ type CacheOption func(*SQLiteSharedCache)

+ func WithEmbedder(e Embedder) CacheOption

+ type Capability struct

+ Meta map[string]any

+ Name string

+ func NewCapability(name string) Capability

+ type CapabilityError struct

+ Effect string

+ func NewCapabilityError(effect string) *CapabilityError

+ func (e *CapabilityError) Error() string

+ type ClockContext struct

+ func NewClockContext() *ClockContext

+ type ContractCheck struct

+ Function string

+ Kind ast.ContractKind

+ Location string

+ Message string

+ Passed bool

+ type ContractContext struct

+ Mode ContractMode

+ func NewContractContext() *ContractContext

+ func NewContractContextWithMode(mode ContractMode) *ContractContext

+ func (c *ContractContext) CheckEnsures(cond bool, msg, location string) error

+ func (c *ContractContext) CheckInvariant(cond bool, msg, location string) error

+ func (c *ContractContext) CheckRequires(cond bool, msg, location string) error

+ func (c *ContractContext) Collect() ContractOutput

+ func (c *ContractContext) CurrentFunction() string

+ func (c *ContractContext) HasViolations() bool

+ func (c *ContractContext) Reset()

+ func (c *ContractContext) SetFunction(name string)

+ func (c *ContractContext) SetMode(mode ContractMode)

+ func (c *ContractContext) Violations() []ContractCheck

+ func (c *ContractContext) ViolationsByKind(kind ast.ContractKind) []ContractCheck

+ type ContractMode int

+ const ContractModeOff

+ const ContractModePanic

+ const ContractModeReport

+ func (m ContractMode) String() string

+ type ContractOutput struct

+ Checks []ContractCheck

+ FailCount int

+ Mode ContractMode

+ PassCount int

+ TotalCount int

+ type DebugContext struct

+ func NewDebugContext() *DebugContext

+ func (d *DebugContext) Check(cond bool, msg, location string)

+ func (d *DebugContext) Collect() DebugOutput

+ func (d *DebugContext) FailedAssertions() []AssertionResult

+ func (d *DebugContext) HasFailedAssertions() bool

+ func (d *DebugContext) Log(msg, location string)

+ func (d *DebugContext) Reset()

+ func (d *DebugContext) SetTimestamp(t int64)

+ type DebugOutput struct

+ Assertions []AssertionResult

+ Logs []LogEntry

+ type DeterminismMode int

+ const DeterminismBestEffort

+ const DeterminismStrict

+ func (m DeterminismMode) String() string

+ type EffContext struct

+ AI *AIContext

+ Args []string

+ Budget *BudgetContext

+ BudgetReport *BudgetReport

+ CallerContext *EffContext

+ Caps map[string]Capability

+ Clock *ClockContext

+ Contracts *ContractContext

+ Debug *DebugContext

+ DeclaredBudgets map[string]int

+ DisableBudgets bool

+ Env EffEnv

+ EnvAllowlist []string

+ EnvSnapshot map[string]string

+ FnCaller func(fn eval.Value, arg eval.Value) (eval.Value, error)

+ FnCallerN func(fn eval.Value, args []eval.Value) (eval.Value, error)

+ GoCtx context.Context

+ IOReader io.Reader

+ IOWriter io.Writer

+ Net *NetContext

+ Process *ProcessContext

+ SharedIndex *SharedIndexContext

+ SharedMem *SharedMemContext

+ SpanWrapper SpanWrapperFunc

+ Stream *StreamContext

+ Trace *trace.Collector

+ func NewEffContext(args []string) *EffContext

+ func (ctx *EffContext) CheckEnsures(cond bool, msg, location string) error

+ func (ctx *EffContext) CheckMinimums(position string) error

+ func (ctx *EffContext) CheckRequires(cond bool, msg, location string) error

+ func (ctx *EffContext) Clone() interface{}

+ func (ctx *EffContext) GetIOReader() *bufio.Reader

+ func (ctx *EffContext) GetIOWriter() io.Writer

+ func (ctx *EffContext) Grant(cap Capability)

+ func (ctx *EffContext) HasCap(name string) bool

+ func (ctx *EffContext) HasTraceCollector() bool

+ func (ctx *EffContext) IsContractCheckingEnabled() bool

+ func (ctx *EffContext) PopScopeAndChargeCaller()

+ func (ctx *EffContext) RecordEffect(effectName, opName string, args []string, result string)

+ func (ctx *EffContext) RecordFunctionEnter(name string, args []string)

+ func (ctx *EffContext) RecordFunctionExit(name string, result string)

+ func (ctx *EffContext) RequireCap(name string) error

+ func (ctx *EffContext) RequireCapWithBudget(name, position string) error

+ func (ctx *EffContext) SetBudget(budget *BudgetContext)

+ func (ctx *EffContext) SetFnCaller(fn func(eval.Value, eval.Value) (eval.Value, error))

+ func (ctx *EffContext) SetFnCallerN(fn func(eval.Value, []eval.Value) (eval.Value, error))

+ func (ctx *EffContext) SetMinBudgets(minLimits map[string]int)

+ func (ctx *EffContext) WithBudget(budget *BudgetContext) *EffContext

+ func (ctx *EffContext) WithBudgetLimits(limits map[string]int) interface{}

+ type EffEnv struct

+ Locale string

+ Sandbox string

+ Seed int64

+ TZ string

+ type EffOp func(ctx *EffContext, args []eval.Value) (eval.Value, error)

+ type EffectBudgetJSON struct

+ Limit *int

+ Physical int

+ Semantic int

+ type Embedder interface

+ Dimension func() int

+ Embed func(text string) ([]float32, error)

+ EmbedBatch func(texts []string) ([][]float32, error)

+ ModelName func() string

+ type EventSource interface

+ Close func()

+ Events func() <-chan streamEvent

+ Name func() string

+ Priority func() int

+ func NewConnSource(conn *StreamConnection, name string, priority int) EventSource

+ func NewProcessSource(parentCtx context.Context, cmdPath string, args []string, name string, ...) (EventSource, error)

+ func NewStdinSource(reader io.Reader, name string, priority int) EventSource

+ type FunctionBudgetJSON struct

+ Effects map[string]EffectBudgetJSON

+ type InMemorySharedCache struct

+ func NewInMemorySharedCache() *InMemorySharedCache

+ func (c *InMemorySharedCache) CAS(key string, oldValue, newValue []byte) bool

+ func (c *InMemorySharedCache) Delete(key string)

+ func (c *InMemorySharedCache) Get(key string) ([]byte, bool)

+ func (c *InMemorySharedCache) Keys() []string

+ func (c *InMemorySharedCache) Len() int

+ func (c *InMemorySharedCache) Put(key string, value []byte)

+ type InMemorySharedIndex struct

+ func NewInMemorySharedIndex() *InMemorySharedIndex

+ func (idx *InMemorySharedIndex) Delete(namespace, key string)

+ func (idx *InMemorySharedIndex) EntryCount(namespace string) int

+ func (idx *InMemorySharedIndex) FindSimilarByEmbedding(namespace string, queryEmbedding []float64, topK, maxScan int, ...) []SearchResult

+ func (idx *InMemorySharedIndex) FindSimilarSimHash(namespace string, querySimHash int64, topK, maxScan int, mode DeterminismMode) []SearchResult

+ func (idx *InMemorySharedIndex) Namespaces() []string

+ func (idx *InMemorySharedIndex) Upsert(namespace, key string, simhash, version, timestamp int64)

+ func (idx *InMemorySharedIndex) UpsertWithEmbedding(namespace, key string, simhash int64, embedding []float64, ...)

+ type IndexEntry struct

+ Embedding []float64

+ Key string

+ Namespace string

+ Score float64

+ SimHash int64

+ Timestamp int64

+ Version int64

+ type LogEntry struct

+ Location string

+ Message string

+ Timestamp int64

+ type NetContext struct

+ AllowHTTP bool

+ AllowLocalhost bool

+ AllowMetadata bool

+ AllowedDomains []string

+ MaxBytes int64

+ MaxRedirects int

+ Timeout time.Duration

+ UserAgent string

+ func NewNetContext() *NetContext

+ type ProcessContext struct

+ Allowlist map[string]string

+ HasAllowlist bool

+ MaxOutput int64

+ Timeout time.Duration

+ func NewProcessContext() *ProcessContext

+ func (pc *ProcessContext) AcquireManagedProcess(mp *managedProcess) int

+ func (pc *ProcessContext) CloseAllManaged()

+ func (pc *ProcessContext) GetManagedProcess(id int) (*managedProcess, bool)

+ func (pc *ProcessContext) ReleaseManagedProcess(id int)

+ func (pc *ProcessContext) ResolveAllowlist(allowlistStr string) error

+ type SQLiteSharedCache struct

+ func NewSQLiteSharedCache(dbPath string, opts ...CacheOption) (*SQLiteSharedCache, error)

+ func (c *SQLiteSharedCache) BackfillEmbeddings(namespace string) (int, int)

+ func (c *SQLiteSharedCache) CAS(key string, oldValue, newValue []byte) bool

+ func (c *SQLiteSharedCache) Close() error

+ func (c *SQLiteSharedCache) DB() *sql.DB

+ func (c *SQLiteSharedCache) Delete(key string)

+ func (c *SQLiteSharedCache) EmbeddingStats() (total, withEmbedding int, models map[string]int)

+ func (c *SQLiteSharedCache) GarbageCollect() (int64, error)

+ func (c *SQLiteSharedCache) GarbageCollectOlderThan(namespace string, age time.Duration) (int64, error)

+ func (c *SQLiteSharedCache) Get(key string) ([]byte, bool)

+ func (c *SQLiteSharedCache) GetEmbedder() Embedder

+ func (c *SQLiteSharedCache) Keys() []string

+ func (c *SQLiteSharedCache) Len() int

+ func (c *SQLiteSharedCache) ListRecent(namespace string, limit int) []BrainFrame

+ func (c *SQLiteSharedCache) Put(key string, value []byte)

+ func (c *SQLiteSharedCache) PutFrame(f BrainFrame) error

+ func (c *SQLiteSharedCache) PutVector(key, namespace string, embedding []float32, model string, payload []byte) error

+ func (c *SQLiteSharedCache) SearchByEmbedding(queryEmbedding []float32, namespace string, limit int) []BrainSearchResult

+ func (c *SQLiteSharedCache) SearchBySimHash(namespace string, queryHash int64, limit int) []BrainSearchResult

+ func (c *SQLiteSharedCache) SearchByText(query string, namespace string, limit int) []BrainSearchResult

+ func (c *SQLiteSharedCache) SetEmbedder(e Embedder)

+ func (c *SQLiteSharedCache) Stats() BrainStats

+ type SearchResult struct

+ Key string

+ Score float64

+ Timestamp int64

+ Version int64

+ type SharedCache interface

+ CAS func(key string, oldValue, newValue []byte) bool

+ Delete func(key string)

+ Get func(key string) ([]byte, bool)

+ Keys func() []string

+ Len func() int

+ Put func(key string, value []byte)

+ type SharedIndex interface

+ Delete func(namespace, key string)

+ EntryCount func(namespace string) int

+ Namespaces func() []string

+ Upsert func(namespace, key string, simhash, version, timestamp int64)

+ UpsertWithEmbedding func(namespace, key string, simhash int64, embedding []float64, ...)

+ type SharedIndexContext struct

+ DeleteCount int64

+ Index SharedIndex

+ ScannedTotal int64

+ SearchCount int64

+ Trace []TraceEntry

+ TraceEnabled bool

+ UpsertCount int64

+ func NewSharedIndexContext(index SharedIndex) *SharedIndexContext

+ func (c *SharedIndexContext) ClearTrace()

+ func (c *SharedIndexContext) DisableTracing()

+ func (c *SharedIndexContext) EnableTracing()

+ func (c *SharedIndexContext) GetTrace() []TraceEntry

+ func (c *SharedIndexContext) IncrementDelete()

+ func (c *SharedIndexContext) IncrementSearch(scanned int64)

+ func (c *SharedIndexContext) IncrementUpsert()

+ func (c *SharedIndexContext) TraceDelete(namespace, key string)

+ func (c *SharedIndexContext) TraceFindByEmbedding(namespace string, embeddingDim, topK, maxScan int, mode DeterminismMode, ...)

+ func (c *SharedIndexContext) TraceFindSimHash(namespace string, queryHash int64, topK, maxScan int, mode DeterminismMode, ...)

+ func (c *SharedIndexContext) TraceResolveBestMatch(namespace string, queryHash int64, chosenKey string)

+ func (c *SharedIndexContext) TraceUpsert(namespace, key string)

+ func (c *SharedIndexContext) TraceUpsertWithEmbedding(namespace, key string, embeddingDim int)

+ type SharedMemContext struct

+ CASCount int64

+ CASSuccess int64

+ Cache SharedCache

+ GetCount int64

+ PutCount int64

+ func NewSharedMemContext(cache SharedCache) *SharedMemContext

+ func (ctx *SharedMemContext) IncrCASCount(success bool)

+ func (ctx *SharedMemContext) IncrGetCount()

+ func (ctx *SharedMemContext) IncrPutCount()

+ func (ctx *SharedMemContext) Stats() (gets, puts, cas, casSuccess int64)

+ type SpanWrapperFunc func(goCtx context.Context, effectName, opName string, args []eval.Value, ...) (eval.Value, error)

+ type StreamConnection struct

+ func (sc *StreamConnection) Close()

+ func (sc *StreamConnection) Status() StreamStatus

+ type StreamContext struct

+ AllowHTTP bool

+ AllowLocalhost bool

+ AllowedDomains []string

+ BlockPrivateIPs bool

+ ConnectTimeout time.Duration

+ EventBufferSize int

+ IdleTimeout time.Duration

+ MaxConnections int

+ MaxDuration time.Duration

+ MaxFrameSize int64

+ MaxMessageSize int64

+ func NewStreamContext() *StreamContext

+ func (sc *StreamContext) AcquireConnection(conn *StreamConnection) (int, error)

+ func (sc *StreamContext) AcquireSource(source EventSource) int

+ func (sc *StreamContext) CloseAll()

+ func (sc *StreamContext) ConnectionCount() int

+ func (sc *StreamContext) GetConnection(id int) (*StreamConnection, bool)

+ func (sc *StreamContext) GetSource(id int) (EventSource, bool)

+ func (sc *StreamContext) ReleaseConnection(id int)

+ func (sc *StreamContext) ReleaseSource(id int)

+ func (sc *StreamContext) ValidateURL(rawURL string) error

+ type StreamStatus int

+ const StreamStatusClosed

+ const StreamStatusClosing

+ const StreamStatusConnecting

+ const StreamStatusOpen

+ func (s StreamStatus) String() string

+ type StubAIHandler struct

+ func NewStubAIHandler() *StubAIHandler

+ func (h *StubAIHandler) Call(input string) (string, error)

+ func (h *StubAIHandler) CallImage(prompt, outputPath, options string) (string, error)

+ func (h *StubAIHandler) CallImageBase64(prompt, options string) (string, error)

+ func (h *StubAIHandler) CallJson(input string, schema string) (string, error)

+ func (h *StubAIHandler) SetDefaultResponse(response string)

+ func (h *StubAIHandler) SetResponse(input, response string)

+ type TraceEntry struct

+ ChosenKey string

+ Key string

+ MaxScan int

+ Mode DeterminismMode

+ Namespace string

+ Operation string

+ QueryHash int64

+ ResultCount int

+ Timestamp int64

+ TopK int

+ type TraceRegistry struct

+ func GlobalTraceRegistry() *TraceRegistry

+ func NewTraceRegistry() *TraceRegistry

+ func (r *TraceRegistry) All() map[string]int

+ func (r *TraceRegistry) Clear()

+ func (r *TraceRegistry) Count(name string) int

+ func (r *TraceRegistry) Exists(name string) bool

+ func (r *TraceRegistry) Record(name string)

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