kubernetes/staging/src/k8s.io/client-go/tools/leaderelection/leaderelection_test.go

func createLockObject(t *testing.T, objectType, namespace, name string, record *rl.LeaderElectionRecord) (obj runtime.Object) { … }

type Reactor …

func testTryAcquireOrRenew(t *testing.T, objectType string) { … }

func TestTryCoordinatedRenew(t *testing.T) { … }

// Will test leader election using lease as the resource
func TestTryAcquireOrRenewLeases(t *testing.T) { … }

func TestLeaseSpecToLeaderElectionRecordRoundTrip(t *testing.T) { … }

func GetRawRecordOrDie(t *testing.T, objectType string, ler rl.LeaderElectionRecord) (ret []byte) { … }

func testReleaseLease(t *testing.T, objectType string) { … }

// Will test leader election using endpoints as the resource
func TestReleaseLeaseLeases(t *testing.T) { … }

func TestReleaseOnCancellation_Leases(t *testing.T) { … }

func testReleaseOnCancellation(t *testing.T, objectType string) { … }

func TestLeaderElectionConfigValidation(t *testing.T) { … }

func assertEqualEvents(t *testing.T, expected []string, actual <-chan string) { … }

func TestFastPathLeaderElection(t *testing.T) { … }