commontestutils

Oct 4, 2024

Changes in this version

type ClusterInfoMock

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

+ func (c ClusterInfoMock) IsDeschedulerAvailable() bool

+ func (c ClusterInfoMock) IsDeschedulerCRDDeployed(_ context.Context, _ client.Client) bool

+ func (c ClusterInfoMock) IsDeschedulerMisconfigured() bool

type ClusterInfoSNOMock

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

+ func (c ClusterInfoSNOMock) IsDeschedulerAvailable() bool

+ func (c ClusterInfoSNOMock) IsDeschedulerCRDDeployed(_ context.Context, _ client.Client) bool

+ func (c ClusterInfoSNOMock) IsDeschedulerMisconfigured() bool

type ClusterInfoSRCPHAIMock

+ func (ClusterInfoSRCPHAIMock) IsDeschedulerAvailable() bool

+ func (ClusterInfoSRCPHAIMock) IsDeschedulerCRDDeployed(_ context.Context, _ client.Client) bool

+ func (ClusterInfoSRCPHAIMock) IsDeschedulerMisconfigured() bool

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

type ManagerMock

+ func (mm *ManagerMock) AddMetricsServerExtraHandler(path string, handler http.Handler) error

Mar 6, 2024

Changes in this version

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

Dec 13, 2023

Changes in this version

+ const BaseDomain

+ const Name

+ const Namespace

+ const RSName

+ const VirtioWinImage

+ var TestLogger = zap.New(zap.WriteTo(GinkgoWriter), zap.UseDevMode(true)).WithName("controller_hyperconverged")

+ var TestRequest = reconcile.Request

+ func CopyFile(dest, src string) error

+ func GetScheme() *runtime.Scheme

+ func NewClusterMock(config *rest.Config, options cluster.Options, client client.Client, ...) (cluster.Cluster, error)

+ func NewHco() *hcov1beta1.HyperConverged

+ func NewHcoNamespace() *corev1.Namespace

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

+ func NewNodePlacement() *sdkapi.NodePlacement

+ func NewOtherNodePlacement() *sdkapi.NodePlacement

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

+ func RepresentCondition(expected metav1.Condition) gomegatypes.GomegaMatcher

+ type ClusterInfoMock struct

+ func (ClusterInfoMock) GetBaseDomain() string

+ func (ClusterInfoMock) GetDomain() string

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

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

+ func (ClusterInfoMock) IsControlPlaneHighlyAvailable() bool

+ func (ClusterInfoMock) IsInfrastructureHighlyAvailable() bool

+ func (ClusterInfoMock) IsManagedByOLM() bool

+ func (ClusterInfoMock) IsOpenshift() bool

+ func (ClusterInfoMock) IsRunningLocally() bool

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

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

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

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

+ func (c ClusterInfoMock) IsConsolePluginImageProvided() bool

+ func (c ClusterInfoMock) IsMonitoringAvailable() bool

+ func (c ClusterInfoMock) IsSingleStackIPv6() bool

+ type ClusterInfoSNOMock struct

+ func (ClusterInfoSNOMock) GetBaseDomain() string

+ func (ClusterInfoSNOMock) GetDomain() string

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

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

+ func (ClusterInfoSNOMock) IsConsolePluginImageProvided() bool

+ func (ClusterInfoSNOMock) IsControlPlaneHighlyAvailable() bool

+ func (ClusterInfoSNOMock) IsInfrastructureHighlyAvailable() bool

+ func (ClusterInfoSNOMock) IsManagedByOLM() bool

+ func (ClusterInfoSNOMock) IsOpenshift() bool

+ func (ClusterInfoSNOMock) IsRunningLocally() bool

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

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

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

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

+ func (c ClusterInfoSNOMock) IsMonitoringAvailable() bool

+ func (c ClusterInfoSNOMock) IsSingleStackIPv6() bool

+ type ClusterInfoSRCPHAIMock struct

+ func (ClusterInfoSRCPHAIMock) GetBaseDomain() string

+ func (ClusterInfoSRCPHAIMock) GetCSV() *csvv1alpha1.ClusterServiceVersion

+ func (ClusterInfoSRCPHAIMock) GetDeployment() *appsv1.Deployment

+ func (ClusterInfoSRCPHAIMock) GetDomain() string

+ func (ClusterInfoSRCPHAIMock) GetPod() *corev1.Pod

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

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

+ func (ClusterInfoSRCPHAIMock) IsConsolePluginImageProvided() bool

+ func (ClusterInfoSRCPHAIMock) IsControlPlaneHighlyAvailable() bool

+ func (ClusterInfoSRCPHAIMock) IsInfrastructureHighlyAvailable() bool

+ func (ClusterInfoSRCPHAIMock) IsManagedByOLM() bool

+ func (ClusterInfoSRCPHAIMock) IsMonitoringAvailable() bool

+ func (ClusterInfoSRCPHAIMock) IsOpenshift() bool

+ func (ClusterInfoSRCPHAIMock) IsRunningLocally() bool

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

+ func (m ClusterInfoSRCPHAIMock) IsSingleStackIPv6() bool

+ type EventEmitterMock struct

+ func NewEventEmitterMock() *EventEmitterMock

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

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

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

+ func (eem *EventEmitterMock) Reset()

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

+ func (eem EventEmitterMock) CheckNoEventEmitted() bool

+ type FakeReadErrorGenerator func(key client.ObjectKey) error

+ type FakeWriteErrorGenerator func(obj client.Object) error

+ type HcoTestClient struct

+ func InitClient(clientObjects []client.Object) *HcoTestClient

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

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

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

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

+ func (c *HcoTestClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)

+ func (c *HcoTestClient) InitiateCreateErrors(f FakeWriteErrorGenerator)

+ func (c *HcoTestClient) InitiateDeleteErrors(f FakeWriteErrorGenerator)

+ func (c *HcoTestClient) InitiateGetErrors(f FakeReadErrorGenerator)

+ func (c *HcoTestClient) InitiateUpdateErrors(f FakeWriteErrorGenerator)

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

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

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

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

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

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

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

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

+ type HcoTestStatusWriter struct

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

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

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

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

+ type ManagerMock struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (mm *ManagerMock) Start(_ context.Context) (err error)

+ type MockEvent struct

+ EventType string

+ Msg string

+ Reason string

+ type RepresentConditionMatcher struct

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

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

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

+ type TestErrors []error

+ func (errs *TestErrors) GetNextError() (bool, error)