commontestutils

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2024 License: Apache-2.0 Imports: 53 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 KeysFromSSMap added in v1.11.0 

func KeysFromSSMap(ssmap map[string]string) gstruct.Keys

func NewClusterMock 

func NewClusterMock(config *rest.Config, options cluster.Options, 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 

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 

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) IsMonitoringAvailable 

func (c ClusterInfoMock) IsMonitoringAvailable() bool

func (ClusterInfoMock) IsOpenshift 

func (ClusterInfoMock) IsOpenshift() bool

func (ClusterInfoMock) IsRunningLocally 

func (ClusterInfoMock) IsRunningLocally() bool

func (ClusterInfoMock) IsSingleStackIPv6 

func (c ClusterInfoMock) IsSingleStackIPv6() bool

func (ClusterInfoMock) RefreshAPIServerCR 

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

type ClusterInfoSNOMock 

type ClusterInfoSNOMock struct{}

ClusterInfoSNOMock mocks Openshift SNO

func (ClusterInfoSNOMock) GetBaseDomain 

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) IsMonitoringAvailable 

func (c ClusterInfoSNOMock) IsMonitoringAvailable() bool

func (ClusterInfoSNOMock) IsOpenshift 

func (ClusterInfoSNOMock) IsOpenshift() bool

func (ClusterInfoSNOMock) IsRunningLocally 

func (ClusterInfoSNOMock) IsRunningLocally() bool

func (ClusterInfoSNOMock) IsSingleStackIPv6 

func (c ClusterInfoSNOMock) IsSingleStackIPv6() 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 

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) IsMonitoringAvailable 

func (ClusterInfoSRCPHAIMock) IsMonitoringAvailable() bool

func (ClusterInfoSRCPHAIMock) IsOpenshift 

func (ClusterInfoSRCPHAIMock) IsOpenshift() bool

func (ClusterInfoSRCPHAIMock) IsRunningLocally 

func (ClusterInfoSRCPHAIMock) IsRunningLocally() bool

func (ClusterInfoSRCPHAIMock) IsSingleStackIPv6 

func (m ClusterInfoSRCPHAIMock) IsSingleStackIPv6() 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 []client.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) GroupVersionKindFor 

func (c *HcoTestClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, 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) IsObjectNamespaced 

func (c *HcoTestClient) IsObjectNamespaced(obj runtime.Object) (bool, error)

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 

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 

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 

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

func (*ManagerMock) Add 

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 

func (mm *ManagerMock) AddHealthzCheck(_ string, _ healthz.Checker) error

AddHealthzCheck allows you to add Healthz checker.

func (*ManagerMock) AddMetricsExtraHandler 

func (mm *ManagerMock) AddMetricsExtraHandler(_ string, _ http.Handler) error

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

func (*ManagerMock) AddReadyzCheck 

func (mm *ManagerMock) AddReadyzCheck(_ string, _ healthz.Checker) error

AddReadyzCheck allows you to add Readyz checker.

func (*ManagerMock) Elected 

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

func (*ManagerMock) GetAPIReader 

func (mm *ManagerMock) GetAPIReader() client.Reader

func (*ManagerMock) GetCache 

func (mm *ManagerMock) GetCache() cache.Cache

func (*ManagerMock) GetClient 

func (mm *ManagerMock) GetClient() client.Client

func (*ManagerMock) GetConfig 

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

func (*ManagerMock) GetControllerOptions 

func (mm *ManagerMock) GetControllerOptions() config.Controller

func (*ManagerMock) GetEventRecorderFor 

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

func (*ManagerMock) GetFieldIndexer 

func (mm *ManagerMock) GetFieldIndexer() client.FieldIndexer

func (*ManagerMock) GetHTTPClient 

func (mm *ManagerMock) GetHTTPClient() *http.Client

func (*ManagerMock) GetLogger 

func (mm *ManagerMock) GetLogger() logr.Logger

func (*ManagerMock) GetRESTMapper 

func (mm *ManagerMock) GetRESTMapper() meta.RESTMapper

func (*ManagerMock) GetRunnables 

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

func (*ManagerMock) GetScheme 

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

func (*ManagerMock) GetWebhookServer 

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

func (*ManagerMock) SetFields deprecated 

func (mm *ManagerMock) SetFields(_ interface{}) error

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

func (*ManagerMock) Start 

func (mm *ManagerMock) Start(_ 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.