util

Documentation

Index

• Variables
• func After(clk quartz.Clock, d time.Duration) <-chan time.Time
• func GetUnexportedField[T any](obj *T, fieldName string) any
• func OpenAPISchema[T ~string](r huma.Registry, enumName string, values []T) *huma.Schema
• func WaitFor(ctx context.Context, timeout WaitTimeout, condition func() (bool, error)) error
• type WaitTimeout

Variables

var WaitTimedOut = xerrors.New("timeout waiting for condition")

Functions

func After

func After(clk quartz.Clock, d time.Duration) <-chan time.Time

After is a convenience function that returns a channel that will send the time after the given duration has elapsed using the provided clock. If clk is nil, a real clock will be used by default. Note that this function spawns a goroutine that will remain alive until the timer fires.

func GetUnexportedField

func GetUnexportedField[T any](obj *T, fieldName string) any

Based on https://stackoverflow.com/a/60598827

func OpenAPISchema

func OpenAPISchema[T ~string](r huma.Registry, enumName string, values []T) *huma.Schema

based on https://github.com/danielgtaylor/huma/issues/621#issuecomment-2456588788

func WaitFor

func WaitFor(ctx context.Context, timeout WaitTimeout, condition func() (bool, error)) error

WaitFor waits for a condition to be true or the timeout to expire. It will wait for the condition to be true with exponential backoff. A single sleep timer is reused across iterations via Reset so that mock-clock tests always have a pending timer to advance.

Types

type WaitTimeout

type WaitTimeout struct {
	Timeout     time.Duration
	MinInterval time.Duration
	MaxInterval time.Duration
	InitialWait bool
	Clock       quartz.Clock
}