commonTestUtils

Documentation

Index

• Constants
• Variables
• func GetScheme() *runtime.Scheme
• func NewHco() *hcov1beta1.HyperConverged
• func NewNodePlacement() *sdkapi.NodePlacement
• func NewOtherNodePlacement() *sdkapi.NodePlacement
• func NewReq(inst *hcov1beta1.HyperConverged) *common.HcoRequest
• type EventEmitterMock
  • func NewEventEmitterMock() *EventEmitterMock
  • func (eem EventEmitterMock) CheckEvents(expectedEvents []MockEvent) bool
  • func (eem *EventEmitterMock) EmitEvent(_ runtime.Object, eventType, reason, msg string)
  • func (EventEmitterMock) Init(_ context.Context, _ manager.Manager, _ hcoutil.ClusterInfo, _ logr.Logger)
  • func (eem *EventEmitterMock) Reset()
  • func (EventEmitterMock) UpdateClient(_ context.Context, _ client.Reader, _ logr.Logger)
• type FakeReadErrorGenerator
• type FakeWriteErrorGenerator
• type HcoTestClient
  • func InitClient(clientObjects []runtime.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) InitiateCreateErrors(f FakeWriteErrorGenerator)
  • func (c *HcoTestClient) InitiateDeleteErrors(f FakeWriteErrorGenerator)
  • func (c *HcoTestClient) InitiateGetErrors(f FakeReadErrorGenerator)
  • func (c *HcoTestClient) InitiateUpdateErrors(f FakeWriteErrorGenerator)
  • 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) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type HcoTestStatusWriter
  • 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.UpdateOption) error
• type MockEvent
• type TestErrors
  • func (errs *TestErrors) GetNextError() (bool, error)

Constants

const (
	Name            = "kubevirt-hyperconverged"
	Namespace       = "kubevirt-hyperconverged"
	ConversionImage = "quay.io/kubevirt/kubevirt-v2v-conversion:v2.0.0"
	VmwareImage     = "quay.io/kubevirt/kubevirt-vmware:v2.0.0"
)

Name and Namespace of our primary resource

Variables

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 GetScheme

func GetScheme() *runtime.Scheme

func NewHco

func NewHco() *hcov1beta1.HyperConverged

func NewNodePlacement

func NewNodePlacement() *sdkapi.NodePlacement

func NewOtherNodePlacement

func NewOtherNodePlacement() *sdkapi.NodePlacement

func NewReq

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

Types

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

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

func (EventEmitterMock) Init

func (EventEmitterMock) Init(_ context.Context, _ manager.Manager, _ hcoutil.ClusterInfo, _ logr.Logger)

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
}

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 TestErrors

type TestErrors []error

func (*TestErrors) GetNextError

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