test

Documentation

Index

• func AssertFinalizers[T runtime.Object](client resource.Interface[T], name string, finalizers ...string)
• func AwaitAndVerifyResource[T runtime.Object](client resource.Interface[T], name string, verify func(T) bool) T
• func AwaitFinalizer[T runtime.Object](client resource.Interface[T], name, finalizer string)
• func AwaitNoFinalizer[T runtime.Object](client resource.Interface[T], name, finalizer string)
• func AwaitNoResource[T runtime.Object](client resource.Interface[T], name string)
• func AwaitResource[T runtime.Object](client resource.Interface[T], name string) T
• func AwaitStatusCondition(expCond *metav1.Condition, get func() ([]metav1.Condition, error))
• func AwaitUpdateAction(f *testing.Fake, resourceType, name string) runtime.Object
• func EnsureActionsForResource(f *testing.Fake, resourceType string, expectedVerbs ...string)
• func EnsureNoActionsForResource(f *testing.Fake, resourceType string, expectedVerbs ...string)
• func EnsureNoResource[T runtime.Object](client resource.Interface[T], name string)
• func GetFinalizers[T runtime.Object](client resource.Interface[T], name string) []string
• func GetOccurredActionVerbs(f *testing.Fake, resourceType string, expectedVerbs ...string) []string
• func SetDeleting[T runtime.Object](client resource.Interface[T], name string)
• type LeaderElectionSupport
  • func NewLeaderElectionSupport(kubeClient *k8sfake.Clientset, namespace, lockName string) *LeaderElectionSupport
  • func (l *LeaderElectionSupport) AwaitLeaseAcquired()
  • func (l *LeaderElectionSupport) AwaitLeaseReleased()
  • func (l *LeaderElectionSupport) AwaitLeaseRenewed()
  • func (l *LeaderElectionSupport) EnsureLeaseNotAcquired()
  • func (l *LeaderElectionSupport) FailLease(renewDeadline time.Duration)
  • func (l *LeaderElectionSupport) GetRecord() *resourcelock.LeaderElectionRecord
  • func (l *LeaderElectionSupport) SucceedLease()

Functions

func AssertFinalizers

func AssertFinalizers[T runtime.Object](client resource.Interface[T], name string, finalizers ...string)

func AwaitAndVerifyResource

func AwaitAndVerifyResource[T runtime.Object](client resource.Interface[T], name string, verify func(T) bool) T

func AwaitFinalizer

func AwaitFinalizer[T runtime.Object](client resource.Interface[T], name, finalizer string)

func AwaitNoFinalizer

func AwaitNoFinalizer[T runtime.Object](client resource.Interface[T], name, finalizer string)

func AwaitNoResource

func AwaitNoResource[T runtime.Object](client resource.Interface[T], name string)

func AwaitResource

func AwaitResource[T runtime.Object](client resource.Interface[T], name string) T

func AwaitStatusCondition

func AwaitStatusCondition(expCond *metav1.Condition, get func() ([]metav1.Condition, error))

func AwaitUpdateAction

func AwaitUpdateAction(f *testing.Fake, resourceType, name string) runtime.Object

func EnsureActionsForResource

func EnsureActionsForResource(f *testing.Fake, resourceType string, expectedVerbs ...string)

func EnsureNoActionsForResource

func EnsureNoActionsForResource(f *testing.Fake, resourceType string, expectedVerbs ...string)

func EnsureNoResource

func EnsureNoResource[T runtime.Object](client resource.Interface[T], name string)

func GetFinalizers

func GetFinalizers[T runtime.Object](client resource.Interface[T], name string) []string

func GetOccurredActionVerbs

func GetOccurredActionVerbs(f *testing.Fake, resourceType string, expectedVerbs ...string) []string

func SetDeleting

func SetDeleting[T runtime.Object](client resource.Interface[T], name string)

Types

type LeaderElectionSupport

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

func NewLeaderElectionSupport

func NewLeaderElectionSupport(kubeClient *k8sfake.Clientset, namespace, lockName string) *LeaderElectionSupport

func (*LeaderElectionSupport) AwaitLeaseAcquired

func (l *LeaderElectionSupport) AwaitLeaseAcquired()

func (*LeaderElectionSupport) AwaitLeaseReleased

func (l *LeaderElectionSupport) AwaitLeaseReleased()

func (*LeaderElectionSupport) AwaitLeaseRenewed

func (l *LeaderElectionSupport) AwaitLeaseRenewed()

func (*LeaderElectionSupport) EnsureLeaseNotAcquired

func (l *LeaderElectionSupport) EnsureLeaseNotAcquired()

func (*LeaderElectionSupport) FailLease

func (l *LeaderElectionSupport) FailLease(renewDeadline time.Duration)

func (*LeaderElectionSupport) GetRecord

func (l *LeaderElectionSupport) GetRecord() *resourcelock.LeaderElectionRecord

func (*LeaderElectionSupport) SucceedLease

func (l *LeaderElectionSupport) SucceedLease()