disruptors

Oct 30, 2023

Changes in this version

+ type PodAgentVisitor struct

+ func NewPodAgentVisitor(helper helpers.PodHelper, options PodAgentVisitorOptions, ...) *PodAgentVisitor

+ func (c *PodAgentVisitor) Visit(ctx context.Context, pod corev1.Pod) error

+ type PodAgentVisitorOptions struct

+ Timeout time.Duration

+ type PodController struct

+ func NewPodController(targets []corev1.Pod) *PodController

+ func (c *PodController) Visit(ctx context.Context, visitor PodVisitor) error

+ type PodFaultInjector interface

+ TerminatePods func(context.Context, PodTerminationFault) ([]string, error)

+ type PodGrpcFaultCommand struct

+ func (c PodGrpcFaultCommand) Commands(pod corev1.Pod) (VisitCommands, error)

+ type PodHTTPFaultCommand struct

+ func (c PodHTTPFaultCommand) Commands(pod corev1.Pod) (VisitCommands, error)

type PodSelector

+ func NewPodSelector(spec PodSelectorSpec, helper helpers.PodHelper) (*PodSelector, error)

+ func (s *PodSelector) Targets(ctx context.Context) ([]corev1.Pod, error)

+ type PodSelectorSpec struct

+ Exclude PodAttributes

+ Namespace string

+ Select PodAttributes

+ func (p PodSelectorSpec) NamespaceOrDefault() string

+ func (p PodSelectorSpec) String() string

+ type PodTerminationFault struct

+ Count intstr.IntOrString

+ Timeout time.Duration

+ type PodTerminationVisitor struct

+ func (c PodTerminationVisitor) Visit(ctx context.Context, pod corev1.Pod) error

+ type PodVisitCommand interface

+ Commands func(corev1.Pod) (VisitCommands, error)

+ type PodVisitor interface

+ Visit func(context.Context, corev1.Pod) error

+ type PodVisitorFunc func(context.Context, corev1.Pod) error

+ func (f PodVisitorFunc) Visit(ctx context.Context, pod corev1.Pod) error

+ type ServicePodSelector struct

+ func NewServicePodSelector(service string, namespace string, helper helpers.ServiceHelper) (*ServicePodSelector, error)

+ func (s *ServicePodSelector) Targets(ctx context.Context) ([]corev1.Pod, error)

Aug 30, 2023

Changes in this version

+ var ErrSelectorNoPods = errors.New("no pods found matching selector")

+ var ErrServiceNoTargets = errors.New("service does not have any backing pods")

type PodSelector

+ func (p PodSelector) NamespaceOrDefault() string

+ func (p PodSelector) String() string

+ type VisitCommands struct

+ Cleanup []string

+ Exec []string

Jun 9, 2023

Changes in this version

+ const DefaultTargetPort

Apr 27, 2023

Changes in this version

+ type Disruptor interface

+ Targets func() ([]string, error)

+ type ProtocolFaultInjector interface

+ InjectGrpcFaults func(fault GrpcFault, duration time.Duration, options GrpcDisruptionOptions) error

+ InjectHTTPFaults func(fault HTTPFault, duration time.Duration, options HTTPDisruptionOptions) error

Apr 12, 2023

Changes in this version

type AgentController

+ Visit func(func(target string) []string) error

+ type PortMapper struct

+ func NewPortMapper(ctx context.Context, service *corev1.Service, endpoints *corev1.Endpoints) PortMapper

+ func (m *PortMapper) Map(port uint) (map[string]uint, error)

Apr 4, 2023

Changes in this version

type AgentController

+ func NewAgentController(ctx context.Context, k8s kubernetes.Kubernetes, namespace string, ...) AgentController

+ Targets func() ([]string, error)

+ type GrpcDisruptionOptions struct

+ Iface string

+ ProxyPort uint

+ type GrpcFault struct

+ AverageDelay uint

+ DelayVariation uint

+ ErrorRate float32

+ Exclude string

+ Port uint

+ StatusCode int32

+ StatusMessage string

type PodDisruptor

+ InjectGrpcFaults func(fault GrpcFault, duration uint, options GrpcDisruptionOptions) error

Dec 23, 2022

Changes in this version

+ type AgentController struct

+ func (c *AgentController) ExecCommand(cmd ...string) error

+ func (c *AgentController) InjectDisruptorAgent() error

+ type HTTPDisruptionOptions struct

+ Iface string

+ ProxyPort uint

+ type HTTPFault struct

+ AverageDelay uint

+ DelayVariation uint

+ ErrorBody string

+ ErrorCode uint

+ ErrorRate float32

+ Exclude string

+ Port uint

+ type PodAttributes struct

+ Labels map[string]string

+ type PodDisruptor interface

+ InjectHTTPFaults func(fault HTTPFault, duration uint, options HTTPDisruptionOptions) error

+ Targets func() ([]string, error)

+ func NewPodDisruptor(k8s kubernetes.Kubernetes, selector PodSelector, options PodDisruptorOptions) (PodDisruptor, error)

+ type PodDisruptorOptions struct

+ InjectTimeout int

+ type PodSelector struct

+ Exclude PodAttributes

+ Namespace string

+ Select PodAttributes

+ func (s *PodSelector) GetTargets(k8s kubernetes.Kubernetes) ([]string, error)

+ type ServiceDisruptor interface

+ func NewServiceDisruptor(k8s kubernetes.Kubernetes, service string, namespace string, ...) (ServiceDisruptor, error)

+ type ServiceDisruptorOptions struct

+ InjectTimeout int