ha

Documentation

Index

• func GetLeaders(ctx context.Context, t *testing.T, client kubernetes.Interface, ...) ([]string, error)
• func WaitForNewLeader(ctx context.Context, client kubernetes.Interface, ...) (string, error)
• func WaitForNewLeaders(ctx context.Context, t *testing.T, client kubernetes.Interface, ...) (sets.Set[string], error)

Functions

func GetLeaders

func GetLeaders(ctx context.Context, t *testing.T, client kubernetes.Interface, 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 kubernetes.Interface, lease, namespace, previousLeader string) (string, error)

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

Deprecated: Use WaitForNewLeaders.

func WaitForNewLeaders

func WaitForNewLeaders(ctx context.Context, t *testing.T, client kubernetes.Interface, deploymentName, namespace string, previousLeaders sets.Set[string], n int) (sets.Set[string], error)

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