runner

package

Go to main page

Versions in this module

v0

v0.2.13

Apr 11, 2026

v0.2.12

Apr 10, 2026

Changes in this version

+ func SnapshotToCoverageDetail(snapshot CoverageSnapshot) map[string]CoverageFileDiff

+ func WriteCoverageJSON(path string, aggregate CoverageSnapshot, ...) error

+ func WriteCoverageLCOV(path string, aggregate CoverageSnapshot) error

+ type BranchInfo struct

+ Covered int

+ Total int

+ type CoverageAggregate struct

+ BranchCoveragePct float64

+ CoveragePct float64

+ CoveredBranches int

+ CoveredFiles int

+ TotalBranches int

+ TotalCoverableLines int

+ TotalCoveredLines int

+ TotalFiles int

+ type CoverageExport struct

+ Aggregate CoverageSnapshot

+ PerTest map[string]map[string]CoverageFileDiff

+ Summary CoverageSummary

+ type CoverageFileDiff struct

+ Branches map[string]BranchInfo

+ CoverableLines int

+ CoveredBranches int

+ CoveredCount int

+ CoveredLines []int

+ TotalBranches int

+ type CoverageFileSummary struct

+ CoverableLines int

+ CoveragePct float64

+ CoveredBranches int

+ CoveredLines int

+ TotalBranches int

+ type CoverageReportView struct

+ Aggregate CoverageSnapshot

+ PerTest map[string]map[string]CoverageFileDiff

+ SuiteRecords []CoverageTestRecord

+ Summary CoverageSummary

+ type CoverageSnapshot map[string]FileCoverageData

+ type CoverageSummary struct

+ Aggregate CoverageAggregate

+ PerFile map[string]CoverageFileSummary

+ PerTest []CoverageTestSummary

+ Timestamp string

+ func ComputeCoverageSummary(aggregate CoverageSnapshot, ...) CoverageSummary

+ type CoverageTestRecord struct

+ Coverage CoverageSnapshot

+ SuiteStatus string

+ TestID string

+ TestName string

+ type CoverageTestSummary struct

+ CoveredLines int

+ FilesTouched int

+ TestID string

+ TestName string

type Executor

+ func (e *Executor) AddCoverageRecord(record CoverageTestRecord)

+ func (e *Executor) BuildCoverageReportView(records []CoverageTestRecord) *CoverageReportView

+ func (e *Executor) FormatCoverageSummaryLines(records []CoverageTestRecord) ([]string, CoverageSnapshot)

+ func (e *Executor) GetCoverageBaselineForUpload() (merged CoverageSnapshot, originalBaseline CoverageSnapshot)

+ func (e *Executor) GetCoverageOutputPath() string

+ func (e *Executor) GetCoveragePerTestSnapshot() map[string]map[string]CoverageFileDiff

+ func (e *Executor) GetCoverageRecords() []CoverageTestRecord

+ func (e *Executor) GetTestCoverageDetail(testID string) map[string]CoverageFileDiff

+ func (e *Executor) IsCoverageEnabled() bool

+ func (e *Executor) IsCoverageShowOutput() bool

+ func (e *Executor) ProcessCoverage(records []CoverageTestRecord) error

+ func (e *Executor) ProcessCoverageWithAggregate(records []CoverageTestRecord, precomputed CoverageSnapshot) error

+ func (e *Executor) SetCoverageBaseline(baseline CoverageSnapshot)

+ func (e *Executor) SetCoverageEnabled(enabled bool)

+ func (e *Executor) SetCoverageExcludePatterns(patterns []string)

+ func (e *Executor) SetCoverageIncludePatterns(patterns []string)

+ func (e *Executor) SetCoverageOutputPath(path string)

+ func (e *Executor) SetCoverageStripPrefix(prefix string)

+ func (e *Executor) SetShowCoverage(show bool)

+ func (e *Executor) SetTestCoverageDetail(testID string, detail map[string]CoverageFileDiff)

+ func (e *Executor) TakeCoverageBaseline() (CoverageSnapshot, error)

+ func (e *Executor) TakeCoverageSnapshot() (CoverageSnapshot, error)

+ type FileCoverageData struct

+ Branches map[string]BranchInfo

+ CoveredBranches int

+ Lines map[string]int

+ TotalBranches int

type Server

+ func (ms *Server) SendCoverageSnapshot(baseline bool) (*core.CoverageSnapshotResponse, error)

v0.2.11

Apr 7, 2026

v0.2.10

Apr 1, 2026

v0.2.9

Mar 31, 2026

Changes in this version

+ func RedactSecrets(content string) string

v0.2.8

Mar 30, 2026

Changes in this version

+ type AgentWriter struct

+ func NewAgentWriter(outputDir string) (*AgentWriter, error)

+ func (w *AgentWriter) OutputDir() string

+ func (w *AgentWriter) RecordPassedTest(test Test)

+ func (w *AgentWriter) SetBaseBranch(branch string)

+ func (w *AgentWriter) WriteDeviation(test Test, result TestResult, server *Server) error

+ func (w *AgentWriter) WriteIndex(totalTests int, passedTests int) error

v0.2.7

Mar 25, 2026

Changes in this version

+ func ExtractSuiteStatusFromFilter(filter string) (string, bool)

+ func ParseTraceTestStatusFilter(val string) *backend.TraceTestStatus

type Test

+ SuiteStatus string

v0.2.6

Mar 24, 2026

v0.2.5

Mar 23, 2026

Changes in this version

+ const MaxServerRestartAttempts

+ const RestartBackoffBase

+ const SandboxModeAuto

+ const SandboxModeOff

+ const SandboxModeStrict

+ func BuildTraceTestResultsProto(e *Executor, results []TestResult, tests []Test) []*backend.TraceTestResult

+ func ConvertRunnerResultToTraceTestResult(result TestResult, test Test) *backend.TraceTestResult

+ func ConvertRunnerResultsToTraceTestResults(results []TestResult, tests []Test) []*backend.TraceTestResult

+ func DecodeValueBySchema(value any, schema *core.JsonSchema) (decodedBytes []byte, parsedValue any, err error)

+ func DedupeSpans(spans []*core.Span) []*core.Span

+ func FetchGlobalSpansFromCloud(ctx context.Context, client *api.TuskClient, auth api.AuthOptions, ...) ([]*core.Span, error)

+ func FetchGlobalSpansFromCloudWithCache(ctx context.Context, client *api.TuskClient, auth api.AuthOptions, ...) ([]*core.Span, error)

+ func FetchLocalPreAppStartSpans(interactive bool) ([]*core.Span, error)

+ func FetchPreAppStartSpansFromCloud(ctx context.Context, client *api.TuskClient, auth api.AuthOptions, ...) ([]*core.Span, error)

+ func FetchPreAppStartSpansFromCloudWithCache(ctx context.Context, client *api.TuskClient, auth api.AuthOptions, ...) ([]*core.Span, error)

+ func GetFirstSpanTimestamp(spans []*core.Span) (float64, string)

+ func OutputResultsSummary(results []TestResult, format string, quiet bool) error

+ func OutputSingleResult(result TestResult, test Test, format string, quiet bool, verbose bool)

+ func PrepareAndSetSuiteSpans(ctx context.Context, exec *Executor, opts SuiteSpanOptions, ...) error

+ func PrepareReplayEnvironmentGroup(executor *Executor, group *EnvironmentGroup) (cleanup func(), err error)

+ func ReportDriftRunSuccess(ctx context.Context, client *api.TuskClient, driftRunID string, ...) error

+ func UploadSingleTestResult(ctx context.Context, client *api.TuskClient, driftRunID string, ...) error

+ type BuildSuiteSpansResult struct

+ GlobalSpans []*core.Span

+ PreAppStartCount int

+ SuiteSpans []*core.Span

+ UniqueTraceCount int

+ func BuildSuiteSpansForRun(ctx context.Context, opts SuiteSpanOptions, currentTests []Test) (*BuildSuiteSpansResult, error)

+ type CommunicationType string

+ const CommunicationTCP

+ const CommunicationUnix

+ type Deviation struct

+ Actual any

+ Description string

+ Expected any

+ Field string

+ type DynamicFieldMatcher struct

+ func NewDynamicFieldMatcher() *DynamicFieldMatcher

+ func NewDynamicFieldMatcherWithConfig(cfg *config.ComparisonConfig) *DynamicFieldMatcher

+ func (m *DynamicFieldMatcher) ShouldIgnoreField(fieldName string, expectedValue, actualValue any, testID string) bool

+ type EnvironmentExtractionResult struct

+ Groups []*EnvironmentGroup

+ Warnings []string

+ func GroupTestsByEnvironment(tests []Test, preAppStartSpans []*core.Span) (*EnvironmentExtractionResult, error)

+ type EnvironmentGroup struct

+ EnvVars map[string]string

+ EnvVarsSpan *core.Span

+ Name string

+ Tests []Test

+ type Executor struct

+ OnTestCompleted func(TestResult, Test)

+ ResultsFile string

+ func NewExecutor() *Executor

+ func (e *Executor) CancelTests()

+ func (e *Executor) CheckServerHealth() bool

+ func (e *Executor) DiscardStartupBuffer()

+ func (e *Executor) ForceStopEnvironment() error

+ func (e *Executor) GetConcurrency() int

+ func (e *Executor) GetEffectiveSandboxMode() string

+ func (e *Executor) GetSandboxMode() string

+ func (e *Executor) GetServer() *Server

+ func (e *Executor) GetServiceLogPath() string

+ func (e *Executor) GetStartupFailureHelpMessage() string

+ func (e *Executor) GetStartupLogs() string

+ func (e *Executor) GetSuiteSpans() []*core.Span

+ func (e *Executor) IsServiceLogsEnabled() bool

+ func (e *Executor) LoadSpansForTrace(traceID string, filename string) ([]*core.Span, error)

+ func (e *Executor) LoadTestFromTraceFile(path string) (*Test, error)

+ func (e *Executor) LoadTestsFromFolder(folder string) ([]Test, error)

+ func (e *Executor) RestartServerWithRetry(attempt int) error

+ func (e *Executor) RunBatchSequentialWithCrashHandling(batch []Test, hasMoreTestsAfterBatch bool) []TestResult

+ func (e *Executor) RunBatchWithCrashDetection(batch []Test, concurrency int) ([]TestResult, bool)

+ func (e *Executor) RunSingleTest(test Test) (TestResult, error)

+ func (e *Executor) RunTests(tests []Test) ([]TestResult, error)

+ func (e *Executor) RunTestsConcurrently(tests []Test, maxConcurrency int) ([]TestResult, error)

+ func (e *Executor) SetAllowSuiteWideMatching(enabled bool)

+ func (e *Executor) SetConcurrency(concurrency int)

+ func (e *Executor) SetDebug(debug bool)

+ func (e *Executor) SetEnableServiceLogs(enable bool)

+ func (e *Executor) SetGlobalSpans(spans []*core.Span)

+ func (e *Executor) SetOnTestCompleted(callback func(TestResult, Test))

+ func (e *Executor) SetReplayEnvVars(envVars map[string]string)

+ func (e *Executor) SetReplaySandboxConfigPath(path string)

+ func (e *Executor) SetResultsOutput(dir string)

+ func (e *Executor) SetSandboxMode(mode string) error

+ func (e *Executor) SetSuiteSpans(spans []*core.Span)

+ func (e *Executor) SetTestTimeout(timeout time.Duration)

+ func (e *Executor) StartEnvironment() error

+ func (e *Executor) StartServer() error

+ func (e *Executor) StartService() error

+ func (e *Executor) StopEnvironment() error

+ func (e *Executor) StopServer() error

+ func (e *Executor) StopService() error

+ func (e *Executor) WaitForSDKAcknowledgement() error

+ func (e *Executor) WaitForSpanData(traceID string, timeout time.Duration)

+ func (e *Executor) WriteRunResultsToFile(tests []Test, results []TestResult) (string, error)

+ type MatchEvent struct

+ InputData map[string]any

+ MatchLevel *core.MatchLevel

+ ReplaySpan *core.Span

+ SpanID string

+ StackTrace string

+ Timestamp time.Time

+ type MessageType string

+ const MessageTypeMockRequest

+ const MessageTypeSDKConnect

+ type MockMatcher struct

+ func NewMockMatcher(server *Server) *MockMatcher

+ func (mm *MockMatcher) FindBestMatchAcrossTraces(req *core.GetMockRequest, traceID string, spans []*core.Span) (*core.Span, *core.MatchLevel, error)

+ func (mm *MockMatcher) FindBestMatchWithTracePriority(req *core.GetMockRequest, traceID string) (*core.Span, *core.MatchLevel, error)

+ type MockMatcherRequestData struct

+ InputSchema *core.JsonSchema

+ InputSchemaHash string

+ InputValue any

+ InputValueHash string

+ type MockNotFoundEvent struct

+ Error string

+ Operation string

+ PackageName string

+ ReplaySpan *core.Span

+ SpanName string

+ StackTrace string

+ Timestamp time.Time

+ type Request struct

+ Body any

+ Headers map[string]string

+ Method string

+ Path string

+ type Response struct

+ Body any

+ Headers map[string]string

+ Status int

+ type SemVer struct

+ type Server struct

+ func NewServer(serviceID string, cfg *config.ServiceConfig) (*Server, error)

+ func (ms *Server) AllowSuiteWideMatching() bool

+ func (ms *Server) CleanupTraceSpans(traceID string)

+ func (ms *Server) GetAnalyticsClient() *analytics.Client

+ func (ms *Server) GetCommunicationType() CommunicationType

+ func (ms *Server) GetConnectionInfo() (string, int)

+ func (ms *Server) GetGlobalSpansByReducedValueHash(reducedHash string) []*core.Span

+ func (ms *Server) GetGlobalSpansByValueHash(valueHash string) []*core.Span

+ func (ms *Server) GetInboundReplaySpan(traceID string) *core.Span

+ func (ms *Server) GetMatchEvents(traceID string) []MatchEvent

+ func (ms *Server) GetMockNotFoundEvents(traceID string) []MockNotFoundEvent

+ func (ms *Server) GetRootSpanID(traceID string) string

+ func (ms *Server) GetSDKRuntime() core.Runtime

+ func (ms *Server) GetSDKVersion() string

+ func (ms *Server) GetSocketPath() string

+ func (ms *Server) GetSpansByPackageForTrace(traceID string, packageName string) []*core.Span

+ func (ms *Server) GetSpansByReducedValueHashForTrace(traceID string, reducedHash string) []*core.Span

+ func (ms *Server) GetSpansByValueHashForTrace(traceID string, valueHash string) []*core.Span

+ func (ms *Server) GetSuiteSpans() []*core.Span

+ func (ms *Server) GetSuiteSpansByPackage(packageName string) []*core.Span

+ func (ms *Server) GetSuiteSpansByReducedSchemaHash(reducedSchemaHash string) []*core.Span

+ func (ms *Server) GetSuiteSpansByReducedValueHash(reducedHash string) []*core.Span

+ func (ms *Server) GetSuiteSpansBySchemaHash(schemaHash string) []*core.Span

+ func (ms *Server) GetSuiteSpansByValueHash(valueHash string) []*core.Span

+ func (ms *Server) HasMockNotFoundEvents(traceID string) bool

+ func (ms *Server) LoadSpansForTrace(traceID string, spans []*core.Span)

+ func (ms *Server) SendSetTimeTravel(timestampSeconds float64, traceID string, timestampSource string) error

+ func (ms *Server) SetAllowSuiteWideMatching(enabled bool)

+ func (ms *Server) SetCurrentTestID(id string)

+ func (ms *Server) SetGlobalSpans(spans []*core.Span)

+ func (ms *Server) SetSuiteSpans(spans []*core.Span)

+ func (ms *Server) Start() error

+ func (ms *Server) Stop() error

+ func (ms *Server) WaitForInboundSpan(traceID string, timeout time.Duration)

+ func (ms *Server) WaitForSDKConnection(timeout time.Duration) error

+ func (ms *Server) WaitForSpanData(traceID string, timeout time.Duration)

+ type SuiteSpanOptions struct

+ AllowSuiteWideMatching bool

+ AuthOptions api.AuthOptions

+ Client *api.TuskClient

+ Interactive bool

+ IsCloudMode bool

+ PreloadedGlobalSpans []*core.Span

+ PreloadedPreAppStartSpans []*core.Span

+ Quiet bool

+ ServiceID string

+ TraceTestID string

+ type Test struct

+ DisplayName string

+ DisplayType string

+ Duration int

+ Environment string

+ FileName string

+ Metadata map[string]any

+ Method string

+ Path string

+ Request Request

+ Response Response

+ Spans []*core.Span

+ Status string

+ Timestamp string

+ TraceID string

+ TraceTestID string

+ Type string

+ func ConvertTraceTestToRunnerTest(tt *backend.TraceTest) Test

+ func ConvertTraceTestsToRunnerTests(traceTests []*backend.TraceTest) []Test

+ func FilterLocalTestsForExecution(tests []Test) (testsToExecute []Test, excludedCount int)

+ func FilterTests(tests []Test, pattern string) ([]Test, error)

+ type TestResult struct

+ Cancelled bool

+ CrashedServer bool

+ Deviations []Deviation

+ Duration int

+ Error string

+ Passed bool

+ RetriedAfterCrash bool

+ TestID string

+ func ReplayTestsByEnvironment(ctx context.Context, executor *Executor, groups []*EnvironmentGroup) ([]TestResult, error)

+ type Trace struct

+ Filename string

+ ID string

+ Spans []*core.Span

+ Timestamp string

+ type ValidateExecutor struct

+ func NewValidateExecutor(base *Executor) *ValidateExecutor

+ func (ve *ValidateExecutor) ValidateDraftTraces(ctx context.Context, tests []Test) ([]ValidationResult, error)

+ type ValidationResult struct

+ Duration time.Duration

+ FailureReason string

+ Passed bool

+ TraceID string

+ TraceTestID string

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