▽

Package test

func GenerateNPods ¶

func GenerateNPods(
    namePrefix string,
    n int,
    status v1.PodPhase,
    ns string,
    ans map[string]string,
    ls map[string]string,
    containerStatus v1.ContainerStatus,
) ([]runtime.Object, []v1.Pod)

GenerateNPods is only for unit testing

type MockChaosDaemonClient ¶

MockChaosDaemonClient implements ChaosDaemonClientInterface for unit testing

type MockChaosDaemonClient struct{}

func (*MockChaosDaemonClient) ApplyIoChaos ¶

func (c *MockChaosDaemonClient) ApplyIoChaos(ctx context.Context, in *chaosdaemon.ApplyIoChaosRequest, opts ...grpc.CallOption) (*chaosdaemon.ApplyIoChaosResponse, error)

func (*MockChaosDaemonClient) CancelStressors ¶

func (c *MockChaosDaemonClient) CancelStressors(ctx context.Context, in *chaosdaemon.CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)

CancelStressors mocks canceling pod stressors on chaos-daemon

func (*MockChaosDaemonClient) Close ¶

func (c *MockChaosDaemonClient) Close() error

func (*MockChaosDaemonClient) ContainerGetPid ¶

func (c *MockChaosDaemonClient) ContainerGetPid(ctx context.Context, in *chaosdaemon.ContainerRequest, opts ...grpc.CallOption) (*chaosdaemon.ContainerResponse, error)

func (*MockChaosDaemonClient) ContainerKill ¶

func (c *MockChaosDaemonClient) ContainerKill(ctx context.Context, in *chaosdaemon.ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*MockChaosDaemonClient) ExecStressors ¶

func (c *MockChaosDaemonClient) ExecStressors(ctx context.Context, in *chaosdaemon.ExecStressRequest, opts ...grpc.CallOption) (*chaosdaemon.ExecStressResponse, error)

ExecStressors mocks executing pod stressors on chaos-daemon

func (*MockChaosDaemonClient) FlushIPSets ¶

func (c *MockChaosDaemonClient) FlushIPSets(ctx context.Context, in *chaosdaemon.IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*MockChaosDaemonClient) RecoverTimeOffset ¶

func (c *MockChaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *chaosdaemon.TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*MockChaosDaemonClient) SetIptablesChains ¶

func (c *MockChaosDaemonClient) SetIptablesChains(ctx context.Context, in *chaosdaemon.IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*MockChaosDaemonClient) SetTcs ¶

func (c *MockChaosDaemonClient) SetTcs(ctx context.Context, in *chaosdaemon.TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*MockChaosDaemonClient) SetTimeOffset ¶

func (c *MockChaosDaemonClient) SetTimeOffset(ctx context.Context, in *chaosdaemon.TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)