mocks

package
v1.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 13, 2026 License: BSD-2-Clause Imports: 11 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaTopicInterface 

type KafkaTopicInterface struct {
	ApplyStub func(context.Context, *v1beta2a.KafkaTopicApplyConfiguration, v1.ApplyOptions) (*v1beta2.KafkaTopic, error)

	CreateStub func(context.Context, *v1beta2.KafkaTopic, v1.CreateOptions) (*v1beta2.KafkaTopic, error)

	DeleteStub func(context.Context, string, v1.DeleteOptions) error

	DeleteCollectionStub func(context.Context, v1.DeleteOptions, v1.ListOptions) error

	GetStub func(context.Context, string, v1.GetOptions) (*v1beta2.KafkaTopic, error)

	ListStub func(context.Context, v1.ListOptions) (*v1beta2.KafkaTopicList, error)

	PatchStub func(context.Context, string, types.PatchType, []byte, v1.PatchOptions, ...string) (*v1beta2.KafkaTopic, error)

	UpdateStub func(context.Context, *v1beta2.KafkaTopic, v1.UpdateOptions) (*v1beta2.KafkaTopic, error)

	WatchStub func(context.Context, v1.ListOptions) (watch.Interface, error)
	// contains filtered or unexported fields
}

func (*KafkaTopicInterface) Apply 

func (fake *KafkaTopicInterface) Apply(arg1 context.Context, arg2 *v1beta2a.KafkaTopicApplyConfiguration, arg3 v1.ApplyOptions) (*v1beta2.KafkaTopic, error)

func (*KafkaTopicInterface) ApplyArgsForCall 

func (fake *KafkaTopicInterface) ApplyArgsForCall(i int) (context.Context, *v1beta2a.KafkaTopicApplyConfiguration, v1.ApplyOptions)

func (*KafkaTopicInterface) ApplyCallCount 

func (fake *KafkaTopicInterface) ApplyCallCount() int

func (*KafkaTopicInterface) ApplyCalls 

func (fake *KafkaTopicInterface) ApplyCalls(stub func(context.Context, *v1beta2a.KafkaTopicApplyConfiguration, v1.ApplyOptions) (*v1beta2.KafkaTopic, error))

func (*KafkaTopicInterface) ApplyReturns 

func (fake *KafkaTopicInterface) ApplyReturns(result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) ApplyReturnsOnCall 

func (fake *KafkaTopicInterface) ApplyReturnsOnCall(i int, result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) Create 

func (fake *KafkaTopicInterface) Create(arg1 context.Context, arg2 *v1beta2.KafkaTopic, arg3 v1.CreateOptions) (*v1beta2.KafkaTopic, error)

func (*KafkaTopicInterface) CreateArgsForCall 

func (fake *KafkaTopicInterface) CreateArgsForCall(i int) (context.Context, *v1beta2.KafkaTopic, v1.CreateOptions)

func (*KafkaTopicInterface) CreateCallCount 

func (fake *KafkaTopicInterface) CreateCallCount() int

func (*KafkaTopicInterface) CreateCalls 

func (fake *KafkaTopicInterface) CreateCalls(stub func(context.Context, *v1beta2.KafkaTopic, v1.CreateOptions) (*v1beta2.KafkaTopic, error))

func (*KafkaTopicInterface) CreateReturns 

func (fake *KafkaTopicInterface) CreateReturns(result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) CreateReturnsOnCall 

func (fake *KafkaTopicInterface) CreateReturnsOnCall(i int, result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) Delete 

func (fake *KafkaTopicInterface) Delete(arg1 context.Context, arg2 string, arg3 v1.DeleteOptions) error

func (*KafkaTopicInterface) DeleteArgsForCall 

func (fake *KafkaTopicInterface) DeleteArgsForCall(i int) (context.Context, string, v1.DeleteOptions)

func (*KafkaTopicInterface) DeleteCallCount 

func (fake *KafkaTopicInterface) DeleteCallCount() int

func (*KafkaTopicInterface) DeleteCalls 

func (fake *KafkaTopicInterface) DeleteCalls(stub func(context.Context, string, v1.DeleteOptions) error)

func (*KafkaTopicInterface) DeleteCollection 

func (fake *KafkaTopicInterface) DeleteCollection(arg1 context.Context, arg2 v1.DeleteOptions, arg3 v1.ListOptions) error

func (*KafkaTopicInterface) DeleteCollectionArgsForCall 

func (fake *KafkaTopicInterface) DeleteCollectionArgsForCall(i int) (context.Context, v1.DeleteOptions, v1.ListOptions)

func (*KafkaTopicInterface) DeleteCollectionCallCount 

func (fake *KafkaTopicInterface) DeleteCollectionCallCount() int

func (*KafkaTopicInterface) DeleteCollectionCalls 

func (fake *KafkaTopicInterface) DeleteCollectionCalls(stub func(context.Context, v1.DeleteOptions, v1.ListOptions) error)

func (*KafkaTopicInterface) DeleteCollectionReturns 

func (fake *KafkaTopicInterface) DeleteCollectionReturns(result1 error)

func (*KafkaTopicInterface) DeleteCollectionReturnsOnCall 

func (fake *KafkaTopicInterface) DeleteCollectionReturnsOnCall(i int, result1 error)

func (*KafkaTopicInterface) DeleteReturns 

func (fake *KafkaTopicInterface) DeleteReturns(result1 error)

func (*KafkaTopicInterface) DeleteReturnsOnCall 

func (fake *KafkaTopicInterface) DeleteReturnsOnCall(i int, result1 error)

func (*KafkaTopicInterface) Get 

func (fake *KafkaTopicInterface) Get(arg1 context.Context, arg2 string, arg3 v1.GetOptions) (*v1beta2.KafkaTopic, error)

func (*KafkaTopicInterface) GetArgsForCall 

func (fake *KafkaTopicInterface) GetArgsForCall(i int) (context.Context, string, v1.GetOptions)

func (*KafkaTopicInterface) GetCallCount 

func (fake *KafkaTopicInterface) GetCallCount() int

func (*KafkaTopicInterface) GetCalls 

func (fake *KafkaTopicInterface) GetCalls(stub func(context.Context, string, v1.GetOptions) (*v1beta2.KafkaTopic, error))

func (*KafkaTopicInterface) GetReturns 

func (fake *KafkaTopicInterface) GetReturns(result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) GetReturnsOnCall 

func (fake *KafkaTopicInterface) GetReturnsOnCall(i int, result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) Invocations 

func (fake *KafkaTopicInterface) Invocations() map[string][][]interface{}

func (*KafkaTopicInterface) List 

func (fake *KafkaTopicInterface) List(arg1 context.Context, arg2 v1.ListOptions) (*v1beta2.KafkaTopicList, error)

func (*KafkaTopicInterface) ListArgsForCall 

func (fake *KafkaTopicInterface) ListArgsForCall(i int) (context.Context, v1.ListOptions)

func (*KafkaTopicInterface) ListCallCount 

func (fake *KafkaTopicInterface) ListCallCount() int

func (*KafkaTopicInterface) ListCalls 

func (fake *KafkaTopicInterface) ListCalls(stub func(context.Context, v1.ListOptions) (*v1beta2.KafkaTopicList, error))

func (*KafkaTopicInterface) ListReturns 

func (fake *KafkaTopicInterface) ListReturns(result1 *v1beta2.KafkaTopicList, result2 error)

func (*KafkaTopicInterface) ListReturnsOnCall 

func (fake *KafkaTopicInterface) ListReturnsOnCall(i int, result1 *v1beta2.KafkaTopicList, result2 error)

func (*KafkaTopicInterface) Patch 

func (fake *KafkaTopicInterface) Patch(arg1 context.Context, arg2 string, arg3 types.PatchType, arg4 []byte, arg5 v1.PatchOptions, arg6 ...string) (*v1beta2.KafkaTopic, error)

func (*KafkaTopicInterface) PatchArgsForCall 

func (fake *KafkaTopicInterface) PatchArgsForCall(i int) (context.Context, string, types.PatchType, []byte, v1.PatchOptions, []string)

func (*KafkaTopicInterface) PatchCallCount 

func (fake *KafkaTopicInterface) PatchCallCount() int

func (*KafkaTopicInterface) PatchCalls 

func (fake *KafkaTopicInterface) PatchCalls(stub func(context.Context, string, types.PatchType, []byte, v1.PatchOptions, ...string) (*v1beta2.KafkaTopic, error))

func (*KafkaTopicInterface) PatchReturns 

func (fake *KafkaTopicInterface) PatchReturns(result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) PatchReturnsOnCall 

func (fake *KafkaTopicInterface) PatchReturnsOnCall(i int, result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) Update 

func (fake *KafkaTopicInterface) Update(arg1 context.Context, arg2 *v1beta2.KafkaTopic, arg3 v1.UpdateOptions) (*v1beta2.KafkaTopic, error)

func (*KafkaTopicInterface) UpdateArgsForCall 

func (fake *KafkaTopicInterface) UpdateArgsForCall(i int) (context.Context, *v1beta2.KafkaTopic, v1.UpdateOptions)

func (*KafkaTopicInterface) UpdateCallCount 

func (fake *KafkaTopicInterface) UpdateCallCount() int

func (*KafkaTopicInterface) UpdateCalls 

func (fake *KafkaTopicInterface) UpdateCalls(stub func(context.Context, *v1beta2.KafkaTopic, v1.UpdateOptions) (*v1beta2.KafkaTopic, error))

func (*KafkaTopicInterface) UpdateReturns 

func (fake *KafkaTopicInterface) UpdateReturns(result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) UpdateReturnsOnCall 

func (fake *KafkaTopicInterface) UpdateReturnsOnCall(i int, result1 *v1beta2.KafkaTopic, result2 error)

func (*KafkaTopicInterface) Watch 

func (fake *KafkaTopicInterface) Watch(arg1 context.Context, arg2 v1.ListOptions) (watch.Interface, error)

func (*KafkaTopicInterface) WatchArgsForCall 

func (fake *KafkaTopicInterface) WatchArgsForCall(i int) (context.Context, v1.ListOptions)

func (*KafkaTopicInterface) WatchCallCount 

func (fake *KafkaTopicInterface) WatchCallCount() int

func (*KafkaTopicInterface) WatchCalls 

func (fake *KafkaTopicInterface) WatchCalls(stub func(context.Context, v1.ListOptions) (watch.Interface, error))

func (*KafkaTopicInterface) WatchReturns 

func (fake *KafkaTopicInterface) WatchReturns(result1 watch.Interface, result2 error)

func (*KafkaTopicInterface) WatchReturnsOnCall 

func (fake *KafkaTopicInterface) WatchReturnsOnCall(i int, result1 watch.Interface, result2 error)

type KafkaV1beta2Interface added in v1.6.1 

type KafkaV1beta2Interface struct {
	KafkaTopicsStub func(string) v1beta2.KafkaTopicInterface

	RESTClientStub func() rest.Interface
	// contains filtered or unexported fields
}

func (*KafkaV1beta2Interface) Invocations added in v1.6.1 

func (fake *KafkaV1beta2Interface) Invocations() map[string][][]interface{}

func (*KafkaV1beta2Interface) KafkaTopics added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopics(arg1 string) v1beta2.KafkaTopicInterface

func (*KafkaV1beta2Interface) KafkaTopicsArgsForCall added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopicsArgsForCall(i int) string

func (*KafkaV1beta2Interface) KafkaTopicsCallCount added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopicsCallCount() int

func (*KafkaV1beta2Interface) KafkaTopicsCalls added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopicsCalls(stub func(string) v1beta2.KafkaTopicInterface)

func (*KafkaV1beta2Interface) KafkaTopicsReturns added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopicsReturns(result1 v1beta2.KafkaTopicInterface)

func (*KafkaV1beta2Interface) KafkaTopicsReturnsOnCall added in v1.6.1 

func (fake *KafkaV1beta2Interface) KafkaTopicsReturnsOnCall(i int, result1 v1beta2.KafkaTopicInterface)

func (*KafkaV1beta2Interface) RESTClient added in v1.6.1 

func (fake *KafkaV1beta2Interface) RESTClient() rest.Interface

func (*KafkaV1beta2Interface) RESTClientCallCount added in v1.6.1 

func (fake *KafkaV1beta2Interface) RESTClientCallCount() int

func (*KafkaV1beta2Interface) RESTClientCalls added in v1.6.1 

func (fake *KafkaV1beta2Interface) RESTClientCalls(stub func() rest.Interface)

func (*KafkaV1beta2Interface) RESTClientReturns added in v1.6.1 

func (fake *KafkaV1beta2Interface) RESTClientReturns(result1 rest.Interface)

func (*KafkaV1beta2Interface) RESTClientReturnsOnCall added in v1.6.1 

func (fake *KafkaV1beta2Interface) RESTClientReturnsOnCall(i int, result1 rest.Interface)

type StrimziClientset added in v1.5.4 

type StrimziClientset struct {
	DiscoveryStub func() discovery.DiscoveryInterface

	KafkaV1beta2Stub func() v1beta2.KafkaV1beta2Interface
	// contains filtered or unexported fields
}

func (*StrimziClientset) Discovery added in v1.5.4 

func (fake *StrimziClientset) Discovery() discovery.DiscoveryInterface

func (*StrimziClientset) DiscoveryCallCount added in v1.5.4 

func (fake *StrimziClientset) DiscoveryCallCount() int

func (*StrimziClientset) DiscoveryCalls added in v1.5.4 

func (fake *StrimziClientset) DiscoveryCalls(stub func() discovery.DiscoveryInterface)

func (*StrimziClientset) DiscoveryReturns added in v1.5.4 

func (fake *StrimziClientset) DiscoveryReturns(result1 discovery.DiscoveryInterface)

func (*StrimziClientset) DiscoveryReturnsOnCall added in v1.5.4 

func (fake *StrimziClientset) DiscoveryReturnsOnCall(i int, result1 discovery.DiscoveryInterface)

func (*StrimziClientset) Invocations added in v1.5.4 

func (fake *StrimziClientset) Invocations() map[string][][]interface{}

func (*StrimziClientset) KafkaV1beta2 added in v1.5.4 

func (fake *StrimziClientset) KafkaV1beta2() v1beta2.KafkaV1beta2Interface

func (*StrimziClientset) KafkaV1beta2CallCount added in v1.5.4 

func (fake *StrimziClientset) KafkaV1beta2CallCount() int

func (*StrimziClientset) KafkaV1beta2Calls added in v1.5.4 

func (fake *StrimziClientset) KafkaV1beta2Calls(stub func() v1beta2.KafkaV1beta2Interface)

func (*StrimziClientset) KafkaV1beta2Returns added in v1.5.4 

func (fake *StrimziClientset) KafkaV1beta2Returns(result1 v1beta2.KafkaV1beta2Interface)

func (*StrimziClientset) KafkaV1beta2ReturnsOnCall added in v1.5.4 

func (fake *StrimziClientset) KafkaV1beta2ReturnsOnCall(i int, result1 v1beta2.KafkaV1beta2Interface)

type TopicDeployer 

type TopicDeployer struct {
	DeployStub func(context.Context, v1beta2.KafkaTopic) error

	UndeployStub func(context.Context, string, string) error
	// contains filtered or unexported fields
}

func (*TopicDeployer) Deploy 

func (fake *TopicDeployer) Deploy(arg1 context.Context, arg2 v1beta2.KafkaTopic) error

func (*TopicDeployer) DeployArgsForCall 

func (fake *TopicDeployer) DeployArgsForCall(i int) (context.Context, v1beta2.KafkaTopic)

func (*TopicDeployer) DeployCallCount 

func (fake *TopicDeployer) DeployCallCount() int

func (*TopicDeployer) DeployCalls 

func (fake *TopicDeployer) DeployCalls(stub func(context.Context, v1beta2.KafkaTopic) error)

func (*TopicDeployer) DeployReturns 

func (fake *TopicDeployer) DeployReturns(result1 error)

func (*TopicDeployer) DeployReturnsOnCall 

func (fake *TopicDeployer) DeployReturnsOnCall(i int, result1 error)

func (*TopicDeployer) Invocations 

func (fake *TopicDeployer) Invocations() map[string][][]interface{}

func (*TopicDeployer) Undeploy 

func (fake *TopicDeployer) Undeploy(arg1 context.Context, arg2 string, arg3 string) error

func (*TopicDeployer) UndeployArgsForCall 

func (fake *TopicDeployer) UndeployArgsForCall(i int) (context.Context, string, string)

func (*TopicDeployer) UndeployCallCount 

func (fake *TopicDeployer) UndeployCallCount() int

func (*TopicDeployer) UndeployCalls 

func (fake *TopicDeployer) UndeployCalls(stub func(context.Context, string, string) error)

func (*TopicDeployer) UndeployReturns 

func (fake *TopicDeployer) UndeployReturns(result1 error)

func (*TopicDeployer) UndeployReturnsOnCall 

func (fake *TopicDeployer) UndeployReturnsOnCall(i int, result1 error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.