test

Documentation

Index

• func GenerateNPods(namePrefix string, n int, status v1.PodPhase, ns string, ans map[string]string, ...) ([]runtime.Object, []v1.Pod)
• type MockChaosDaemonClient
  • func (c *MockChaosDaemonClient) AddEmatchFilter(ctx context.Context, in *chaosdaemon.EmatchFilterRequest, ...) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) AddQdisc(ctx context.Context, in *chaosdaemon.QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) CancelStressors(ctx context.Context, in *chaosdaemon.CancelStressRequest, ...) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) Close() error
  • func (c *MockChaosDaemonClient) ContainerGetPid(ctx context.Context, in *chaosdaemon.ContainerRequest, opts ...grpc.CallOption) (*chaosdaemon.ContainerResponse, error)
  • func (c *MockChaosDaemonClient) ContainerKill(ctx context.Context, in *chaosdaemon.ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) DelQdisc(ctx context.Context, in *chaosdaemon.QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) DelTcFilter(ctx context.Context, in *chaosdaemon.TcFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) DeleteNetem(ctx context.Context, in *chaosdaemon.NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) DeleteTbf(ctx context.Context, in *chaosdaemon.TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) ExecStressors(ctx context.Context, in *chaosdaemon.ExecStressRequest, ...) (*chaosdaemon.ExecStressResponse, error)
  • func (c *MockChaosDaemonClient) FlushIpSet(ctx context.Context, in *chaosdaemon.IpSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) FlushIptables(ctx context.Context, in *chaosdaemon.IpTablesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *chaosdaemon.TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) SetNetem(ctx context.Context, in *chaosdaemon.NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) SetTbf(ctx context.Context, in *chaosdaemon.TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  • func (c *MockChaosDaemonClient) SetTimeOffset(ctx context.Context, in *chaosdaemon.TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)

Functions

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

Types

type MockChaosDaemonClient

type MockChaosDaemonClient struct{}

MockChaosDaemonClient implements ChaosDaemonClientInterface for unit testing

func (*MockChaosDaemonClient) AddEmatchFilter

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

func (*MockChaosDaemonClient) AddQdisc

func (c *MockChaosDaemonClient) AddQdisc(ctx context.Context, in *chaosdaemon.QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, 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) DelQdisc

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

func (*MockChaosDaemonClient) DelTcFilter

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

func (*MockChaosDaemonClient) DeleteNetem

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

func (*MockChaosDaemonClient) DeleteTbf

func (c *MockChaosDaemonClient) DeleteTbf(ctx context.Context, in *chaosdaemon.TbfRequest, 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) FlushIpSet

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

func (*MockChaosDaemonClient) FlushIptables

func (c *MockChaosDaemonClient) FlushIptables(ctx context.Context, in *chaosdaemon.IpTablesRequest, 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) SetNetem

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

func (*MockChaosDaemonClient) SetTbf

func (c *MockChaosDaemonClient) SetTbf(ctx context.Context, in *chaosdaemon.TbfRequest, 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)