sim

package

Go to main page

Versions in this module

v0

v0.11.0

Aug 13, 2026

Changes in this version

type SimReport

+ Mode ExecMode

+ Scenario string

v0.10.0

Jul 24, 2026

Changes in this version

+ func ParallelAggregateVariantPair() (EngineVariant, EngineVariant)

type Trace

+ func ParallelAggregateTrace() Trace

v0.9.0

Jul 19, 2026

v0.8.1

Jul 14, 2026

v0.8.0

Jul 14, 2026

Changes in this version

+ const ScenarioCSRFilePublishFault

+ const ScenarioCheckpointDirFsyncFault

+ const ScenarioCheckpointTeardown

+ const ScenarioDurableCommitCrash

+ const ScenarioIORoundTripFault

+ const ScenarioMergeRel

+ const ScenarioReadTxIsolation

+ const ScenarioSchemaMutation

+ const ScenarioWALCorruptionFailStop

type ConcurrentResult

+ AckedNames []string

+ FailedNames []string

+ IssuedNames []string

type DiskConfig

+ FaultRate float64

+ type MergeRelWriter struct

+ func (MergeRelWriter) Name() string

+ func (MergeRelWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

+ type SchemaMutationWriter struct

+ func (SchemaMutationWriter) Name() string

+ func (SchemaMutationWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

type SimDisk

+ func (d *SimDisk) ArmParentDirSyncFaultForPath(childPath string)

+ func (d *SimDisk) ArmSyncFaultAt(at int64)

+ func (d *SimDisk) CorruptRange(path string, off int64, n int) error

+ func (d *SimDisk) FaultRate() float64

+ func (d *SimDisk) SyncCount() int64

type Violation

+ func CheckCypherSurfaceExtended(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

+ func CheckExprLiterals(tick int64, engine *EngineAdapter) []Violation

+ func CheckMergeRel(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

+ func CheckSchemaMutation(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

v0.7.0

Jul 3, 2026

v0.6.0

Jun 28, 2026

Changes in this version

+ const ScenarioCPUStarvation

+ const ScenarioConstraintEnforce

+ const ScenarioConstraintExistence

+ const ScenarioCypherPaths

+ const ScenarioCypherSurface

+ const ScenarioDiskFull

+ const ScenarioEdgeProperties

+ const ScenarioIndexDiversity

+ const ScenarioMemPressure

+ const ScenarioSearch

+ const ScenarioSearchCrash

+ const ScenarioTypeCoverage

+ func ParallelScanVariantPair() (EngineVariant, EngineVariant)

type CheckSelection

+ Search bool

+ type CheckpointConfig struct

+ Dir string

+ Enabled bool

+ Every int

type Config

+ Checkpoint CheckpointConfig

+ Disk DiskConfig

+ EngineOpts cypher.EngineOptions

+ type DiskConfig struct

+ CapacityBytes int64

+ ENOSPCOnSync bool

+ type EdgeByName struct

+ Dst string

+ Props map[string]any

+ Src string

+ type EdgePropsWriter struct

+ func (*EdgePropsWriter) Name() string

+ func (w *EdgePropsWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

type GraphOracle

+ func (o *GraphOracle) ExistenceOnEmail() bool

+ func (o *GraphOracle) HasKnowsByName(a, b string) bool

+ func (o *GraphOracle) KnowsEdgesByName() []EdgeByName

+ func (o *GraphOracle) SetExistenceOnEmail(active bool)

+ func (o *GraphOracle) SetUniqueOnName(active bool)

+ func (o *GraphOracle) TypedIDs() []int64

+ func (o *GraphOracle) TypedNode(id int64) (map[string]any, bool)

+ func (o *GraphOracle) UniqueOnName() bool

type IndexSpec

+ Numeric bool

+ type OverloadReader struct

+ func (OverloadReader) Name() string

+ func (OverloadReader) NextOp(seed *Seed, _ *GraphOracle) Op

type Scenario

+ Checkpoint CheckpointConfig

+ Disk DiskConfig

+ EngineOpts cypher.EngineOptions

+ SearchEvery int

type SimDisk

+ func (d *SimDisk) Crash()

+ func (d *SimDisk) DirSync(dir string) error

+ func (d *SimDisk) ParentDirSync(childPath string) error

+ func (d *SimDisk) ReadFile(path string) ([]byte, error)

+ func (d *SimDisk) RemoveAll(path string) error

+ func (d *SimDisk) SetCapacity(capacityBytes int64, enospcOnSync bool)

+ func (d *SimDisk) Stat(path string) (fs.FileInfo, error)

+ func (d *SimDisk) TruncatePath(path string, size int64) error

type SimFileHandle

+ func (h *SimFileHandle) Stat() (fs.FileInfo, error)

type SimStore

+ func (s *SimStore) Checkpoint() error

+ func (s *SimStore) Config() simStoreConfig

type Simulator

+ func (s *Simulator) CheckpointCount() int

+ func (s *Simulator) Disk() *SimDisk

+ func (s *Simulator) RejectedReads() int

+ func (s *Simulator) RejectedWrites() int

+ type SurfaceWriter struct

+ func (*SurfaceWriter) Name() string

+ func (w *SurfaceWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

+ type TypedWriter struct

+ func (*TypedWriter) Name() string

+ func (w *TypedWriter) NextOp(seed *Seed, _ *GraphOracle) Op

type Violation

+ func CheckCypherSurface(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

+ func CheckEdgeProperties(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

+ func CheckSearch(tick int64, oracle *GraphOracle, engine Engine) []Violation

+ func CheckShortestPath(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

+ func CheckTypedProperties(tick int64, oracle *GraphOracle, engine *EngineAdapter) []Violation

type ViolationKind

+ const ViolationSearchDivergence

type Workload

+ func MemPressureWorkload(_ *Seed) *Workload

v0.5.0

Jun 17, 2026

v0.4.0

Jun 17, 2026

Changes in this version

+ const ScenarioBadActors

+ const ScenarioBulkVsOnline

+ const ScenarioCrashStorm

+ const ScenarioLongRunning

+ const ScenarioOverload

+ const ScenarioReadHeavy

+ const ScenarioSchemaChaos

+ const ScenarioWriteHeavy

+ var ErrSimConnClosed = errors.New("sim: SimConn is closed")

+ var ErrSimFault = errors.New("sim: injected disk fault")

+ var ErrSimListenerClosed = errors.New("sim: SimListener is closed")

+ func CheckCorruptImageRejected(ctx context.Context, seed uint64) error

+ func DefaultVariantPair() (EngineVariant, EngineVariant)

+ func RangeSeekVariantPair() (EngineVariant, EngineVariant)

+ func RecordTrace(ctx context.Context, cfg Config) (Trace, *SimReport, error)

+ func ReplayInstructions(trace Trace) string

+ func RunSwarmWithMetricsOracle(ctx context.Context, sw *Swarm, goroutineSlack int) (SwarmResult, MetricsOracleResult, error)

+ func SimEngineForServer() *cypher.Engine

+ type AbuseFamily int

+ const AbuseBadHandshake

+ const AbuseDuplicateHello

+ const AbuseGarbageOpcode

+ const AbuseNoCommonVersion

+ const AbuseOversizedChunk

+ const AbusePullBeforeRun

+ const AbuseRunBeforeLogon

+ const AbuseTruncatedChunk

+ func (f AbuseFamily) String() string

+ type AbuseOutcome struct

+ FailureMsg string

+ Family AbuseFamily

+ GotClose bool

+ GotFailure bool

+ func (o AbuseOutcome) Acceptable() bool

+ type Actor interface

+ Name func() string

+ NextOp func(seed *Seed, oracle *GraphOracle) Op

+ type BoltAbuser struct

+ func (BoltAbuser) Name() string

+ func (BoltAbuser) PickFamily(seed *Seed) AbuseFamily

+ func (a BoltAbuser) Abuse(srv *SimServer, family AbuseFamily) (AbuseOutcome, error)

+ type BoundedChurnWriter struct

+ func (BoundedChurnWriter) Name() string

+ func (BoundedChurnWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

+ type CheckSelection struct

+ IndexConsistency bool

+ IndexSpecs []IndexSpec

+ type ConcurrentConfig struct

+ Connections int

+ Mix *ConcurrentMix

+ OpsPerConn int

+ Seed uint64

+ type ConcurrentMix struct

+ OverloadWeight float64

+ ReaderWeight float64

+ WriterWeight float64

+ type ConcurrentResult struct

+ AckedCreates int64

+ BaselineRoutines int

+ BoundedRejects int64

+ Connections int

+ EngineNodeCount int64

+ FinalRoutines int

+ Panics int64

+ Seed uint64

+ TransportErrors int64

+ func RunConcurrent(ctx context.Context, srv *SimServer, cfg ConcurrentConfig) (ConcurrentResult, error)

+ func (r ConcurrentResult) Consistent() bool

+ type Config struct

+ CheckEvery int

+ Crash CrashConfig

+ MaxTicks int

+ OnCrash func(tick int64, replayedWALOps int)

+ OnOp func(tick int64, op Op)

+ Seed uint64

+ Workload *Workload

+ type CoverageBucket struct

+ Count int

+ Dimension string

+ Key string

+ func (b CoverageBucket) Exercised() bool

+ type CoverageSummary struct

+ Buckets []CoverageBucket

+ Exercised int

+ Unexplored int

+ func (s CoverageSummary) String() string

+ type CoverageTracker struct

+ func NewCoverageTracker(scenarios []string) *CoverageTracker

+ func (ct *CoverageTracker) Record(run SwarmRun)

+ func (ct *CoverageTracker) ScenarioCoverage() map[string]int

+ func (ct *CoverageTracker) Select(_ int, defaultScenario string) string

+ func (ct *CoverageTracker) Summary() CoverageSummary

+ func (ct *CoverageTracker) UnobservableSignals() []string

+ type CrashConfig struct

+ CrashProb float64

+ Enabled bool

+ StabilityWindow int64

+ type CrashSchedule struct

+ func NewCrashSchedule(seed *Seed, cfg CrashConfig) *CrashSchedule

+ func (c *CrashSchedule) Enabled() bool

+ func (c *CrashSchedule) LastCrashTick() int64

+ func (c *CrashSchedule) ShouldCrash(tick int64) bool

+ type CrossReleaseDiffResult struct

+ Agreed bool

+ CurrentEdges int64

+ CurrentNodes int64

+ Divergences []CrossReleaseDivergence

+ FinalCountsMatch bool

+ PriorEdges int64

+ PriorNodes int64

+ Tag string

+ func RunCrossReleaseDifferential(ctx context.Context, repoRoot, tag string, seed uint64, ops int) (CrossReleaseDiffResult, error)

+ func (r CrossReleaseDiffResult) String() string

+ type CrossReleaseDivergence struct

+ Benign bool

+ CurrentRows string

+ Index int

+ Op Op

+ PriorRows string

+ Reason string

+ type CrossReleaseUpgradeResult struct

+ CountMismatch string

+ DataCompatError error

+ PriorLiveEdges int64

+ PriorLiveNodes int64

+ PriorSelfEdges int64

+ PriorSelfNodes int64

+ PriorWALFidelityGap bool

+ RecoveredEdges int64

+ RecoveredNodes int64

+ ReplayedWALOps int

+ Tag string

+ func RunCrossReleaseUpgrade(ctx context.Context, repoRoot, tag string, seed uint64, ops int) (CrossReleaseUpgradeResult, error)

+ func (r *CrossReleaseUpgradeResult) Parity() bool

+ func (r CrossReleaseUpgradeResult) String() string

+ type DiffResult struct

+ Agreed bool

+ DivergedAt int

+ DivergedOp Op

+ Reason string

+ SignatureA string

+ SignatureB string

+ VariantA string

+ VariantB string

+ func DifferentialTrace(ctx context.Context, trace Trace, a, b *EngineVariant) (DiffResult, error)

+ func DifferentialTraceInjectB(ctx context.Context, trace Trace, a, b *EngineVariant, injectAt int) (DiffResult, error)

+ func (r DiffResult) String() string

+ type EdgeState struct

+ DstID uint64

+ Label string

+ Properties map[string]any

+ SrcID uint64

+ type Engine interface

+ EdgeCount func() (int64, error)

+ NodeCount func() (int64, error)

+ Run func(ctx context.Context, query string, params map[string]any) (Result, error)

+ type EngineAdapter struct

+ func NewEngineAdapter(eng *cypher.Engine) *EngineAdapter

+ func (a *EngineAdapter) EdgeCount() (int64, error)

+ func (a *EngineAdapter) NodeCount() (int64, error)

+ func (a *EngineAdapter) Run(ctx context.Context, query string, params map[string]any) (Result, error)

+ func (a *EngineAdapter) RunWrite(ctx context.Context, query string, params map[string]any) (Result, error)

+ type EngineVariant struct

+ Name string

+ Options cypher.EngineOptions

+ type ExecMode int

+ const ModeBulkVsOnline

+ const ModeConcurrent

+ const ModeDeterministic

+ const ModeLiveness

+ func (m ExecMode) Reproducible() bool

+ func (m ExecMode) String() string

+ type GraphOracle struct

+ func NewGraphOracle() *GraphOracle

+ func (o *GraphOracle) ApplyCreate(cypher string, params map[string]any) OracleResult

+ func (o *GraphOracle) ApplyDelete(cypher string, params map[string]any) OracleResult

+ func (o *GraphOracle) ApplyMalformed(cypher string, params map[string]any) OracleResult

+ func (o *GraphOracle) ApplyMatch(cypher string, params map[string]any) OracleResult

+ func (o *GraphOracle) ApplyMerge(cypher string, params map[string]any) OracleResult

+ func (o *GraphOracle) EdgeCount() int

+ func (o *GraphOracle) HasEdge(src, dst uint64, label string) bool

+ func (o *GraphOracle) HasNode(id uint64) bool

+ func (o *GraphOracle) NodeCount() int

+ func (o *GraphOracle) NodeNames() []string

+ func (o *GraphOracle) Ops() []OracleOp

+ func (o *GraphOracle) String() string

+ type HelperOpResult struct

+ Committed bool

+ Rows string

+ type HelperRunResult struct

+ Edges int64

+ Nodes int64

+ Ops []HelperOpResult

+ type HonestReader struct

+ func (HonestReader) Name() string

+ func (HonestReader) NextOp(seed *Seed, _ *GraphOracle) Op

+ type HonestWriter struct

+ func (HonestWriter) Name() string

+ func (w HonestWriter) NextOp(seed *Seed, oracle *GraphOracle) Op

+ type IndexSpec struct

+ Label string

+ Property string

+ type InvariantChecker struct

+ func NewInvariantChecker(seed *Seed) *InvariantChecker

+ func (c *InvariantChecker) Check(tick int64, oracle *GraphOracle, engine Engine) []Violation

+ func (c *InvariantChecker) CheckDurability(tick int64, oracle *GraphOracle, engine Engine) []Violation

+ func (c *InvariantChecker) ChecksRun() int

+ func (c *InvariantChecker) HasViolations() bool

+ func (c *InvariantChecker) Violations() []Violation

+ type LivenessConfig struct

+ Connections int

+ ConvergeBudget time.Duration

+ NoProgressGrace int

+ OpsPerConn int

+ PollStep time.Duration

+ Seed uint64

+ type LivenessOutcome struct

+ Converged bool

+ FinalPending PendingState

+ Resonance bool

+ Seed uint64

+ Ticks int

+ func RunLiveness(ctx context.Context, srv *SimServer, clk clock.Clock, cfg LivenessConfig) (LivenessOutcome, error)

+ func (o LivenessOutcome) Report() string

+ type MalformedSender struct

+ func (MalformedSender) Name() string

+ func (m MalformedSender) NextOp(seed *Seed, _ *GraphOracle) Op

+ type MetricsOracle struct

+ func NewMetricsOracle() *MetricsOracle

+ func (o *MetricsOracle) Check(before, after MetricsSnapshot, expectedWrites, expectedWriteErrors uint64, ...) MetricsOracleResult

+ func (o *MetricsOracle) CheckGoroutineBaseline(before, after MetricsSnapshot, goroutineSlack int) MetricsOracleResult

+ func (o *MetricsOracle) Restore()

+ func (o *MetricsOracle) Snapshot() MetricsSnapshot

+ type MetricsOracleResult struct

+ After MetricsSnapshot

+ Before MetricsSnapshot

+ Discrepancies []string

+ ExpectedWriteErrors uint64

+ ExpectedWrites uint64

+ func RunWithMetricsOracle(ctx context.Context, seed uint64, ops int, wlFactory func(*Seed) *Workload) (MetricsOracleResult, error)

+ func (r *MetricsOracleResult) Consistent() bool

+ func (r *MetricsOracleResult) String() string

+ type MetricsRunStats struct

+ WriteErrors uint64

+ Writes uint64

+ type MetricsSnapshot struct

+ Goroutines int

+ RunCount uint64

+ RunErrors uint64

+ RunInTxCount uint64

+ RunInTxErrors uint64

+ type NodeState struct

+ ID uint64

+ Labels []string

+ Properties map[string]any

+ type Op struct

+ Cypher string

+ Kind OpKind

+ Params map[string]any

+ func GenerateCrossReleaseOps(seed uint64, n int) ([]Op, error)

+ type OpKind string

+ const OpCreate

+ const OpDelete

+ const OpMalformed

+ const OpMatch

+ const OpMerge

+ const OpUpdate

+ func (k OpKind) IsWrite() bool

+ type OracleOp struct

+ Cypher string

+ Expected OracleResult

+ Params map[string]any

+ Tick int64

+ type OracleResult struct

+ Committed bool

+ EdgesCreated int

+ ErrorMsg string

+ NodesCreated int

+ type OracleSnapshot struct

+ EdgeCount int

+ NodeCount int

+ OpCount int

+ type OverloadActor struct

+ func (OverloadActor) Name() string

+ func (OverloadActor) PickFamily(seed *Seed) OverloadFamily

+ func (a OverloadActor) Run(c *WireClient, family OverloadFamily) (OverloadOutcome, error)

+ type OverloadFamily int

+ const OverloadDeepVLE

+ const OverloadHugeUnwind

+ const OverloadLargeCreateTx

+ const OverloadLargeResultSet

+ func (f OverloadFamily) String() string

+ type OverloadOutcome struct

+ BoundedError bool

+ FailureMsg string

+ Family OverloadFamily

+ Rows int

+ Succeeded bool

+ func (o OverloadOutcome) Acceptable() bool

+ type PendingState struct

+ EngineNodeCount int64

+ ExpectedNodes int64

+ InFlightOps int

+ OracleDivergent bool

+ UngatedStreams int

+ func (p PendingState) Magnitude() int

+ func (p PendingState) Pending() bool

+ func (p PendingState) String() string

+ type PriorReleaseHelper struct

+ BinPath string

+ Tag string

+ func BuildPriorReleaseHelper(ctx context.Context, repoRoot, tag string) (*PriorReleaseHelper, error)

+ func (h *PriorReleaseHelper) Close() error

+ func (h *PriorReleaseHelper) SelfRecoverCounts(ctx context.Context, dir string) (nodes, edges int64, err error)

+ func (h *PriorReleaseHelper) WriteImage(ctx context.Context, dir string, ops []Op) (HelperRunResult, error)

+ type Registry struct

+ func DefaultRegistry() (*Registry, error)

+ func NewRegistry(scenarios ...Scenario) (*Registry, error)

+ func (r *Registry) Len() int

+ func (r *Registry) Lookup(name string) (Scenario, bool)

+ func (r *Registry) Names() []string

+ func (r *Registry) Scenarios() []Scenario

+ type Result interface

+ Close func() error

+ Err func() error

+ IntAt func(i int) (int64, bool)

+ Next func() bool

+ RowCount func() int

+ ScalarInt func() (int64, bool)

+ StringAt func(i int) (string, bool)

+ type Scenario struct

+ CheckEvery int

+ Checks CheckSelection

+ Connections int

+ ConvergeBudget time.Duration

+ Crash CrashConfig

+ DefaultSeed uint64

+ Description string

+ MaxTicks int

+ Mix *ConcurrentMix

+ Mode ExecMode

+ Name string

+ OpsPerConn int

+ Workload func(*Seed) *Workload

+ func (sc *Scenario) DeterministicConfig(seed uint64) Config

+ func (sc *Scenario) Run(ctx context.Context, seed uint64) (*SimReport, error)

+ type ScenarioSelector interface

+ Select func(runIndex int, defaultScenario string) string

+ type SchemaChangeFamily int

+ const SchemaCreateConstraint

+ const SchemaCreateIndex

+ const SchemaDropConstraint

+ const SchemaDropIndex

+ func (f SchemaChangeFamily) String() string

+ type SchemaChangeOutcome struct

+ Failed bool

+ FailureMsg string

+ Family SchemaChangeFamily

+ Succeeded bool

+ func RunSchemaChurn(ctx context.Context, srv *SimServer, seed *Seed, rounds int) ([]SchemaChangeOutcome, error)

+ func (o SchemaChangeOutcome) Acceptable() bool

+ type SchemaChanger struct

+ func (SchemaChanger) Name() string

+ func (SchemaChanger) PickFamily(seed *Seed) SchemaChangeFamily

+ func (a SchemaChanger) Run(c *WireClient, family SchemaChangeFamily) (SchemaChangeOutcome, error)

+ type ScriptedResult struct

+ EdgeCount int64

+ NodeCount int64

+ OracleE int

+ OracleN int

+ Report *SimReport

+ func ReplayTrace(ctx context.Context, trace Trace) (ScriptedResult, error)

+ func (r ScriptedResult) Violated() bool

+ type Seed struct

+ func NewSeed(val uint64) *Seed

+ func (s *Seed) Bool(p float64) bool

+ func (s *Seed) Float64() float64

+ func (s *Seed) IntN(n int) int

+ func (s *Seed) Pick(items []string) string

+ func (s *Seed) Shuffle(items []string) []string

+ func (s *Seed) Uint64N(n uint64) uint64

+ func (s *Seed) Value() uint64

+ type ShrinkConfig struct

+ MaxIterations int

+ type ShrinkResult struct

+ Iterations int

+ Minimal Trace

+ MinimalLen int

+ OriginalLen int

+ Violation Violation

+ func ShrinkTrace(ctx context.Context, trace Trace, cfg ShrinkConfig) (ShrinkResult, error)

+ func (r *ShrinkResult) Ratio() float64

+ type SimConn struct

+ func NewSimConnPair(clk clock.Clock) (clientEnd, serverEnd *SimConn)

+ func (c *SimConn) Close() error

+ func (c *SimConn) CloseWithError(err error) error

+ func (c *SimConn) LocalAddr() net.Addr

+ func (c *SimConn) Read(p []byte) (int, error)

+ func (c *SimConn) ReadBuffered() int

+ func (c *SimConn) RemoteAddr() net.Addr

+ func (c *SimConn) SetDeadline(t time.Time) error

+ func (c *SimConn) SetReadDeadline(t time.Time) error

+ func (c *SimConn) SetWriteDeadline(t time.Time) error

+ func (c *SimConn) Write(p []byte) (int, error)

+ type SimDisk struct

+ func NewSimDisk(seed *Seed, faultRate float64) *SimDisk

+ func (d *SimDisk) Exists(path string) bool

+ func (d *SimDisk) MkdirAll(_ string, _ fs.FileMode) error

+ func (d *SimDisk) OpenFile(path string, flag int) (*SimFileHandle, error)

+ func (d *SimDisk) Remove(path string) error

+ func (d *SimDisk) Rename(oldPath, newPath string) error

+ func (d *SimDisk) Snapshot() map[string][]byte

+ type SimFileHandle struct

+ func (h *SimFileHandle) Close() error

+ func (h *SimFileHandle) Read(p []byte) (int, error)

+ func (h *SimFileHandle) Seek(offset int64, whence int) (int64, error)

+ func (h *SimFileHandle) Sync() error

+ func (h *SimFileHandle) Truncate(size int64) error

+ func (h *SimFileHandle) Write(p []byte) (int, error)

+ type SimListener struct

+ func NewSimListener(clk clock.Clock) *SimListener

+ func (l *SimListener) Accept() (net.Conn, error)

+ func (l *SimListener) Addr() net.Addr

+ func (l *SimListener) Close() error

+ func (l *SimListener) Dial() (*SimConn, error)

+ type SimReport struct

+ FailedOp Op

+ FailedTick int64

+ OracleState OracleSnapshot

+ Seed uint64

+ Shrunk *ShrinkResult

+ Violations []Violation

+ func (r *SimReport) String() string

+ type SimServer struct

+ func NewSimServer(eng *cypher.Engine, clk clock.Clock) (*SimServer, error)

+ func (s *SimServer) Close() error

+ func (s *SimServer) Dial() (*WireClient, error)

+ func (s *SimServer) DialConn() (*SimConn, error)

+ type SimStore struct

+ func OpenSimStore(disk *SimDisk, cfg simStoreConfig) (*SimStore, error)

+ func (s *SimStore) Clean() bool

+ func (s *SimStore) Close() error

+ func (s *SimStore) Crash()

+ func (s *SimStore) Engine() *cypher.Engine

+ func (s *SimStore) Graph() *lpg.Graph[string, float64]

+ func (s *SimStore) WALOps() int

+ type Simulator struct

+ func New(cfg Config) (*Simulator, error)

+ func (s *Simulator) Close() error

+ func (s *Simulator) CrashCount() int

+ func (s *Simulator) Oracle() *GraphOracle

+ func (s *Simulator) ReplayedOps() int

+ func (s *Simulator) Run(ctx context.Context) (*SimReport, error)

+ type SlowConsumer struct

+ func NewSlowConsumer(clk clock.Clock) *SlowConsumer

+ func (*SlowConsumer) Name() string

+ func (s *SlowConsumer) Stall(ctx context.Context, srv *SimServer, stallFor time.Duration, ...) (SlowConsumerResult, error)

+ type SlowConsumerResult struct

+ ClosedCleanly bool

+ RecordsPulled int

+ ServerParked bool

+ type Swarm struct

+ func NewSwarm(reg *Registry, cfg *SwarmConfig) (*Swarm, error)

+ func (s *Swarm) Run(ctx context.Context) (SwarmResult, error)

+ type SwarmConfig struct

+ Clock clock.Clock

+ Duration time.Duration

+ MasterSeed uint64

+ Observe func(SwarmRun)

+ Runs int

+ Scenario string

+ Selector ScenarioSelector

+ Workers int

+ type SwarmResult struct

+ Elapsed time.Duration

+ Failures []SwarmRun

+ MasterSeed uint64

+ Passes int

+ Runs int

+ Workers int

+ func (r SwarmResult) FailureCount() int

+ func (r SwarmResult) Summary() string

+ func (r SwarmResult) Throughput() float64

+ type SwarmRun struct

+ Err error

+ Index int

+ Report *SimReport

+ Scenario string

+ Seed uint64

+ func (r SwarmRun) Failed() bool

+ func (r SwarmRun) ReproduceLine() string

+ type Trace struct

+ CrashTicks []int64

+ Ops []TracedOp

+ Seed uint64

+ func (t Trace) Len() int

+ type TraceFault string

+ const FaultDropEngineWrite

+ const FaultNone

+ type TracedOp struct

+ Fault TraceFault

+ Op Op

+ Tick int64

+ type UpgradeConfig struct

+ IndexSpecs []IndexSpec

+ Ops int

+ Seed uint64

+ Workload func(*Seed) *Workload

+ type UpgradeResult struct

+ RecoveredEdges int64

+ RecoveredNodes int64

+ ReplayedWALOps int

+ Report *SimReport

+ WrittenEdges int

+ WrittenNodes int

+ func RunUpgrade(ctx context.Context, cfg UpgradeConfig) (UpgradeResult, error)

+ func (r UpgradeResult) Parity() bool

+ type Violation struct

+ Kind ViolationKind

+ Message string

+ Op string

+ Tick int64

+ func CheckIndexConsistency(tick int64, _ *GraphOracle, engine indexConsistencyEngine, specs ...IndexSpec) []Violation

+ func (v Violation) String() string

+ type ViolationKind string

+ const ViolationACIDAtomicity

+ const ViolationACIDConsistency

+ const ViolationACIDDurability

+ const ViolationACIDIsolation

+ const ViolationGraphIntegrity

+ const ViolationOracleDeviation

+ type VirtualClock struct

+ func NewVirtualClock(tickSize time.Duration) *VirtualClock

+ func (c *VirtualClock) Now() int64

+ func (c *VirtualClock) SimulatedTime() time.Duration

+ func (c *VirtualClock) Tick() int64

+ type WireClient struct

+ func NewWireClient(conn *SimConn, clk clock.Clock) *WireClient

+ func (c *WireClient) Begin() (any, error)

+ func (c *WireClient) Close() error

+ func (c *WireClient) Commit() (any, error)

+ func (c *WireClient) Conn() *SimConn

+ func (c *WireClient) Connect(ctx context.Context) error

+ func (c *WireClient) Goodbye() error

+ func (c *WireClient) Handshake(_ context.Context) (proto.Version, error)

+ func (c *WireClient) Hello(extra map[string]packstream.Value) (any, error)

+ func (c *WireClient) Logon() (any, error)

+ func (c *WireClient) Pull(n int64) (records []*proto.Record, terminal any, err error)

+ func (c *WireClient) PullAll() (records []*proto.Record, terminal any, err error)

+ func (c *WireClient) Recv() (any, error)

+ func (c *WireClient) RecvRaw() ([]byte, error)

+ func (c *WireClient) Request(msg any) (any, error)

+ func (c *WireClient) Reset() (any, error)

+ func (c *WireClient) Rollback() (any, error)

+ func (c *WireClient) Run(query string, params map[string]any) (any, error)

+ func (c *WireClient) Version() proto.Version

+ func (c *WireClient) WriteChunkedRaw(payload []byte) error

+ func (c *WireClient) WriteRaw(p []byte) (int, error)

+ type WireExchange struct

+ Op string

+ Response string

+ type WireTranscript struct

+ Exchanges []WireExchange

+ Seed uint64

+ func RunLockStepWire(seed uint64, nOps int) (WireTranscript, error)

+ func (t WireTranscript) Equal(other WireTranscript) bool

+ type Workload struct

+ Actors []Actor

+ Weights []float64

+ func BadActorWorkload(_ *Seed) *Workload

+ func DefaultWorkload(_ *Seed) *Workload

+ func ReadHeavyWorkload(_ *Seed) *Workload

+ func SteadyStateWorkload(_ *Seed) *Workload

+ func WriteHeavyWorkload(_ *Seed) *Workload

+ func (w *Workload) SelectActor(seed *Seed) Actor

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