▽

Package graph

Constants

const DefaultNamespace = "default"

type DaemonHelper ¶

type DaemonHelper struct {
    Builder *chaosdaemon.ChaosDaemonClientBuilder
}

func (*DaemonHelper) GetPidFromPod ¶

func (h *DaemonHelper) GetPidFromPod(ctx context.Context, pod *v1.Pod) (uint32, error)

GetPidFromPod returns pid given containerd ID in pod

type Resolver ¶

type Resolver struct {
    *DaemonHelper
    Log       logr.Logger
    Client    client.Client
    Clientset *kubernetes.Clientset
}

func (*Resolver) AttrOverrideSpec ¶

func (r *Resolver) AttrOverrideSpec() generated.AttrOverrideSpecResolver

AttrOverrideSpec returns generated.AttrOverrideSpecResolver implementation.

func (*Resolver) BandwidthSpec ¶

func (r *Resolver) BandwidthSpec() generated.BandwidthSpecResolver

BandwidthSpec returns generated.BandwidthSpecResolver implementation.

func (*Resolver) ChaosCondition ¶

func (r *Resolver) ChaosCondition() generated.ChaosConditionResolver

ChaosCondition returns generated.ChaosConditionResolver implementation.

func (*Resolver) ContainerStateRunning ¶

func (r *Resolver) ContainerStateRunning() generated.ContainerStateRunningResolver

ContainerStateRunning returns generated.ContainerStateRunningResolver implementation.

func (*Resolver) ContainerStateTerminated ¶

func (r *Resolver) ContainerStateTerminated() generated.ContainerStateTerminatedResolver

ContainerStateTerminated returns generated.ContainerStateTerminatedResolver implementation.

func (*Resolver) CorruptSpec ¶

func (r *Resolver) CorruptSpec() generated.CorruptSpecResolver

CorruptSpec returns generated.CorruptSpecResolver implementation.

func (*Resolver) ExecBypass ¶

func (r *Resolver) ExecBypass(ctx context.Context, pod *v1.Pod, cmd string) (string, error)

ExecBypass use chaos-daemon to enter namespace and execute command in target pod

func (*Resolver) ExperimentStatus ¶

func (r *Resolver) ExperimentStatus() generated.ExperimentStatusResolver

ExperimentStatus returns generated.ExperimentStatusResolver implementation.

func (*Resolver) GetFdsOfProcess ¶

func (r *Resolver) GetFdsOfProcess(ctx context.Context, process *model.Process) ([]*model.Fd, error)

GetFdsOfProcess returns fd-target pairs

func (*Resolver) GetIpset ¶

func (r *Resolver) GetIpset(ctx context.Context, obj *v1.Pod) (string, error)

GetIpset returns result of ipset list

func (*Resolver) GetIptables ¶

func (r *Resolver) GetIptables(ctx context.Context, obj *v1.Pod) (string, error)

GetIptables returns result of iptables --list

func (*Resolver) GetMounts ¶

func (r *Resolver) GetMounts(ctx context.Context, pod *v1.Pod) ([]string, error)

GetMounts returns mounts info

func (*Resolver) GetPidFromPS ¶

func (r *Resolver) GetPidFromPS(ctx context.Context, pod *v1.Pod) ([]*model.Process, error)

GetPidFromPS returns pid-command pairs

func (*Resolver) GetTcQdisc ¶

func (r *Resolver) GetTcQdisc(ctx context.Context, obj *v1.Pod) (string, error)

GetIpset returns result of tc qdisc list

func (*Resolver) HTTPChaos ¶

func (r *Resolver) HTTPChaos() generated.HTTPChaosResolver

HTTPChaos returns generated.HTTPChaosResolver implementation.

func (*Resolver) HTTPChaosSpec ¶

func (r *Resolver) HTTPChaosSpec() generated.HTTPChaosSpecResolver

HTTPChaosSpec returns generated.HTTPChaosSpecResolver implementation.

func (*Resolver) HTTPChaosStatus ¶

func (r *Resolver) HTTPChaosStatus() generated.HTTPChaosStatusResolver

HTTPChaosStatus returns generated.HTTPChaosStatusResolver implementation.

func (*Resolver) IOChaos ¶

func (r *Resolver) IOChaos() generated.IOChaosResolver

IOChaos returns generated.IOChaosResolver implementation.

func (*Resolver) IOChaosAction ¶

func (r *Resolver) IOChaosAction() generated.IOChaosActionResolver

IOChaosAction returns generated.IOChaosActionResolver implementation.

func (*Resolver) IOChaosSpec ¶

func (r *Resolver) IOChaosSpec() generated.IOChaosSpecResolver

IOChaosSpec returns generated.IOChaosSpecResolver implementation.

func (*Resolver) IOChaosStatus ¶

func (r *Resolver) IOChaosStatus() generated.IOChaosStatusResolver

IOChaosStatus returns generated.IOChaosStatusResolver implementation.

func (*Resolver) IoFault ¶

func (r *Resolver) IoFault() generated.IoFaultResolver

IoFault returns generated.IoFaultResolver implementation.

func (*Resolver) Logger ¶

func (r *Resolver) Logger() generated.LoggerResolver

Logger returns generated.LoggerResolver implementation.

func (*Resolver) MistakeSpec ¶

func (r *Resolver) MistakeSpec() generated.MistakeSpecResolver

MistakeSpec returns generated.MistakeSpecResolver implementation.

func (*Resolver) Namespace ¶

func (r *Resolver) Namespace() generated.NamespaceResolver

Namespace returns generated.NamespaceResolver implementation.

func (*Resolver) NetworkChaos ¶

func (r *Resolver) NetworkChaos() generated.NetworkChaosResolver

NetworkChaos returns generated.NetworkChaosResolver implementation.

func (*Resolver) OwnerReference ¶

func (r *Resolver) OwnerReference() generated.OwnerReferenceResolver

OwnerReference returns generated.OwnerReferenceResolver implementation.

func (*Resolver) Pod ¶

func (r *Resolver) Pod() generated.PodResolver

Pod returns generated.PodResolver implementation.

func (*Resolver) PodCondition ¶

func (r *Resolver) PodCondition() generated.PodConditionResolver

PodCondition returns generated.PodConditionResolver implementation.

func (*Resolver) PodHTTPChaos ¶

func (r *Resolver) PodHTTPChaos() generated.PodHTTPChaosResolver

PodHTTPChaos returns generated.PodHTTPChaosResolver implementation.

func (*Resolver) PodHttpChaosReplaceActions ¶

func (r *Resolver) PodHttpChaosReplaceActions() generated.PodHttpChaosReplaceActionsResolver

PodHttpChaosReplaceActions returns generated.PodHttpChaosReplaceActionsResolver implementation.

func (*Resolver) PodHttpChaosRule ¶

func (r *Resolver) PodHttpChaosRule() generated.PodHttpChaosRuleResolver

PodHttpChaosRule returns generated.PodHttpChaosRuleResolver implementation.

func (*Resolver) PodHttpChaosSelector ¶

func (r *Resolver) PodHttpChaosSelector() generated.PodHttpChaosSelectorResolver

PodHttpChaosSelector returns generated.PodHttpChaosSelectorResolver implementation.

func (*Resolver) PodIOChaos ¶

func (r *Resolver) PodIOChaos() generated.PodIOChaosResolver

PodIOChaos returns generated.PodIOChaosResolver implementation.

func (*Resolver) PodNetworkChaos ¶

func (r *Resolver) PodNetworkChaos() generated.PodNetworkChaosResolver

PodNetworkChaos returns generated.PodNetworkChaosResolver implementation.

func (*Resolver) PodSelectorSpec ¶

func (r *Resolver) PodSelectorSpec() generated.PodSelectorSpecResolver

PodSelectorSpec returns generated.PodSelectorSpecResolver implementation.

func (*Resolver) PodStatus ¶

func (r *Resolver) PodStatus() generated.PodStatusResolver

PodStatus returns generated.PodStatusResolver implementation.

func (*Resolver) Process ¶

func (r *Resolver) Process() generated.ProcessResolver

Process returns generated.ProcessResolver implementation.

func (*Resolver) Query ¶

func (r *Resolver) Query() generated.QueryResolver

Query returns generated.QueryResolver implementation.

func (*Resolver) RawIptables ¶

func (r *Resolver) RawIptables() generated.RawIptablesResolver

RawIptables returns generated.RawIptablesResolver implementation.

func (*Resolver) RawTrafficControl ¶

func (r *Resolver) RawTrafficControl() generated.RawTrafficControlResolver

RawTrafficControl returns generated.RawTrafficControlResolver implementation.

func (*Resolver) Record ¶

func (r *Resolver) Record() generated.RecordResolver

Record returns generated.RecordResolver implementation.

func (*Resolver) StressChaos ¶

func (r *Resolver) StressChaos() generated.StressChaosResolver

StressChaos returns generated.StressChaosResolver implementation.

Subdirectories