util

func CloneMapNonNil ¶

func CloneMapNonNil[M ~map[K]V, K comparable, V any](m M) M

CloneMapNonNil is like maps.Clone except it can't return nil, it will return an empty map instead.

func ConvertPathToCamel ¶

func ConvertPathToCamel(input string) []string

func DeleteFromMap ¶

func DeleteFromMap[M ~map[K]M2, M2 ~map[K2]V, K, K2 comparable, V any](m M, k K, k2 K2)

DeleteFromMap deletes k2 from the nested map m[k]. If the inner map becomes empty after deletion, k is also removed from m to prevent memory leaks.

func ErrorType ¶

func ErrorType(err error) string

ErrorType returns a best effort guess at the most meaningful type name for the given error. If any of err's underlying errors implement TypedError, then the type name of the first such error is returned. This allows us to be explicit about the tag values we want to use for telemetry. Otherwise, the type name of the first non-wrapper error in the depth-first traversal of err's tree is returned. We consider errors wrapped via fmt.Errorf, errors.Join and some pkg/errors functions to be wrapper errors.

func FilterSlice ¶

func FilterSlice[T any](in []T, predicate func(T) bool) []T

FilterSlice iterates over elements of a slice, returning a new slice of all elements predicate returns true for.

func FoldSlice ¶

func FoldSlice[T any, A any](in []T, initializer A, reducer func(A, T) A) A

FoldSlice folds left a slice using given reducer function and initial value.

func GetOrSetMap ¶

func GetOrSetMap[M ~map[K]M2, M2 ~map[K2]V, K, K2 comparable, V any](m M, k K) M2

GetOrSetMap looks up k in m, a two-level map, and returns the result. If it's not present, it uses `make` to allocate new second-level map and sets that in the first map, then returns it.

func GetOrSetNew ¶

func GetOrSetNew[M ~map[K]*V, K comparable, V any](m M, k K) *V

GetOrSetNew looks up k in m and returns the result. If it's not present, it uses `new` to allocate an new value type and sets that in the map, then returns it.

func InterruptibleSleep ¶

func InterruptibleSleep(ctx context.Context, timeout time.Duration) error

InterruptibleSleep is like time.Sleep but can be interrupted by a context. Returns context error if interrupted, otherwise nil.

func InverseMap ¶

func InverseMap[M ~map[K]V, K, V comparable](m M) map[V]K

InverseMap creates the inverse map, ie., for a key-value map, it builds the value-key map.

func MapConcurrent ¶

func MapConcurrent[IN any, OUT any](input []IN, mapper func(IN) (OUT, error)) ([]OUT, error)

MapConcurrent concurrently maps a function over input and fails fast on error.

func MapSlice ¶

func MapSlice[T, S any](xs []T, f func(T) S) []S

MapSlice given slice xs []T and f(T) S produces slice []S by applying f to every element of xs

func MaxTime ¶

func MaxTime(a, b time.Time) time.Time

MaxTime returns the later of two given time.Time

func MinTime ¶

func MinTime(a, b time.Time) time.Time

MinTime returns the earlier of two given time.Time

func NextAlignedTime ¶

func NextAlignedTime(t time.Time, align time.Duration) time.Time

NextAlignedTime returns the earliest time after `t` that is aligned to an integer multiple of `align` since the unix epoch.

func ParseFieldMask ¶

func ParseFieldMask(mask *fieldmaskpb.FieldMask) map[string]struct{}

func Ptr ¶

func Ptr[T any](v T) *T

Ptr returns a pointer to a copy of v.

func RepeatSlice ¶

func RepeatSlice[T any](xs []T, n int) []T

RepeatSlice given slice and a number (n) produces a new slice containing original slice n times if n is non-positive will produce nil

func SliceHead ¶

func SliceHead[S ~[]E, E any](s S, n int) S

SliceHead returns the first n elements of s. n may be greater than len(s).

func SliceTail ¶

func SliceTail[S ~[]E, E any](s S, n int) S

SliceTail returns the last n elements of s. n may be greater than len(s).

func SortSlice ¶

func SortSlice[S ~[]E, E expconstraints.Ordered](slice S)

SortSlice sorts the given slice of an ordered type. Sort is not guaranteed to be stable.

func TruncateUTF8 ¶

func TruncateUTF8(s string, n int) string

TruncateUTF8 truncates s to no more than n _bytes_, and returns a valid utf-8 string as long as the input is a valid utf-8 string. Note that truncation pays attention to codepoints only! This may truncate in the middle of a grapheme cluster.

func WildCardStringToRegexp ¶

func WildCardStringToRegexp(pattern string) (*regexp.Regexp, error)

WildCardStringToRegexp converts a given string pattern to a regular expression matching wildcards (*) with any substring.

func WildCardStringsToRegexp ¶

func WildCardStringsToRegexp(patterns []string) (*regexp.Regexp, error)

WildCardStringToRegexps converts a given slices of string patterns to a slice of regular expressions matching wildcards (*) with any substring.