engine

type ActionHandler func(ctx context.Context, client ContainerRuntime, target string, spec config.ActionSpec) (*ContainerInfo, error)

type ChaosEngine struct {
	// contains filtered or unexported fields
}

type ComposeFile struct {
	Services map[string]ComposeService `yaml:"services"`
}

type ComposeService struct {
	Image       string             `yaml:"image"`
	Deploy      *DeployConfig      `yaml:"deploy"`
	Restart     string             `yaml:"restart"`
	HealthCheck *HealthCheckConfig `yaml:"healthcheck"`
	Privileged  bool               `yaml:"privileged"`
	Networks    interface{}        `yaml:"networks"` // Can be list or map
}

type ContainerInfo struct {
	ID     string            `json:"id"`
	Name   string            `json:"name"`
	Image  string            `json:"image"`
	Status string            `json:"status"`
	Ports  map[string]string `json:"ports"`
}

type ContainerRuntime interface {
	StopContainer(ctx context.Context, name string, timeout int) (*ContainerInfo, error)
	RestartContainer(ctx context.Context, name string, timeout int) (*ContainerInfo, error)
	PauseContainer(ctx context.Context, name string) (*ContainerInfo, error)
	UnpauseContainer(ctx context.Context, name string) (*ContainerInfo, error)
	GetContainerPID(ctx context.Context, name string) (int, error)
	UpdateContainerResources(ctx context.Context, name string, cpuQuota int64, cpuPeriod int64, memLimit int64) (*ContainerInfo, error)
	ScheduleResourceRestore(ctx context.Context, target string, duration int)
	InjectNetworkDelay(ctx context.Context, target string, latencyMs int, jitterMs int, duration *int) error
	InjectNetworkLoss(ctx context.Context, target string, lossPercent int, duration *int) error
	ExecCommand(ctx context.Context, name string, cmd []string) (int, error)
	ListContainers(ctx context.Context, all bool) ([]ContainerInfo, error)
	CleanupAll(ctx context.Context)
	Close()
}

type DeployConfig struct {
	Replicas  int             `yaml:"replicas"`
	Resources *ResourceConfig `yaml:"resources"`
}

type DockerClient struct {
	// contains filtered or unexported fields
}

type DoctorIssue struct {
	Severity string // "CRITICAL", "WARNING"
	Category string // "SPOF", "RESOURCES", "RECOVERY", "OBSERVABILITY", "SECURITY"
	Message  string
}

type DoctorResult struct {
	ServiceName string
	Issues      []DoctorIssue
}

type EngineStatus struct {
	Running           bool
	Config            *config.ChaosConfig
	CycleCount        int
	DownContainers    []string
	LastEvent         *utils.EventRecord
	History           []utils.EventRecord
	LastInjectionTime time.Time
	CooldownRemaining float64
}

type HealthCheckConfig struct {
	Test    interface{} `yaml:"test"` // can be string or list
	Disable bool        `yaml:"disable"`
}

type KubernetesClient struct {
	// contains filtered or unexported fields
}

type NetworkChaosManager struct {
	// contains filtered or unexported fields
}

type ProbeResult struct {
	Success bool
	Message string
}

type PrometheusResponse struct {
	Status string `json:"status"`
	Data   struct {
		ResultType string `json:"resultType"`
		Result     []struct {
			Value []interface{} `json:"value"`
		} `json:"result"`
	} `json:"data"`
}

type ResourceChaosManager struct {
	// contains filtered or unexported fields
}

type ResourceConfig struct {
	Limits *ResourceLimits `yaml:"limits"`
}

type ResourceLimits struct {
	CPUs   string `yaml:"cpus"`
	Memory string `yaml:"memory"`
}

type ScenarioResult struct {
	Success           bool
	ProbesPassed      int
	ProbesTotal       int
	SteadyStatePassed int
	SteadyStateTotal  int
	ExecutedSteps     int
	TotalSteps        int
	Error             string
	SteadyStateError  string
}

type ScenarioRunner struct {
	// contains filtered or unexported fields
}

type TopologyNode struct {
	Name      string
	Networks  []string
	DependsOn []string
}