util

func BinSearchInRange ¶

func BinSearchInRange(from, to int, fn func(i int) bool) int

func ByteToStringUnsafe ¶

func ByteToStringUnsafe(b []byte) string

func CollapseErrors ¶

func CollapseErrors(errs []error) error

CollapseErrors combines errors and writes repeats of each.

func DeduplicateErrors ¶

func DeduplicateErrors(errs []error) error

DeduplicateErrors deduplicates errors.

func DurationToUnit ¶

func DurationToUnit(durationVal time.Duration, unit string) float64

DurationToUnit converts duration to unit and returns as float64.

func EnsureSliceSize ¶

func EnsureSliceSize[T any](src []T, size int) []T

func Float64ToPrec ¶

func Float64ToPrec(val float64, prec uint32) float64

Float64ToPrec formats float64 by removing numberics after prec digit.

func IdxFill ¶

func IdxFill(n int) []int

func IdxShuffle ¶

func IdxShuffle(n int) []int

func IsCancelled ¶

func IsCancelled(ctx context.Context) bool

IsCancelled is a faster way to check if the context has been canceled, compared to ctx.Err() != nil

func MsTsToESFormat ¶

func MsTsToESFormat(ts uint64) string

MsTsToESFormat converts timestamp in milliseconds to ES time format string.

func MustRemoveFileByPath ¶ added in v0.60.0

func MustRemoveFileByPath(path string)

func MustSyncPath ¶

func MustSyncPath(path string)

func NsTsToESFormat ¶ added in v0.64.0

func NsTsToESFormat(ts uint64) string

NsTsToESFormat converts timestamp in nanoseconds to ES time format string. Nanosecond part will not be printed.

func ParseDuration ¶

func ParseDuration(esDuration string) (time.Duration, error)

func Recover ¶

func Recover(metric prometheus.Counter, err error)

func RecoverToError ¶

func RecoverToError(panicData any, metric prometheus.Counter) error

func RemoveFile ¶ added in v0.62.3

func RemoveFile(file string)

RemoveFile safely removes a file with logging Handles cases where the file already doesn't exist

func RunEvery ¶

func RunEvery(done <-chan struct{}, runInterval time.Duration, actionFn func())

func SizeStr ¶

func SizeStr(bytes uint64) string

func SizeToUnit ¶

func SizeToUnit(sizeVal uint64, unit string) float64

SizeToUnit converts size in bytes to unit and returns as float64.

func StringToByteUnsafe ¶

func StringToByteUnsafe(str string) []byte

func SyncPath ¶ added in v0.62.0

func SyncPath(path string) error

func ZapDurationWithPrec ¶

func ZapDurationWithPrec(
	key string, dur time.Duration, unit string, prec uint32,
) zap.Field

ZapDurationWithPrec converts duration to unit and forms float64 zap.Field with removed numerics after prec digit.

func ZapFloat64WithPrec ¶

func ZapFloat64WithPrec(key string, val float64, prec uint32) zap.Field

ZapFloat64WithPrec forms float64 zap.Field with removed numerics after prec digit.

func ZapMsTsAsESTimeStr ¶

func ZapMsTsAsESTimeStr(key string, ts uint64) zap.Field

ZapMsTsAsESTimeStr converts timestamp in milliseconds to ES time format string and forms string zap.Field.

func ZapUint64AsSizeStr ¶

func ZapUint64AsSizeStr(key string, val uint64) zap.Field

ZapUint64AsSizeStr forms string zap.Field with val converted to size string.