utils

Documentation

Index

• func AddFinalizer(meta *metav1.ObjectMeta, finalizer string) bool
• func AppendModuleDeploymentCondition(conditions []v1alpha1.ModuleDeploymentCondition, ...) []v1alpha1.ModuleDeploymentCondition
• func Error(err error, msg string, keysAndValues ...interface{}) error
• func GetModuleCountFromPod(pod *corev1.Pod) (count int)
• func GetModuleInstanceCount(pod corev1.Pod) int
• func GetNextReconcileTime(currentTime time.Time) time.Duration
• func HasFinalizer(meta *metav1.ObjectMeta, needle string) bool
• func HasOwnerReference(meta *metav1.ObjectMeta, needle string) bool
• func Key(req ctrl.Request) string
• func PrepareModuleDeployment(namespace, moduleDeploymentName string) v1alpha1.ModuleDeployment
• func PrepareModuleReplicaSet(namespace, moduleReplicaSetName string) v1alpha1.ModuleReplicaSet
• func RemoveFinalizer(meta *metav1.ObjectMeta, needle string) bool
• func UpdateResource(client client.Client, ctx context.Context, obj client.Object, ...) error
• func UpdateStatus(client client.Client, ctx context.Context, obj client.Object, ...) error
• type MockClient
  • func (m MockClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (m MockClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (m MockClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (m MockClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error
  • func (m MockClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
  • func (m MockClient) IsObjectNamespaced(obj runtime.Object) (bool, error)
  • func (m MockClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (m MockClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (m MockClient) RESTMapper() meta.RESTMapper
  • func (m MockClient) Scheme() *runtime.Scheme
  • func (m MockClient) Status() client.SubResourceWriter
  • func (m MockClient) SubResource(subResource string) client.SubResourceClient
  • func (m MockClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type MockSubResourceWriter
  • func (m MockSubResourceWriter) Create(ctx context.Context, obj client.Object, subResource client.Object, ...) error
  • func (m MockSubResourceWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (m MockSubResourceWriter) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error

Functions

func AddFinalizer

func AddFinalizer(meta *metav1.ObjectMeta, finalizer string) bool

func AppendModuleDeploymentCondition

func AppendModuleDeploymentCondition(conditions []v1alpha1.ModuleDeploymentCondition, condition v1alpha1.ModuleDeploymentCondition) []v1alpha1.ModuleDeploymentCondition

func Error

func Error(err error, msg string, keysAndValues ...interface{}) error

func GetModuleCountFromPod

func GetModuleCountFromPod(pod *corev1.Pod) (count int)

func GetModuleInstanceCount

func GetModuleInstanceCount(pod corev1.Pod) int

func GetNextReconcileTime

func GetNextReconcileTime(currentTime time.Time) time.Duration

func HasFinalizer

func HasFinalizer(meta *metav1.ObjectMeta, needle string) bool

func HasOwnerReference

func HasOwnerReference(meta *metav1.ObjectMeta, needle string) bool

func Key

func Key(req ctrl.Request) string

func PrepareModuleDeployment

func PrepareModuleDeployment(namespace, moduleDeploymentName string) v1alpha1.ModuleDeployment

func PrepareModuleReplicaSet

func PrepareModuleReplicaSet(namespace, moduleReplicaSetName string) v1alpha1.ModuleReplicaSet

func RemoveFinalizer

func RemoveFinalizer(meta *metav1.ObjectMeta, needle string) bool

func UpdateResource

func UpdateResource(client client.Client, ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

func UpdateStatus

func UpdateStatus(client client.Client, ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error

Types

type MockClient

type MockClient struct {
}

func (MockClient) Create

func (m MockClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (MockClient) Delete

func (m MockClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (MockClient) DeleteAllOf

func (m MockClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (MockClient) Get

func (m MockClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error

func (MockClient) GroupVersionKindFor

func (m MockClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)

func (MockClient) IsObjectNamespaced

func (m MockClient) IsObjectNamespaced(obj runtime.Object) (bool, error)

func (MockClient) List

func (m MockClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (MockClient) Patch

func (m MockClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (MockClient) RESTMapper

func (m MockClient) RESTMapper() meta.RESTMapper

func (MockClient) Scheme

func (m MockClient) Scheme() *runtime.Scheme

func (MockClient) Status

func (m MockClient) Status() client.SubResourceWriter

func (MockClient) SubResource

func (m MockClient) SubResource(subResource string) client.SubResourceClient

func (MockClient) Update

func (m MockClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type MockSubResourceWriter

type MockSubResourceWriter struct {
}

func (MockSubResourceWriter) Create

func (m MockSubResourceWriter) Create(ctx context.Context, obj client.Object, subResource client.Object, opts ...client.SubResourceCreateOption) error

func (MockSubResourceWriter) Patch

func (m MockSubResourceWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.SubResourcePatchOption) error

func (MockSubResourceWriter) Update

func (m MockSubResourceWriter) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error