Versions in this module Expand all Collapse all v1 v1.1.0 Mar 15, 2026 v1.0.1 Nov 22, 2025 Changes in this version + type ChaosScenario struct + Description string + Duration time.Duration + Faults []*FaultConfig + Injector *FaultInjector + Name string + func NewChaosScenario(name, description string, duration time.Duration, logger Logger) *ChaosScenario + func NewCombinedChaosScenario(logger Logger) *ChaosScenario + func NewIntermittentErrorScenario(logger Logger) *ChaosScenario + func NewRandomLatencyScenario(logger Logger) *ChaosScenario + func NewSlowNetworkScenario(logger Logger) *ChaosScenario + func (cs *ChaosScenario) AddFault(config *FaultConfig) + func (cs *ChaosScenario) Run(ctx context.Context, testFunc func(context.Context) error) error + type FaultConfig struct + Delay time.Duration + Duration time.Duration + Enabled bool + ErrorMsg string + Probability float64 + Type FaultType + type FaultInjector struct + func NewFaultInjector(logger Logger) *FaultInjector + func (fi *FaultInjector) AddFault(config *FaultConfig) + func (fi *FaultInjector) Disable() + func (fi *FaultInjector) Enable() + func (fi *FaultInjector) GetStats() map[FaultType]int + func (fi *FaultInjector) InjectError(operation string) error + func (fi *FaultInjector) InjectLatency(ctx context.Context, operation string) error + func (fi *FaultInjector) InjectSlowResponse(ctx context.Context, operation string) error + func (fi *FaultInjector) RemoveFault(faultType FaultType) + func (fi *FaultInjector) Reset() + func (fi *FaultInjector) ShouldInjectFault(faultType FaultType) bool + type FaultType string + const FaultTypeDataLoss + const FaultTypeDisconnect + const FaultTypeError + const FaultTypeLatency + const FaultTypePartition + const FaultTypeSlowResponse + type Logger interface + Error func(msg string, fields map[string]interface{}) + Info func(msg string, fields map[string]interface{}) + Warn func(msg string, fields map[string]interface{}) + type NetworkPartitionSimulator struct + func NewNetworkPartitionSimulator(logger Logger) *NetworkPartitionSimulator + func (nps *NetworkPartitionSimulator) HealAll() + func (nps *NetworkPartitionSimulator) HealPartition(from, to string) + func (nps *NetworkPartitionSimulator) IsPartitioned(from, to string) bool + func (nps *NetworkPartitionSimulator) PartitionNodes(from, to string)
Go to main page