commonTestUtils

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2022 License: Apache-2.0 Imports: 41 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"
)

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 NewHco 

func NewHco() *hcov1beta1.HyperConverged

func NewHcoNamespace 

func NewHcoNamespace() *corev1.Namespace

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) 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) 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) 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) 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) 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) 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.PatchOption) error

func (*HcoTestStatusWriter) Update 

func (sw *HcoTestStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) 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.