testing

type BuildLister ¶

type BuildLister struct {
	Err   error
	Items []*buildv1alpha1.Build
}

BuildLister is a lister.BuildLister fake for testing.

func (r *BuildLister) Builds(namespace string) buildlisters.BuildNamespaceLister

func (r *BuildLister) List(selector labels.Selector) (results []*buildv1alpha1.Build, err error)

type ConfigMapLister ¶

type ConfigMapLister struct {
	Err   error
	Items []*corev1.ConfigMap
}

ConfigMapLister is a lister.ConfigMapLister fake for testing.

func (r *ConfigMapLister) ConfigMaps(namespace string) corev1listers.ConfigMapNamespaceLister

func (r *ConfigMapLister) List(selector labels.Selector) (results []*corev1.ConfigMap, err error)

type ConfigurationLister ¶

type ConfigurationLister struct {
	Err   error
	Items []*v1alpha1.Configuration
}

ConfigurationLister is a lister.ConfigurationLister fake for testing.

func (r *ConfigurationLister) Configurations(namespace string) listers.ConfigurationNamespaceLister

func (r *ConfigurationLister) List(selector labels.Selector) (results []*v1alpha1.Configuration, err error)

type CreateHookFunc ¶

type CreateHookFunc func(runtime.Object) HookResult

CreateHookFunc is a function for handling a Create hook. Its runtime.Object parameter will be the Kubernetes resource created. The resource can be cast to its actual type like this:

pod := obj.(*v1.Pod)

A return value of true marks the hook as completed. Returning false allows the hook to run again when the next resource of the requested type is created.

func ExpectNormalEventDelivery(t *testing.T, messageRegexp string) CreateHookFunc

func ExpectWarningEventDelivery(t *testing.T, messageRegexp string) CreateHookFunc

type Ctor ¶

type Ctor func(*Listers, controller.Options) controller.Interface

type DeleteHookFunc ¶

type DeleteHookFunc func(string) HookResult

DeleteHookFunc is a function for handling a delete hook. Its name parameter will be the name of the resource deleted. The resource itself is not available to the reactor.

type DeploymentLister ¶

type DeploymentLister struct {
	Err   error
	Items []*appsv1.Deployment
}

DeploymentLister is a lister.DeploymentLister fake for testing.

func (r *DeploymentLister) Deployments(namespace string) appsv1listers.DeploymentNamespaceLister

func (r *DeploymentLister) GetDeploymentsForReplicaSet(rs *appsv1.ReplicaSet) (results []*appsv1.Deployment, err error)

func (r *DeploymentLister) List(selector labels.Selector) (results []*appsv1.Deployment, err error)

type EndpointsLister ¶

type EndpointsLister struct {
	Err   error
	Items []*corev1.Endpoints
}

EndpointsLister is a lister.EndpointsLister fake for testing.

func (r *EndpointsLister) Endpoints(namespace string) corev1listers.EndpointsNamespaceLister

func (r *EndpointsLister) List(selector labels.Selector) (results []*corev1.Endpoints, err error)

type HookResult ¶

type HookResult bool

HookResult is the return value of hook functions.

const (
	// HookComplete indicates the hook function completed, and WaitForHooks should
	// not wait for it.
	HookComplete HookResult = true
	// HookIncomplete indicates the hook function is incomplete, and WaitForHooks
	// should wait for it to complete.
	HookIncomplete HookResult = false
)

type Hooks ¶

type Hooks struct {
	// contains filtered or unexported fields
}

Hooks is a utility struct that simplifies controller testing with fake clients. A Hooks struct allows attaching hook functions to actions (create, update, delete) on a specified resource type within a fake client and ensuring that all hooks complete in a timely manner.

h := NewHooks()
f := fake.NewSimpleClientset()

h.OnCreate(&f.Fake, "pods", func(obj runtime.Object) HookResult {
	pod := obj.(*v1.Pod)
	fmt.Printf("Pod %s has restart policy %v\n", pod.Name, pod.Spec.RestartPolicy)
	return true
})

h.OnUpdate(&f.Fake, "pods", func(obj runtime.Object) HookResult {
	pod := obj.(*v1.Pod)
	fmt.Printf("Pod %s restart policy was updated to %v\n", pod.Name, pod.Spec.RestartPolicy)
	return true
})

h.OnDelete(&f.Fake, "pods", func(name string) HookResult {
	fmt.Printf("Pod %s was deleted\n", name)
	return true
})

pod := &v1.Pod{
	ObjectMeta: metav1.ObjectMeta{
		Name: "test-pod",
	},
	Spec: v1.PodSpec{
		RestartPolicy: v1.RestartPolicyAlways,
	},
}
f.CoreV1().Pods("test").Create(pod)

updatedPod := pod.DeepCopy()
updatedPod.Spec.RestartPolicy = v1.RestartPolicyNever
f.CoreV1().Pods("test").Update(updatedPod)

f.CoreV1().Pods("test").Delete(pod.Name, &metav1.DeleteOptions{})
if err := h.WaitForHooks(time.Second); err != nil {
	log.Fatal(err)
}

Output:

Pod test-pod has restart policy Always
Pod test-pod restart policy was updated to Never
Pod test-pod was deleted

func NewHooks() *Hooks

func (h *Hooks) OnCreate(fake *kubetesting.Fake, resource string, rf CreateHookFunc)

func (h *Hooks) OnDelete(fake *kubetesting.Fake, resource string, rf DeleteHookFunc)

func (h *Hooks) OnUpdate(fake *kubetesting.Fake, resource string, rf UpdateHookFunc)

func (h *Hooks) WaitForHooks(timeout time.Duration) error

type K8sServiceLister ¶

type K8sServiceLister struct {
	Err   error
	Items []*corev1.Service
}

K8sServiceLister is a lister.ServiceLister fake for testing.

func (r *K8sServiceLister) GetPodServices(p *corev1.Pod) (results []*corev1.Service, err error)

func (r *K8sServiceLister) List(selector labels.Selector) (results []*corev1.Service, err error)

func (r *K8sServiceLister) Services(namespace string) corev1listers.ServiceNamespaceLister

type Listers ¶

type Listers struct {
	Service       *ServiceLister
	Route         *RouteLister
	Configuration *ConfigurationLister
	Revision      *RevisionLister

	VirtualService *VirtualServiceLister

	Build *BuildLister

	Deployment *DeploymentLister
	K8sService *K8sServiceLister
	Endpoints  *EndpointsLister
	ConfigMap  *ConfigMapLister
}

Listers holds the universe of objects that are available at the start of a reconciliation.

func NewListers(objs []runtime.Object) Listers

func (f *Listers) GetBuildLister() *BuildLister

func (f *Listers) GetBuildObjects() []runtime.Object

func (f *Listers) GetConfigMapLister() *ConfigMapLister

func (f *Listers) GetConfigurationLister() *ConfigurationLister

func (f *Listers) GetDeploymentLister() *DeploymentLister

func (f *Listers) GetEndpointsLister() *EndpointsLister

func (f *Listers) GetK8sServiceLister() *K8sServiceLister

func (f *Listers) GetKubeObjects() []runtime.Object

func (f *Listers) GetRevisionLister() *RevisionLister

func (f *Listers) GetRouteLister() *RouteLister

func (f *Listers) GetServiceLister() *ServiceLister

func (f *Listers) GetServingObjects() []runtime.Object

func (f *Listers) GetVirtualServiceLister() *VirtualServiceLister

type RevisionLister ¶

type RevisionLister struct {
	Err   error
	Items []*v1alpha1.Revision
}

RevisionLister is a lister.RevisionLister fake for testing.

func (r *RevisionLister) List(selector labels.Selector) (results []*v1alpha1.Revision, err error)

func (r *RevisionLister) Revisions(namespace string) listers.RevisionNamespaceLister

type RouteLister ¶

type RouteLister struct {
	Err   error
	Items []*v1alpha1.Route
}

RouteLister is a lister.RouteLister fake for testing.

func (r *RouteLister) List(selector labels.Selector) (results []*v1alpha1.Route, err error)

func (r *RouteLister) Routes(namespace string) listers.RouteNamespaceLister

type ServiceLister ¶

type ServiceLister struct {
	Err   error
	Items []*v1alpha1.Service
}

ServiceLister is a lister.ServiceLister fake for testing.

func (r *ServiceLister) List(selector labels.Selector) (results []*v1alpha1.Service, err error)

func (r *ServiceLister) Services(namespace string) listers.ServiceNamespaceLister

type TableRow ¶

type TableRow struct {
	// Name is a descriptive name for this test suitable as a first argument to t.Run()
	Name string

	// Objects holds the state of the world at the onset of reconciliation.
	Objects []runtime.Object

	// Key is the parameter to reconciliation.
	// This has the form "namespace/name".
	Key string

	// WantErr holds whether we should expect the reconciliation to result in an error.
	WantErr bool

	// WantCreates holds the set of Create calls we expect during reconciliation.
	WantCreates []metav1.Object

	// WantUpdates holds the set of Update calls we expect during reconciliation.
	WantUpdates []clientgotesting.UpdateActionImpl

	// WantDeletes holds the set of Delete calls we expect during reconciliation.
	WantDeletes []clientgotesting.DeleteActionImpl

	// WantQueue is the set of keys we expect to be in the workqueue following reconciliation.
	WantQueue []string

	// WithReactors is a set of functions that are installed as Reactors for the execution
	// of this row of the table-driven-test.
	WithReactors []clientgotesting.ReactionFunc
}

TableRow holds a single row of our table test.

func (r *TableRow) Test(t *testing.T, ctor Ctor)

type TableTest ¶

type TableTest []TableRow

func (tt TableTest) Test(t *testing.T, ctor Ctor)

type UpdateHookFunc ¶

type UpdateHookFunc func(runtime.Object) HookResult

UpdateHookFunc is a function for handling an update hook. its runtime.Object parameter will be the Kubernetes resource updated. The resource can be cast to its actual type like this:

pod := obj.(*v1.Pod)

A return value of true marks the hook as completed. Returning false allows the hook to run again when the next resource of the requested type is updated.

type VirtualServiceLister ¶

type VirtualServiceLister struct {
	Err   error
	Items []*istiov1alpha3.VirtualService
}

VirtualServiceLister is a istiolisters.VirtualServiceLister fake for testing.

func (r *VirtualServiceLister) GetPodServices(p *corev1.Pod) (results []*istiov1alpha3.VirtualService, err error)

func (r *VirtualServiceLister) List(selector labels.Selector) (results []*istiov1alpha3.VirtualService, err error)

func (r *VirtualServiceLister) VirtualServices(namespace string) istiolisters.VirtualServiceNamespaceLister