utils

Jan 16, 2026

Changes in this version

+ func Average[T int | int8 | int16 | int32 | int64 | float32 | float64](values []T) float64

Dec 19, 2025

Changes in this version

+ func ConnWithCustomDeadlineSupport(conn net.Conn) (net.Conn, error)

+ func ExtractColumnName(groups ...string) string

+ type NoDeadlineConn struct

+ func (c *NoDeadlineConn) SetDeadline(_ time.Time) error

+ func (c *NoDeadlineConn) SetReadDeadline(_ time.Time) error

+ func (c *NoDeadlineConn) SetWriteDeadline(_ time.Time) error

Nov 11, 2025

Changes in this version

+ func SplitAndTrim(s string) []string

Sep 16, 2025

Changes in this version

+ func ParsePrivateKey(pemText, passphrase string) (ssh.Signer, error)

+ type SSHConfig struct

+ Host string

+ Passphrase string

+ Password string

+ Port int

+ PrivateKey string

+ Username string

+ func (c *SSHConfig) SetupSSHConnection() (*ssh.Client, error)

+ func (c *SSHConfig) Validate() error

Sep 10, 2025

Changes in this version

+ func GenerateDestinationDetails(namespace, name string, sourceDatabase *string) (string, string)

+ func IsLetterOrNumber(symbol int32) bool

+ func Reformat(key string) string

Jul 24, 2025

Changes in this version

+ func ExecCommand(ctx context.Context, c testcontainers.Container, cmd string) (int, []byte, error)

+ func NormalizedEqual(strune1, strune2 string) bool

Jun 29, 2025

Changes in this version

+ func Decrypt(encryptedText string) (string, error)

Jun 26, 2025

Changes in this version

+ func ComputeConfigHash(srcPath, destPath string) string

Jun 13, 2025

Changes in this version

+ const SSLModeDisable

+ const SSLModeRequire

+ const SSLModeVerifyCA

+ const SSLModeVerifyFull

+ const Unknown

+ func Absolute[T int | int8 | int16 | int32 | int64 | float32 | float64](value T) T

+ func AddConstantToInterface(val interface{}, increment int) (interface{}, error)

+ func ArrayContains[T any](set []T, match func(elem T) bool) (int, bool)

+ func CheckIfFilesExists(files ...string) error

+ func CompareInterfaceValue(a, b interface{}) int

+ func ConcurrentC[T any](ctx context.Context, next *Next[T], concurrency int, ...) error

+ func ConcurrentF(ctx context.Context, functions ...CtxFunc) error

+ func ConcurrentInGroup[T any](group *CxGroup, array []T, execute func(ctx context.Context, one T) error)

+ func Concurrent[T any](ctx context.Context, array []T, concurrency int, ...) error

+ func ConvertToString(value interface{}) string

+ func DetermineSystemMemoryGB() int64

+ func ErrExec(functions ...func() error) error

+ func ErrExecFormat(format string, function func() error) func() error

+ func ErrExecSequential(functions ...func() error) error

+ func ExistInArray[T ~string | int | int8 | int16 | int32 | int64 | float32 | float64](set []T, value T) bool

+ func ForEach[T any](set []T, action func(elem T) error) error

+ func GetHash(m map[string]interface{}) string

+ func GetKeysHash(m map[string]interface{}, keys ...string) string

+ func IsInstance(val any, typ reflect.Kind) bool

+ func IsJSON(str string) bool

+ func IsOfType(object any, decidingKey string) (bool, error)

+ func IsSubset[T comparable](setArray, subsetArray []T) bool

+ func IsValidSubcommand(available []*cobra.Command, sub string) bool

+ func MaxDate(v1, v2 time.Time) time.Time

+ func SizeOf(v any) int

+ func StreamIdentifier(name, namespace string) string

+ func Ternary(cond bool, a, b any) any

+ func TimestampedFileName(extension string) string

+ func ULID() string

+ func Unmarshal(from, object any) error

+ func UnmarshalFile(file string, dest any) error

+ func Validate[T any](structure T) error

+ type CtxFunc = func(ctx context.Context) error

+ type CxGroup struct

+ func NewCGroup(ctx context.Context) *CxGroup

+ func NewCGroupWithLimit(ctx context.Context, limit int) *CxGroup

+ func (g *CxGroup) Add(execute func(ctx context.Context) error)

+ func (g *CxGroup) Block() error

+ func (g *CxGroup) Ctx() context.Context

+ type Next struct

+ func Yield[T any](next func(prev T) (bool, T, error)) *Next[T]

+ func (n *Next[T]) Close()

+ func (n *Next[T]) Next() bool

+ type SSLConfig struct

+ ClientCert string

+ ClientKey string

+ Mode string

+ ServerCA string

+ func (sc *SSLConfig) Validate() error