testSupport

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const ChangeStatusSubroutineFinalizer = "changestatus"
View Source 
const ContextValueKey = keys.ContextKey("ContextValueKey")
View Source 
const FailureScenarioSubroutineFinalizer = "failuresubroutine"
View Source 
const SubroutineFinalizer = "finalizer"

Variables

This section is empty.

Functions

func CreateFakeClient 

func CreateFakeClient(t *testing.T, objects ...client.Object) client.WithWatch

Types

type AddConditionSubroutine added in v0.0.21 

type AddConditionSubroutine struct {
	Ready metav1.ConditionStatus
}

func (AddConditionSubroutine) Finalize added in v0.0.21 

func (c AddConditionSubroutine) Finalize(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

func (AddConditionSubroutine) Finalizers added in v0.0.21 

func (c AddConditionSubroutine) Finalizers() []string

func (AddConditionSubroutine) GetName added in v0.0.21 

func (c AddConditionSubroutine) GetName() string

func (AddConditionSubroutine) Process added in v0.0.21 

func (c AddConditionSubroutine) Process(_ context.Context, runtimeObj runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

type ChangeStatusSubroutine added in v0.0.21 

type ChangeStatusSubroutine struct {
	Client client.Client
}

func (ChangeStatusSubroutine) Finalize added in v0.0.21 

func (c ChangeStatusSubroutine) Finalize(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

func (ChangeStatusSubroutine) Finalizers added in v0.0.21 

func (c ChangeStatusSubroutine) Finalizers() []string

func (ChangeStatusSubroutine) GetName added in v0.0.21 

func (c ChangeStatusSubroutine) GetName() string

func (ChangeStatusSubroutine) Process added in v0.0.21 

func (c ChangeStatusSubroutine) Process(_ context.Context, runtimeObj runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

type ContextValueSubroutine added in v0.0.21 

type ContextValueSubroutine struct {
}

func (ContextValueSubroutine) Finalize added in v0.0.21 

func (f ContextValueSubroutine) Finalize(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

func (ContextValueSubroutine) Finalizers added in v0.0.21 

func (f ContextValueSubroutine) Finalizers() []string

func (ContextValueSubroutine) GetName added in v0.0.21 

func (c ContextValueSubroutine) GetName() string

func (ContextValueSubroutine) Process added in v0.0.21 

func (f ContextValueSubroutine) Process(ctx context.Context, r runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

type DummyRuntimeObject added in v0.0.21 

type DummyRuntimeObject struct{}

func (DummyRuntimeObject) DeepCopyObject added in v0.0.21 

func (d DummyRuntimeObject) DeepCopyObject() runtime.Object

func (DummyRuntimeObject) GetAnnotations added in v0.0.21 

func (d DummyRuntimeObject) GetAnnotations() map[string]string

func (DummyRuntimeObject) GetClusterName added in v0.0.21 

func (d DummyRuntimeObject) GetClusterName() string

func (DummyRuntimeObject) GetCreationTimestamp added in v0.0.21 

func (d DummyRuntimeObject) GetCreationTimestamp() metav1.Time

func (DummyRuntimeObject) GetDeletionGracePeriodSeconds added in v0.0.21 

func (d DummyRuntimeObject) GetDeletionGracePeriodSeconds() *int64

func (DummyRuntimeObject) GetDeletionTimestamp added in v0.0.21 

func (d DummyRuntimeObject) GetDeletionTimestamp() *metav1.Time

func (DummyRuntimeObject) GetFinalizers added in v0.0.21 

func (d DummyRuntimeObject) GetFinalizers() []string

func (DummyRuntimeObject) GetGenerateName added in v0.0.21 

func (d DummyRuntimeObject) GetGenerateName() string

func (DummyRuntimeObject) GetGeneration added in v0.0.21 

func (d DummyRuntimeObject) GetGeneration() int64

func (DummyRuntimeObject) GetLabels added in v0.0.21 

func (d DummyRuntimeObject) GetLabels() map[string]string

func (DummyRuntimeObject) GetManagedFields added in v0.0.21 

func (d DummyRuntimeObject) GetManagedFields() []metav1.ManagedFieldsEntry

func (DummyRuntimeObject) GetName added in v0.0.21 

func (d DummyRuntimeObject) GetName() string

func (DummyRuntimeObject) GetNamespace added in v0.0.21 

func (d DummyRuntimeObject) GetNamespace() string

func (DummyRuntimeObject) GetObjectKind added in v0.0.21 

func (d DummyRuntimeObject) GetObjectKind() schema.ObjectKind

func (DummyRuntimeObject) GetOwnerReferences added in v0.0.21 

func (d DummyRuntimeObject) GetOwnerReferences() []metav1.OwnerReference

func (DummyRuntimeObject) GetResourceVersion added in v0.0.21 

func (d DummyRuntimeObject) GetResourceVersion() string
func (d DummyRuntimeObject) GetSelfLink() string

func (DummyRuntimeObject) GetUID added in v0.0.21 

func (d DummyRuntimeObject) GetUID() types.UID

func (DummyRuntimeObject) SetAnnotations added in v0.0.21 

func (d DummyRuntimeObject) SetAnnotations(map[string]string)

func (DummyRuntimeObject) SetClusterName added in v0.0.21 

func (d DummyRuntimeObject) SetClusterName(string)

func (DummyRuntimeObject) SetCreationTimestamp added in v0.0.21 

func (d DummyRuntimeObject) SetCreationTimestamp(metav1.Time)

func (DummyRuntimeObject) SetDeletionGracePeriodSeconds added in v0.0.21 

func (d DummyRuntimeObject) SetDeletionGracePeriodSeconds(*int64)

func (DummyRuntimeObject) SetDeletionTimestamp added in v0.0.21 

func (d DummyRuntimeObject) SetDeletionTimestamp(*metav1.Time)

func (DummyRuntimeObject) SetFinalizers added in v0.0.21 

func (d DummyRuntimeObject) SetFinalizers([]string)

func (DummyRuntimeObject) SetGenerateName added in v0.0.21 

func (d DummyRuntimeObject) SetGenerateName(string)

func (DummyRuntimeObject) SetGeneration added in v0.0.21 

func (d DummyRuntimeObject) SetGeneration(int64)

func (DummyRuntimeObject) SetLabels added in v0.0.21 

func (d DummyRuntimeObject) SetLabels(map[string]string)

func (DummyRuntimeObject) SetManagedFields added in v0.0.21 

func (d DummyRuntimeObject) SetManagedFields([]metav1.ManagedFieldsEntry)

func (DummyRuntimeObject) SetName added in v0.0.21 

func (d DummyRuntimeObject) SetName(string)

func (DummyRuntimeObject) SetNamespace added in v0.0.21 

func (d DummyRuntimeObject) SetNamespace(string)

func (DummyRuntimeObject) SetOwnerReferences added in v0.0.21 

func (d DummyRuntimeObject) SetOwnerReferences([]metav1.OwnerReference)

func (DummyRuntimeObject) SetResourceVersion added in v0.0.21 

func (d DummyRuntimeObject) SetResourceVersion(string)
func (d DummyRuntimeObject) SetSelfLink(string)

func (DummyRuntimeObject) SetUID added in v0.0.21 

func (d DummyRuntimeObject) SetUID(types.UID)

type DummyRuntimeObjectWithConditions added in v0.0.21 

type DummyRuntimeObjectWithConditions struct {
	DummyRuntimeObject
}

func (DummyRuntimeObjectWithConditions) GetConditions added in v0.0.21 

func (d DummyRuntimeObjectWithConditions) GetConditions() []metav1.Condition

func (DummyRuntimeObjectWithConditions) SetConditions added in v0.0.21 

func (d DummyRuntimeObjectWithConditions) SetConditions([]metav1.Condition)

type FailureScenarioSubroutine added in v0.0.21 

type FailureScenarioSubroutine struct {
	Retry              bool
	RequeAfter         bool
	FinalizeRetry      bool
	FinalizeRequeAfter bool
}

func (FailureScenarioSubroutine) Finalize added in v0.0.21 

func (f FailureScenarioSubroutine) Finalize(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

func (FailureScenarioSubroutine) Finalizers added in v0.0.21 

func (f FailureScenarioSubroutine) Finalizers() []string

func (FailureScenarioSubroutine) GetName added in v0.0.21 

func (c FailureScenarioSubroutine) GetName() string

func (FailureScenarioSubroutine) Process added in v0.0.21 

func (f FailureScenarioSubroutine) Process(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

type FakeCluster added in v0.1.0 

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

func (FakeCluster) GetAPIReader added in v0.1.0 

func (f FakeCluster) GetAPIReader() client.Reader

func (FakeCluster) GetCache added in v0.1.0 

func (f FakeCluster) GetCache() cache.Cache

func (FakeCluster) GetClient added in v0.1.0 

func (f FakeCluster) GetClient() client.Client

func (FakeCluster) GetConfig added in v0.1.0 

func (f FakeCluster) GetConfig() *rest.Config

func (FakeCluster) GetEventRecorderFor added in v0.1.0 

func (f FakeCluster) GetEventRecorderFor(string) record.EventRecorder

func (FakeCluster) GetFieldIndexer added in v0.1.0 

func (f FakeCluster) GetFieldIndexer() client.FieldIndexer

func (FakeCluster) GetHTTPClient added in v0.1.0 

func (f FakeCluster) GetHTTPClient() *http.Client

func (FakeCluster) GetRESTMapper added in v0.1.0 

func (f FakeCluster) GetRESTMapper() meta.RESTMapper

func (FakeCluster) GetScheme added in v0.1.0 

func (f FakeCluster) GetScheme() *runtime.Scheme

func (FakeCluster) Start added in v0.1.0 

func (f FakeCluster) Start(context.Context) error

type FakeManager added in v0.1.0 

type FakeManager struct{ Client client.Client }

func (*FakeManager) GetCluster added in v0.1.0 

func (f *FakeManager) GetCluster(context.Context, string) (cluster.Cluster, error)

type FakeProvider added in v0.1.0 

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

func NewFakeProvider added in v0.1.0 

func NewFakeProvider(cfg *rest.Config) *FakeProvider

func (FakeProvider) Get added in v0.1.0 

func (f FakeProvider) Get(context.Context, string) (cluster.Cluster, error)

func (FakeProvider) IndexField added in v0.1.0 

func (f FakeProvider) IndexField(context.Context, client.Object, string, client.IndexerFunc) error

IndexField indexes the given object by the given field on all engaged clusters, current and future.

type FinalizerSubroutine added in v0.0.21 

type FinalizerSubroutine struct {
	Client       client.Client
	Err          error
	RequeueAfter time.Duration
}

func (FinalizerSubroutine) Finalize added in v0.0.21 

func (c FinalizerSubroutine) Finalize(_ context.Context, _ runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

func (FinalizerSubroutine) Finalizers added in v0.0.21 

func (c FinalizerSubroutine) Finalizers() []string

func (FinalizerSubroutine) GetName added in v0.0.21 

func (c FinalizerSubroutine) GetName() string

func (FinalizerSubroutine) Process added in v0.0.21 

func (c FinalizerSubroutine) Process(_ context.Context, runtimeObj runtimeobject.RuntimeObject) (controllerruntime.Result, errors.OperatorError)

type ImplementConditions added in v0.0.21 

type ImplementConditions struct {
	TestApiObject `json:",inline"`
}

func (*ImplementConditions) GetConditions added in v0.0.21 

func (m *ImplementConditions) GetConditions() []metav1.Condition

func (*ImplementConditions) SetConditions added in v0.0.21 

func (m *ImplementConditions) SetConditions(conditions []metav1.Condition)

type ImplementConditionsAndSpreadReconciles added in v0.0.21 

type ImplementConditionsAndSpreadReconciles struct {
	TestApiObject `json:",inline"`
}

func (*ImplementConditionsAndSpreadReconciles) GetConditions added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) GetConditions() []metav1.Condition

func (*ImplementConditionsAndSpreadReconciles) GetGeneration added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) GetGeneration() int64

func (*ImplementConditionsAndSpreadReconciles) GetNextReconcileTime added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) GetNextReconcileTime() metav1.Time

func (*ImplementConditionsAndSpreadReconciles) GetObservedGeneration added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) GetObservedGeneration() int64

func (*ImplementConditionsAndSpreadReconciles) SetConditions added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) SetConditions(conditions []metav1.Condition)

func (*ImplementConditionsAndSpreadReconciles) SetNextReconcileTime added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) SetNextReconcileTime(time metav1.Time)

func (*ImplementConditionsAndSpreadReconciles) SetObservedGeneration added in v0.0.21 

func (m *ImplementConditionsAndSpreadReconciles) SetObservedGeneration(g int64)

type ImplementingSpreadReconciles added in v0.0.21 

type ImplementingSpreadReconciles struct {
	TestApiObject `json:",inline"`
}

func (*ImplementingSpreadReconciles) GetGeneration added in v0.0.21 

func (m *ImplementingSpreadReconciles) GetGeneration() int64

func (*ImplementingSpreadReconciles) GetNextReconcileTime added in v0.0.21 

func (m *ImplementingSpreadReconciles) GetNextReconcileTime() metav1.Time

func (*ImplementingSpreadReconciles) GetObservedGeneration added in v0.0.21 

func (m *ImplementingSpreadReconciles) GetObservedGeneration() int64

func (*ImplementingSpreadReconciles) SetNextReconcileTime added in v0.0.21 

func (m *ImplementingSpreadReconciles) SetNextReconcileTime(time metav1.Time)

func (*ImplementingSpreadReconciles) SetObservedGeneration added in v0.0.21 

func (m *ImplementingSpreadReconciles) SetObservedGeneration(g int64)

type NotImplementingSpreadReconciles added in v0.0.21 

type NotImplementingSpreadReconciles struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Status TestStatus `json:"status,omitempty"`
}

func (*NotImplementingSpreadReconciles) DeepCopy added in v0.0.21 

func (m *NotImplementingSpreadReconciles) DeepCopy() *NotImplementingSpreadReconciles

func (*NotImplementingSpreadReconciles) DeepCopyInto added in v0.0.21 

func (m *NotImplementingSpreadReconciles) DeepCopyInto(out *NotImplementingSpreadReconciles)

func (*NotImplementingSpreadReconciles) DeepCopyObject added in v0.0.21 

func (m *NotImplementingSpreadReconciles) DeepCopyObject() runtime.Object

type TestApiObject 

type TestApiObject struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Status TestStatus `json:"status,omitempty"`
}

func (*TestApiObject) DeepCopy 

func (t *TestApiObject) DeepCopy() *TestApiObject

func (*TestApiObject) DeepCopyInto 

func (m *TestApiObject) DeepCopyInto(out *TestApiObject)

func (*TestApiObject) DeepCopyObject 

func (t *TestApiObject) DeepCopyObject() runtime.Object

type TestConditionManager added in v0.1.0 

type TestConditionManager struct{}

func (TestConditionManager) SetInstanceConditionReady added in v0.1.0 

func (t TestConditionManager) SetInstanceConditionReady(conditions *[]metav1.Condition, _ metav1.ConditionStatus) bool

func (TestConditionManager) SetInstanceConditionUnknownIfNotSet added in v0.1.0 

func (t TestConditionManager) SetInstanceConditionUnknownIfNotSet(conditions *[]metav1.Condition) bool

func (TestConditionManager) SetSubroutineCondition added in v0.1.0 

func (t TestConditionManager) SetSubroutineCondition(conditions *[]metav1.Condition, subroutine subroutine.Subroutine, _ ctrl.Result, _ error, _ bool, _ *logger.Logger) bool

func (TestConditionManager) SetSubroutineConditionToUnknownIfNotSet added in v0.1.0 

func (t TestConditionManager) SetSubroutineConditionToUnknownIfNotSet(conditions *[]metav1.Condition, subroutine subroutine.Subroutine, _ bool, _ *logger.Logger) bool

type TestLifecycleManager added in v0.0.21 

type TestLifecycleManager struct {
	Logger         *logger.Logger
	SubroutinesArr []subroutine.Subroutine

	ShouldReconcile bool
	// contains filtered or unexported fields
}

func (*TestLifecycleManager) ConditionsManager added in v0.0.21 

func (l *TestLifecycleManager) ConditionsManager() api.ConditionManager

func (*TestLifecycleManager) Config added in v0.0.21 

func (l *TestLifecycleManager) Config() api.Config

func (*TestLifecycleManager) Log added in v0.0.21 

func (l *TestLifecycleManager) Log() *logger.Logger

func (*TestLifecycleManager) PrepareContextFunc added in v0.0.21 

func (l *TestLifecycleManager) PrepareContextFunc() api.PrepareContextFunc

func (*TestLifecycleManager) Spreader added in v0.0.21 

func (l *TestLifecycleManager) Spreader() api.SpreadManager

func (*TestLifecycleManager) Subroutines added in v0.0.21 

func (l *TestLifecycleManager) Subroutines() []subroutine.Subroutine

func (*TestLifecycleManager) WithConditionManagement added in v0.1.0 

func (l *TestLifecycleManager) WithConditionManagement() api.Lifecycle

func (*TestLifecycleManager) WithPrepareContextFunc added in v0.1.0 

func (l *TestLifecycleManager) WithPrepareContextFunc(prepareFunction api.PrepareContextFunc) *TestLifecycleManager

func (*TestLifecycleManager) WithSpreadingReconciles added in v0.1.0 

func (l *TestLifecycleManager) WithSpreadingReconciles() api.Lifecycle

type TestNoStatusApiObject 

type TestNoStatusApiObject struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
}

func (*TestNoStatusApiObject) DeepCopy 

func (t *TestNoStatusApiObject) DeepCopy() *TestNoStatusApiObject

func (*TestNoStatusApiObject) DeepCopyInto 

func (m *TestNoStatusApiObject) DeepCopyInto(out *TestNoStatusApiObject)

func (*TestNoStatusApiObject) DeepCopyObject 

func (t *TestNoStatusApiObject) DeepCopyObject() runtime.Object

type TestSpreader added in v0.1.0 

type TestSpreader struct {
	ShouldReconcile bool
}

func (TestSpreader) MustToRuntimeObjectSpreadReconcileStatusInterface added in v0.1.0 

func (t TestSpreader) MustToRuntimeObjectSpreadReconcileStatusInterface() api.RuntimeObjectSpreadReconcileStatus

func (TestSpreader) OnNextReconcile added in v0.1.0 

func (t TestSpreader) OnNextReconcile(runtimeobject.RuntimeObject, *logger.Logger) (ctrl.Result, error)

func (TestSpreader) ReconcileRequired added in v0.1.0 

func (t TestSpreader) ReconcileRequired(runtimeobject.RuntimeObject, *logger.Logger) bool

func (TestSpreader) RemoveRefreshLabelIfExists added in v0.1.0 

func (t TestSpreader) RemoveRefreshLabelIfExists(instance runtimeobject.RuntimeObject) bool

func (TestSpreader) SetNextReconcileTime added in v0.1.0 

func (t TestSpreader) SetNextReconcileTime(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, _ *logger.Logger)

func (TestSpreader) ToRuntimeObjectSpreadReconcileStatusInterface added in v0.1.0 

func (t TestSpreader) ToRuntimeObjectSpreadReconcileStatusInterface() (api.RuntimeObjectSpreadReconcileStatus, error)

func (TestSpreader) UpdateObservedGeneration added in v0.1.0 

func (t TestSpreader) UpdateObservedGeneration(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, _ *logger.Logger)

type TestStatus 

type TestStatus struct {
	Some               string
	Conditions         []metav1.Condition
	NextReconcileTime  metav1.Time
	ObservedGeneration int64
}

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.