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 (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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssertFinalizers ¶
func AwaitAndVerifyResource ¶ added in v0.17.0
func AwaitFinalizer ¶
func AwaitNoFinalizer ¶
func AwaitNoResource ¶
func AwaitResource ¶
func AwaitStatusCondition ¶
func AwaitUpdateAction ¶
func EnsureActionsForResource ¶ added in v0.15.0
func EnsureNoResource ¶
func GetFinalizers ¶
func GetOccurredActionVerbs ¶ added in v0.15.0
Types ¶
type LeaderElectionSupport ¶ added in v0.16.1
type LeaderElectionSupport struct {
// contains filtered or unexported fields
}
func NewLeaderElectionSupport ¶ added in v0.16.1
func NewLeaderElectionSupport(kubeClient *k8sfake.Clientset, namespace, lockName string) *LeaderElectionSupport
func (*LeaderElectionSupport) AwaitLeaseAcquired ¶ added in v0.16.1
func (l *LeaderElectionSupport) AwaitLeaseAcquired()
func (*LeaderElectionSupport) AwaitLeaseReleased ¶ added in v0.16.1
func (l *LeaderElectionSupport) AwaitLeaseReleased()
func (*LeaderElectionSupport) AwaitLeaseRenewed ¶ added in v0.16.1
func (l *LeaderElectionSupport) AwaitLeaseRenewed()
func (*LeaderElectionSupport) EnsureLeaseNotAcquired ¶ added in v0.16.1
func (l *LeaderElectionSupport) EnsureLeaseNotAcquired()
func (*LeaderElectionSupport) FailLease ¶ added in v0.16.1
func (l *LeaderElectionSupport) FailLease(renewDeadline time.Duration)
func (*LeaderElectionSupport) GetRecord ¶ added in v0.16.1
func (l *LeaderElectionSupport) GetRecord() *resourcelock.LeaderElectionRecord
func (*LeaderElectionSupport) SucceedLease ¶ added in v0.16.1
func (l *LeaderElectionSupport) SucceedLease()
Click to show internal directories.
Click to hide internal directories.