ha

Documentation

Index

• func GetLeaders(ctx context.Context, t *testing.T, client *test.KubeClient, ...) ([]string, error)
• func WaitForNewLeader(ctx context.Context, client *test.KubeClient, ...) (string, error)
• func WaitForNewLeaders(ctx context.Context, t *testing.T, client *test.KubeClient, ...) (sets.String, error)

Functions

func GetLeaders

func GetLeaders(ctx context.Context, t *testing.T, client *test.KubeClient, deploymentName, namespace string) ([]string, error)

GetLeaders collects all of the leader pods from the specified deployment. GetLeaders will return duplicate pods by design.

func WaitForNewLeader

func WaitForNewLeader(ctx context.Context, client *test.KubeClient, lease, namespace, previousLeader string) (string, error)

DEPRECATED WaitForNewLeader waits until the holder of the given lease is different from the previousLeader.

func WaitForNewLeaders

func WaitForNewLeaders(ctx context.Context, t *testing.T, client *test.KubeClient, deploymentName, namespace string, previousLeaders sets.String, n int) (sets.String, error)

WaitForNewLeaders waits until the collection of current leaders consists of "n" leaders which do not include the specified prior leaders.