testhelper

Documentation

Index

• func CollectResources[T any](ch chan T) []T
• func CollectResourcesBlocking[T any](ch chan T) []T
• func CollectResourcesWithTimeout[T any](ch chan T, maxCount int, timeout time.Duration) []T
• func CreateMockClients[T any](client T, regions []string) map[string]T
• func NewLogger(t *testing.T) *clog.Logger
• func NewObserverLogger(t *testing.T) *clog.Logger
• func SkipLong(t *testing.T)

Functions

func CollectResources

func CollectResources[T any](ch chan T) []T

CollectResources fetches items from a channel and returns them in a slice.

Warning: this function does not wait for the channel to close, using it can cause race conditions. See CollectResourcesBlocking for a blocking version of the function.

func CollectResourcesBlocking

func CollectResourcesBlocking[T any](ch chan T) []T

CollectResourcesBlocking fetches items from a channel and returns them in a slice. This function waits for the channel to close before returning. See CollectResources for a non-blocking version of the function.

func CollectResourcesWithTimeout

func CollectResourcesWithTimeout[T any](ch chan T, maxCount int, timeout time.Duration) []T

CollectResourcesWithTimeout fetches items from a channel and returns them in a slice after no elements have been received for the specified timeout duration.

func CreateMockClients

func CreateMockClients[T any](client T, regions []string) map[string]T

func NewLogger

func NewLogger(t *testing.T) *clog.Logger

func NewObserverLogger

func NewObserverLogger(t *testing.T) *clog.Logger

func SkipLong

func SkipLong(t *testing.T)