testhelper

Documentation

Index

• type FakePodClient
  • func (f *FakePodClient) Exec(namespace, name string, opts *coreapi.PodExecOptions) (remotecommand.Executor, error)
  • func (*FakePodClient) GetLogs(string, string, *coreapi.PodLogOptions) *rest.Request
  • func (f FakePodClient) GetPendingTimeout() time.Duration
  • func (f *FakePodClient) WithNewLoggingClient() kubernetes.PodClient
• type FakePodExecutor
  • func (f *FakePodExecutor) Create(ctx context.Context, o ctrlruntimeclient.Object, ...) error
  • func (f *FakePodExecutor) Get(ctx context.Context, n ctrlruntimeclient.ObjectKey, o ctrlruntimeclient.Object, ...) error
  • func (f *FakePodExecutor) Watch(ctx context.Context, list ctrlruntimeclient.ObjectList, ...) (watch.Interface, error)

Types

type FakePodClient

type FakePodClient struct {
	*FakePodExecutor
	Namespace, Name string
	PendingTimeout  time.Duration
}

func (*FakePodClient) Exec

func (f *FakePodClient) Exec(namespace, name string, opts *coreapi.PodExecOptions) (remotecommand.Executor, error)

func (*FakePodClient) GetLogs

func (*FakePodClient) GetLogs(string, string, *coreapi.PodLogOptions) *rest.Request

func (FakePodClient) GetPendingTimeout

func (f FakePodClient) GetPendingTimeout() time.Duration

func (*FakePodClient) WithNewLoggingClient

func (f *FakePodClient) WithNewLoggingClient() kubernetes.PodClient

type FakePodExecutor

type FakePodExecutor struct {
	loggingclient.LoggingClient
	Failures    sets.Set[string]
	CreatedPods []*coreapi.Pod
	// contains filtered or unexported fields
}

func (*FakePodExecutor) Create

func (f *FakePodExecutor) Create(ctx context.Context, o ctrlruntimeclient.Object, opts ...ctrlruntimeclient.CreateOption) error

func (*FakePodExecutor) Get

func (f *FakePodExecutor) Get(ctx context.Context, n ctrlruntimeclient.ObjectKey, o ctrlruntimeclient.Object, opts ...ctrlruntimeclient.GetOption) error

func (*FakePodExecutor) Watch

func (f *FakePodExecutor) Watch(ctx context.Context, list ctrlruntimeclient.ObjectList, opts ...ctrlruntimeclient.ListOption) (watch.Interface, error)