Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

effects

package

Go to main page

Versions in this module

v0

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

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

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

+ 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)