commonTestUtils

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Name           = "kubevirt-hyperconverged"
	Namespace      = "kubevirt-hyperconverged"
	VirtioWinImage = "quay.io/kubevirt/virtio-container-disk:v2.0.0"
)

Name and Namespace of our primary resource

View Source 
const (
	RSName = "hco-operator"

	BaseDomain = "basedomain"
)

Variables

View Source 
var (
	TestLogger  = zap.New(zap.WriteTo(GinkgoWriter), zap.UseDevMode(true)).WithName("controller_hyperconverged")
	TestRequest = reconcile.Request{
		NamespacedName: types.NamespacedName{
			Name:      Name,
			Namespace: Namespace,
		},
	}
)

Functions

func CopyFile 

func CopyFile(dest, src string) error

func GetScheme 

func GetScheme() *runtime.Scheme

func NewClusterMock added in v1.8.0 

func NewClusterMock(config *rest.Config, client client.Client, logger logr.Logger) (cluster.Cluster, error)

NewClusterMock returns a new mocked Cluster for creating Controllers.

func NewHco 

func NewHco() *hcov1beta1.HyperConverged

func NewHcoNamespace 

func NewHcoNamespace() *corev1.Namespace

func NewManagerMock added in v1.8.0 

func NewManagerMock(config *rest.Config, options manager.Options, client client.Client, logger logr.Logger) (manager.Manager, error)

NewManagerMock returns a new mocked Manager for unit test which involves Controller Managers

func NewNodePlacement 

func NewNodePlacement() *sdkapi.NodePlacement

func NewOtherNodePlacement 

func NewOtherNodePlacement() *sdkapi.NodePlacement

func NewReq 

func NewReq(inst *hcov1beta1.HyperConverged) *common.HcoRequest

func RepresentCondition 

func RepresentCondition(expected metav1.Condition) gomegatypes.GomegaMatcher

RepresentCondition - returns a GomegaMatcher useful for comparing conditions

Types

type ClusterInfoMock 

type ClusterInfoMock struct{}

ClusterInfoMock mocks regular Openshift

func (ClusterInfoMock) GetBaseDomain added in v1.9.0 

func (ClusterInfoMock) GetBaseDomain() string

func (ClusterInfoMock) GetCSV 

func (c ClusterInfoMock) GetCSV() *csvv1alpha1.ClusterServiceVersion

func (ClusterInfoMock) GetDeployment 

func (c ClusterInfoMock) GetDeployment() *appsv1.Deployment

func (ClusterInfoMock) GetDomain 

func (ClusterInfoMock) GetDomain() string

func (ClusterInfoMock) GetPod 

func (c ClusterInfoMock) GetPod() *corev1.Pod

func (ClusterInfoMock) GetTLSSecurityProfile 

func (ClusterInfoMock) GetTLSSecurityProfile(_ *openshiftconfigv1.TLSSecurityProfile) *openshiftconfigv1.TLSSecurityProfile

func (ClusterInfoMock) Init 

func (ClusterInfoMock) Init(_ context.Context, _ client.Client, _ logr.Logger) error

func (ClusterInfoMock) IsConsolePluginImageProvided 

func (c ClusterInfoMock) IsConsolePluginImageProvided() bool

func (ClusterInfoMock) IsControlPlaneHighlyAvailable 

func (ClusterInfoMock) IsControlPlaneHighlyAvailable() bool

func (ClusterInfoMock) IsInfrastructureHighlyAvailable 

func (ClusterInfoMock) IsInfrastructureHighlyAvailable() bool

func (ClusterInfoMock) IsManagedByOLM 

func (ClusterInfoMock) IsManagedByOLM() bool

func (ClusterInfoMock) IsOpenshift 

func (ClusterInfoMock) IsOpenshift() bool

func (ClusterInfoMock) IsRunningLocally 

func (ClusterInfoMock) IsRunningLocally() bool

func (ClusterInfoMock) RefreshAPIServerCR 

func (ClusterInfoMock) RefreshAPIServerCR(_ context.Context, _ client.Client) error

type ClusterInfoSNOMock 

type ClusterInfoSNOMock struct{}

ClusterInfoSNOMock mocks Openshift SNO

func (ClusterInfoSNOMock) GetBaseDomain added in v1.9.0 

func (ClusterInfoSNOMock) GetBaseDomain() string

func (ClusterInfoSNOMock) GetCSV 

func (c ClusterInfoSNOMock) GetCSV() *csvv1alpha1.ClusterServiceVersion

func (ClusterInfoSNOMock) GetDeployment 

func (c ClusterInfoSNOMock) GetDeployment() *appsv1.Deployment

func (ClusterInfoSNOMock) GetDomain 

func (ClusterInfoSNOMock) GetDomain() string

func (ClusterInfoSNOMock) GetPod 

func (c ClusterInfoSNOMock) GetPod() *corev1.Pod

func (ClusterInfoSNOMock) GetTLSSecurityProfile 

func (ClusterInfoSNOMock) GetTLSSecurityProfile(_ *openshiftconfigv1.TLSSecurityProfile) *openshiftconfigv1.TLSSecurityProfile

func (ClusterInfoSNOMock) Init 

func (ClusterInfoSNOMock) Init(_ context.Context, _ client.Client, _ logr.Logger) error

func (ClusterInfoSNOMock) IsConsolePluginImageProvided 

func (ClusterInfoSNOMock) IsConsolePluginImageProvided() bool

func (ClusterInfoSNOMock) IsControlPlaneHighlyAvailable 

func (ClusterInfoSNOMock) IsControlPlaneHighlyAvailable() bool

func (ClusterInfoSNOMock) IsInfrastructureHighlyAvailable 

func (ClusterInfoSNOMock) IsInfrastructureHighlyAvailable() bool

func (ClusterInfoSNOMock) IsManagedByOLM 

func (ClusterInfoSNOMock) IsManagedByOLM() bool

func (ClusterInfoSNOMock) IsOpenshift 

func (ClusterInfoSNOMock) IsOpenshift() bool

func (ClusterInfoSNOMock) IsRunningLocally 

func (ClusterInfoSNOMock) IsRunningLocally() bool

func (ClusterInfoSNOMock) RefreshAPIServerCR 

func (ClusterInfoSNOMock) RefreshAPIServerCR(_ context.Context, _ client.Client) error

type ClusterInfoSRCPHAIMock 

type ClusterInfoSRCPHAIMock struct{}

ClusterInfoSRCPHAIMock mocks Openshift with SingleReplica ControlPlane and HighAvailable Infrastructure

func (ClusterInfoSRCPHAIMock) GetBaseDomain added in v1.9.0 

func (ClusterInfoSRCPHAIMock) GetBaseDomain() string

func (ClusterInfoSRCPHAIMock) GetCSV 

func (ClusterInfoSRCPHAIMock) GetCSV() *csvv1alpha1.ClusterServiceVersion

func (ClusterInfoSRCPHAIMock) GetDeployment 

func (ClusterInfoSRCPHAIMock) GetDeployment() *appsv1.Deployment

func (ClusterInfoSRCPHAIMock) GetDomain 

func (ClusterInfoSRCPHAIMock) GetDomain() string

func (ClusterInfoSRCPHAIMock) GetPod 

func (ClusterInfoSRCPHAIMock) GetPod() *corev1.Pod

func (ClusterInfoSRCPHAIMock) GetTLSSecurityProfile 

func (ClusterInfoSRCPHAIMock) GetTLSSecurityProfile(_ *openshiftconfigv1.TLSSecurityProfile) *openshiftconfigv1.TLSSecurityProfile

func (ClusterInfoSRCPHAIMock) Init 

func (ClusterInfoSRCPHAIMock) Init(_ context.Context, _ client.Client, _ logr.Logger) error

func (ClusterInfoSRCPHAIMock) IsConsolePluginImageProvided 

func (ClusterInfoSRCPHAIMock) IsConsolePluginImageProvided() bool

func (ClusterInfoSRCPHAIMock) IsControlPlaneHighlyAvailable 

func (ClusterInfoSRCPHAIMock) IsControlPlaneHighlyAvailable() bool

func (ClusterInfoSRCPHAIMock) IsInfrastructureHighlyAvailable 

func (ClusterInfoSRCPHAIMock) IsInfrastructureHighlyAvailable() bool

func (ClusterInfoSRCPHAIMock) IsManagedByOLM 

func (ClusterInfoSRCPHAIMock) IsManagedByOLM() bool

func (ClusterInfoSRCPHAIMock) IsOpenshift 

func (ClusterInfoSRCPHAIMock) IsOpenshift() bool

func (ClusterInfoSRCPHAIMock) IsRunningLocally 

func (ClusterInfoSRCPHAIMock) IsRunningLocally() bool

func (ClusterInfoSRCPHAIMock) RefreshAPIServerCR 

func (ClusterInfoSRCPHAIMock) RefreshAPIServerCR(_ context.Context, _ client.Client) error

type EventEmitterMock 

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

func NewEventEmitterMock 

func NewEventEmitterMock() *EventEmitterMock

func (EventEmitterMock) CheckEvents 

func (eem EventEmitterMock) CheckEvents(expectedEvents []MockEvent) bool

func (EventEmitterMock) CheckNoEventEmitted 

func (eem EventEmitterMock) CheckNoEventEmitted() bool

func (*EventEmitterMock) EmitEvent 

func (eem *EventEmitterMock) EmitEvent(_ runtime.Object, eventType, reason, msg string)

func (EventEmitterMock) Init 

func (EventEmitterMock) Init(_ *corev1.Pod, _ *csvv1alpha1.ClusterServiceVersion, _ record.EventRecorder)

func (*EventEmitterMock) Reset 

func (eem *EventEmitterMock) Reset()

func (EventEmitterMock) UpdateClient 

func (EventEmitterMock) UpdateClient(_ context.Context, _ client.Reader, _ logr.Logger)

type FakeReadErrorGenerator 

type FakeReadErrorGenerator func(key client.ObjectKey) error

type FakeWriteErrorGenerator 

type FakeWriteErrorGenerator func(obj client.Object) error

type HcoTestClient 

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

implements the client.Client interface (proxy pattern)

func InitClient 

func InitClient(clientObjects []runtime.Object) *HcoTestClient

func (*HcoTestClient) Create 

func (c *HcoTestClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*HcoTestClient) Delete 

func (c *HcoTestClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*HcoTestClient) DeleteAllOf 

func (c *HcoTestClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*HcoTestClient) Get 

func (c *HcoTestClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error

func (*HcoTestClient) InitiateCreateErrors 

func (c *HcoTestClient) InitiateCreateErrors(f FakeWriteErrorGenerator)

func (*HcoTestClient) InitiateDeleteErrors 

func (c *HcoTestClient) InitiateDeleteErrors(f FakeWriteErrorGenerator)

func (*HcoTestClient) InitiateGetErrors 

func (c *HcoTestClient) InitiateGetErrors(f FakeReadErrorGenerator)

func (*HcoTestClient) InitiateUpdateErrors 

func (c *HcoTestClient) InitiateUpdateErrors(f FakeWriteErrorGenerator)

func (*HcoTestClient) List 

func (c *HcoTestClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*HcoTestClient) Patch 

func (c *HcoTestClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*HcoTestClient) RESTMapper 

func (c *HcoTestClient) RESTMapper() meta.RESTMapper

func (*HcoTestClient) Scheme 

func (c *HcoTestClient) Scheme() *runtime.Scheme

func (*HcoTestClient) Status 

func (c *HcoTestClient) Status() client.StatusWriter

func (*HcoTestClient) SubResource added in v1.9.0 

func (c *HcoTestClient) SubResource(subResource string) client.SubResourceClient

func (*HcoTestClient) Update 

func (c *HcoTestClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type HcoTestStatusWriter 

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

func (*HcoTestStatusWriter) Create added in v1.9.0 

func (sw *HcoTestStatusWriter) Create(ctx context.Context, obj client.Object, subResource client.Object, opts ...client.SubResourceCreateOption) error

func (*HcoTestStatusWriter) InitiateErrors 

func (sw *HcoTestStatusWriter) InitiateErrors(errs ...error)

func (*HcoTestStatusWriter) Patch 

func (sw *HcoTestStatusWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.SubResourcePatchOption) error

func (*HcoTestStatusWriter) Update 

func (sw *HcoTestStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error

type ManagerMock added in v1.8.0 

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

func (*ManagerMock) Add added in v1.8.0 

func (mm *ManagerMock) Add(r manager.Runnable) error

Add sets dependencies on i, and adds it to the list of Runnables to start.

func (ManagerMock) AddHealthzCheck added in v1.8.0 

func (mm ManagerMock) AddHealthzCheck(name string, check healthz.Checker) error

AddHealthzCheck allows you to add Healthz checker.

func (ManagerMock) AddMetricsExtraHandler added in v1.8.0 

func (mm ManagerMock) AddMetricsExtraHandler(path string, handler http.Handler) error

AddMetricsExtraHandler adds extra handler served on path to the http server that serves metrics.

func (ManagerMock) AddReadyzCheck added in v1.8.0 

func (mm ManagerMock) AddReadyzCheck(name string, check healthz.Checker) error

AddReadyzCheck allows you to add Readyz checker.

func (ManagerMock) Elected added in v1.8.0 

func (mm ManagerMock) Elected() <-chan struct{}

func (ManagerMock) GetAPIReader added in v1.8.0 

func (mm ManagerMock) GetAPIReader() client.Reader

func (ManagerMock) GetCache added in v1.8.0 

func (mm ManagerMock) GetCache() cache.Cache

func (ManagerMock) GetClient added in v1.8.0 

func (mm ManagerMock) GetClient() client.Client

func (ManagerMock) GetConfig added in v1.8.0 

func (mm ManagerMock) GetConfig() *rest.Config

func (ManagerMock) GetControllerOptions added in v1.8.0 

func (mm ManagerMock) GetControllerOptions() v1alpha1.ControllerConfigurationSpec

func (ManagerMock) GetEventRecorderFor added in v1.8.0 

func (mm ManagerMock) GetEventRecorderFor(name string) record.EventRecorder

func (ManagerMock) GetFieldIndexer added in v1.8.0 

func (mm ManagerMock) GetFieldIndexer() client.FieldIndexer

func (ManagerMock) GetLogger added in v1.8.0 

func (mm ManagerMock) GetLogger() logr.Logger

func (ManagerMock) GetRESTMapper added in v1.8.0 

func (mm ManagerMock) GetRESTMapper() meta.RESTMapper

func (ManagerMock) GetRunnables added in v1.8.0 

func (mm ManagerMock) GetRunnables() []manager.Runnable

func (ManagerMock) GetScheme added in v1.8.0 

func (mm ManagerMock) GetScheme() *runtime.Scheme

func (ManagerMock) GetWebhookServer added in v1.8.0 

func (mm ManagerMock) GetWebhookServer() *webhook.Server

func (ManagerMock) SetFields deprecated added in v1.8.0 

func (mm ManagerMock) SetFields(i interface{}) error

Deprecated: use the equivalent Options field to set a field. This method will be removed in v0.10.

func (ManagerMock) Start added in v1.8.0 

func (mm ManagerMock) Start(ctx context.Context) (err error)

type MockEvent 

type MockEvent struct {
	EventType string
	Reason    string
	Msg       string
}

type RepresentConditionMatcher 

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

func (*RepresentConditionMatcher) FailureMessage 

func (matcher *RepresentConditionMatcher) FailureMessage(actual interface{}) (message string)

func (*RepresentConditionMatcher) Match 

func (matcher *RepresentConditionMatcher) Match(actual interface{}) (success bool, err error)

Match - compares two conditions two conditions are the same if they have the same type, status, reason, and message

func (*RepresentConditionMatcher) NegatedFailureMessage 

func (matcher *RepresentConditionMatcher) NegatedFailureMessage(actual interface{}) (message string)

type TestErrors 

type TestErrors []error

func (*TestErrors) GetNextError 

func (errs *TestErrors) GetNextError() (bool, 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.