commontestutils

package
v1.10.0 Latest Latest
Warning

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

Go to latest
Published: Dec 13, 2023 License: Apache-2.0 Imports: 51 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

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 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 (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) Init

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 (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) Init

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

func (ClusterInfoSRCPHAIMock) GetDeployment() *appsv1.Deployment

func (ClusterInfoSRCPHAIMock) GetDomain

func (ClusterInfoSRCPHAIMock) GetDomain() string

func (ClusterInfoSRCPHAIMock) GetPod

func (ClusterInfoSRCPHAIMock) GetPod() *corev1.Pod

func (ClusterInfoSRCPHAIMock) Init

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) 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 (*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 (*HcoTestStatusWriter) Update

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL