Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v1

v1.2.0

Feb 12, 2024

v1.1.0

Jan 4, 2024

v1.0.0

Dec 12, 2023

Changes in this version

+ func CanWriteAccessDir(dirPath string) int

+ func GetOptionalFlagMsg(message string) string

+ func ParseConfigParams(configParamListStr string) (map[string]string, error)

+ func ParseKeyValueListStr(listStr, opt string) (map[string]string, error)

+ func SplitHosts(hosts string) ([]string, error)

v0

v0.0.1234

Sep 11, 2024

v0.0.123

Sep 9, 2024

Changes in this version

+ const AWSAuthKey

+ const ArchiveEndpoint

+ const CallCommand

+ const CloseAllConns

+ const CommStorageFail

+ const CommStorageLoc

+ const DBInfo

+ const Default

+ const DefaultClientPort

+ const DefaultConfigDir

+ const DefaultControlAddressFamily

+ const DefaultControlSetSize

+ const DefaultDBDir

+ const DefaultDateOnlyFormat

+ const DefaultDateTimeFormat

+ const DefaultDateTimeNanoSecFormat

+ const DefaultDrainSeconds

+ const DefaultHTTPPort

+ const DefaultHTTPPortOffset

+ const DefaultLargeCluster

+ const DefaultLicenseKey

+ const DefaultLoadCatalogTimeoutSeconds

+ const DefaultP2p

+ const DefaultRestartPolicy

+ const DefaultRetryCount

+ const DefaultShareDir

+ const DefaultSpreadLoggingLevel

+ const DefaultStatePollingTimeout

+ const DefaultTimeoutSeconds

+ const DepotFmtMsg

+ const DepotSizeHint

+ const DepotSizeKMGTMsg

+ const DropEndpoint

+ const EmptyConfigParamErrMsg

+ const FailToWriteToConfig

+ const FileExist

+ const FileNotExist

+ const IPv6ControlAddressFamily

+ const InfiniteWaitTime

+ const MainClusterSandbox

+ const MaxDepotSize

+ const MaxLargeCluster

+ const MinDepotSize

+ const NoWritePerm

+ const NodeDownState

+ const NodeInfoCountMismatch

+ const NodeUnknownState

+ const NodeUpState

+ const NodesEndpoint

+ const RootDir

+ const ShutDownEndpoint

+ const SubclustersEndpoint

+ const SuppressHelp

+ const TimeExpire

+ const TimeToWaitToClose

+ var RestartPolicyList = []string

+ func AbsPathCheck(dirPath string) error

+ func AddressCheck(address string, ipv6 bool) error

+ func ArrayToString(arr []string, delimiter string) string

+ func BoolToStr(b bool) string

+ func CanReadAccessDir(dirPath string) error

+ func CanWriteAccessPath(path string) int

+ func CheckAllEmptyOrNonEmpty(vars ...string) bool

+ func CheckMissingFields(object any) error

+ func CheckNotEmpty(a string) bool

+ func CheckPathExist(filePath string) bool

+ func CopyFile(sourcePath, destinationPath string, perm fs.FileMode) error

+ func CopyMap[K comparable, V any](original map[K]V) map[K]V

+ func CopySlice[T any](original []T) []T

+ func FillInDefaultTimeForEndTimestamp(dateonly *string) *time.Time

+ func FillInDefaultTimeForStartTimestamp(dateonly *string) *time.Time

+ func FilterMapByKey[M ~map[K]V, K comparable, V any](m M, n []K) M

+ func GenVNodeName(vnodes map[string]string, dbName string, hostCount int) (string, bool)

+ func GenerateTLSVerifyFunc(rootCAs *x509.CertPool) func([][]byte, [][]*x509.Certificate) error

+ func GetCleanPath(path string) string

+ func GetClusterName(sandbox string) string

+ func GetCurrentUsername() (string, error)

+ func GetEnv(key, fallback string) string

+ func GetEnvInt(key string, fallback int) int

+ func GetEonFlagMsg(message string) string

+ func GetJSONLogErrors(responseContent string, responseObj any, opName string, logger vlog.Printer) error

+ func GetPathPrefix(path string) string

+ func HoursAgo(t time.Time) (int, error)

+ func IsAbsPath(path string) bool

+ func IsEmptyOrValidTimeStr(layout, value string) (*time.Time, error)

+ func IsIPv4(ip string) bool

+ func IsIPv6(ip string) bool

+ func IsK8sEnvironment() bool

+ func IsOptionSet(f *flag.FlagSet, optionName string) bool

+ func IsTimeEqualOrAfter(start, end time.Time) bool

+ func MapKeyDiff[M ~map[K]V, K comparable, V any](m, n M) []K

+ func Max[T constraints.Ordered](a, b T) T

+ func NmaCertsLookup(f FetchAllEnvVars)

+ func NmaSecretLookup(f FetchAllEnvVars)

+ func ParamNotSetErrorMsg(param string) error

+ func ParseHostList(hosts *[]string) error

+ func ParseTime(timeString string, formats []TimeFormat) (t time.Time, allErrs error)

+ func ResolveRawHostsToAddresses(rawHosts []string, ipv6 bool) ([]string, error)

+ func ResolveToAbsPath(path string) (string, error)

+ func ResolveToIPAddrs(hostname string, ipv6 bool) ([]string, error)

+ func ResolveToOneIP(hostname string, ipv6 bool) (string, error)

+ func SetParserUsage(parser *flag.FlagSet, op string)

+ func SliceCommon[K constraints.Ordered](m, n []K) []K

+ func SliceDiff[K comparable](m, n []K) []K

+ func StringInArray(str string, list []string) bool

+ func TrimSpace(str string) string

+ func ValidateAbsPath(path, pathName string) error

+ func ValidateArchiveName(archive string) error

+ func ValidateCommunalStorageLocation(location string) error

+ func ValidateDBName(dbName string) error

+ func ValidateName(name, obj string, allowDash bool) error

+ func ValidateQualifiedObjectNamePattern(pattern string, allowAsterisk bool) error

+ func ValidateRequiredAbsPath(path, pathName string) error

+ func ValidateSandboxName(dbName string) error

+ func ValidateScName(dbName string) error

+ func ValidateUsernameAndPassword(opName string, useHTTPPassword bool, userName string) error

+ type FetchAllEnvVars interface

+ SetK8Certs func(rootCAPath, certPath, keyPath string)

+ SetK8Secrets func(port, secretNameSpace, secretName string)

+ TypeName func() string

+ type TimeFormat struct

+ Layout string

+ UseLocalTZ bool