utils

package
v0.19.0-spc.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2023 License: AGPL-3.0 Imports: 37 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Timing []timeLog

Functions

func Base36Hash added in v0.19.0

func Base36Hash(input string, length int) (string, error)

func BuildRequestPayload

func BuildRequestPayload(signature string, payload map[string]interface{}) *bytes.Buffer

BuildRequestPayload merges the provided payload with the standard payload that needs to be sent

func ContainsUpper added in v0.19.0

func ContainsUpper(s string) bool

ContainsUpper returns true if the string contains any uppercase characters

func DisplayProfileData

func DisplayProfileData()

func EnsureDirectoryPermission

func EnsureDirectoryPermission(directoryPath string) error

func FileModTime

func FileModTime(filePath string) (time.Time, error)

func FilenameNoExtension added in v0.17.0

func FilenameNoExtension(fileName string) string

func Filter

func Filter[V any](elements []V, predicate func(V) bool) []V

Filter returns a new slice only containing the elements for which invoking the predicate returned true

The predicate is invoked with each element

func FindProcess

func FindProcess(targetPid int) (*psutils.Process, error)

FindProcess tries to find the process with the given pid returns nil if the process could not be found

func GetPluginName added in v0.17.0

func GetPluginName(plugin string) string

GetPluginName function is used to get the plugin name required while installing/updating/removing a plugin. External plugins require the repo names to be prefixed(eg: francois2metz/scalingo). Sample input 1: hub.steampipe.io/plugins/francois2metz/scalingo@latest Sample output 1: francois2metz/scalingo Sample input 2: hub.steampipe.io/plugins/turbot/aws@latest Sample output 2: aws

func IsMacM1

func IsMacM1() (bool, error)

IsMacM1 returns whether the system is a Mac M1 machine

func IsPortBindable

func IsPortBindable(port int) error

func IsWSL

func IsWSL() bool

IsWSL detects whether app is running in WSL environment refer to: https://github.com/Microsoft/WSL/issues/423#issuecomment-679190758

func JsonCloneToMap added in v0.19.0

func JsonCloneToMap(val any) (map[string]any, error)

JsonCloneToMap tries to JSON marshal and unmarshal the given data, returning a map[string]any if successful

func LocalAddresses

func LocalAddresses() ([]string, error)

func LogTime

func LogTime(operation string)

func Map

func Map[V any, M any](elements []V, mapper func(V) M) []M

Map returns a new slice where every value is mapped to a new value through the mapper

The mapper is invoked with each element

func MergeMaps added in v0.17.0

func MergeMaps[M ~map[K]V, K comparable, V any](old, new M) M

MergeMaps merges 'new' onto 'old'. Values existing in old already have precedence Any value existing in new but not old is added to old

func MoveFile

func MoveFile(source string, destination string) error

MoveFile moves a file from source to destiantion.

It first attempts the movement using OS primitives (os.Rename)
If os.Rename fails, it copies the file byte-by-byte to the destination and then removes the source

func ParseCertificateInLocation added in v0.17.0

func ParseCertificateInLocation(location string) (*x509.Certificate, error)

func Partition

func Partition[V any](elements []V, predicate func(V) bool) ([]V, []V)

Partition splits the array of elements into two groups: the left partition contains elements that the predicate returns `true` for. the right partition contains elements that the predicate returns `false` for.

The predicate is invoked with each element

func PidExists

func PidExists(targetPid int) (bool, error)

PidExists scans through the list of PIDs in the system and checks for the `targetPID`.

PidExists uses iteration, instead of signalling, since we have observed that signalling does not always work reliably when the destination of the signal is a child of the source of the signal - which may be the case then starting implicit services

func PluginFQNToSchemaName added in v0.19.0

func PluginFQNToSchemaName(pluginFQN string) string

PluginFQNToSchemaName convert a full plugin name to a schema name schemas in postgres are limited to 63 chars - the name may be longer than this, in which case trim the length and add a hash to the end to make unique

func Pluralize

func Pluralize(base string, count int) string

Pluralize :: pluralizes a word (if applicable) based on provided count

func PrettifyJsonFromReader added in v0.17.0

func PrettifyJsonFromReader(dataToExport io.Reader) (io.Reader, error)

func RemoveDirectoryContents

func RemoveDirectoryContents(removePath string) error

func SafeIntEqual

func SafeIntEqual(i1, i2 *int) bool

func SafeStringsEqual

func SafeStringsEqual(s1, s2 interface{}) bool

func SendRequest

func SendRequest(ctx context.Context, signature string, method string, sendRequestTo url.URL, payload io.Reader) (*http.Response, error)

SendRequest makes a http call to the given URL

func SortedMapKeys added in v0.17.0

func SortedMapKeys[V any](m map[string]V) []string

func StringSlicesEqual added in v0.19.0

func StringSlicesEqual(l, r []string) bool

StringSlicesEqual returns whether the 2 string slices are identical

func ToIntegerPointer

func ToIntegerPointer(i int) *int

ToIntegerPointer converts an integer into its pointer

func ToStringPointer

func ToStringPointer(s string) *string

ToStringPointer converts a string into its pointer

func TrimSchemaName added in v0.19.0

func TrimSchemaName(pluginFQN string) string

func UnderlyingArch

func UnderlyingArch() (string, error)

UnderlyingArch detects the underlying architecture(amd64/arm64) of the system we need this to detect the underlying architecture to install the correct FDW package

func UnquoteStringArray added in v0.17.0

func UnquoteStringArray(stringArray []string) []string

UnquoteStringArray removes quote marks from elements of string array

func WriteCertificate added in v0.17.0

func WriteCertificate(path string, certificate []byte) error

func WritePrivateKey added in v0.17.0

func WritePrivateKey(path string, key *rsa.PrivateKey) error

Types

type ExitCode

type ExitCode int

ExitCode :: alias for exitcode

type InteractiveExitStatus

type InteractiveExitStatus struct {
	// TODO remove altogether
	ExitCode int
}

InteractiveExitStatus :: exist status from the interative prompt

We exit go-prompt after every query (in order to manage the prompt history to only include complete queries) We therefore need to distinguish between:

a user requested exit (ctrl+D or .exit) - indicated by a non-nil exit code and restart=false and a value , go-prompt being terminated after a query completion and requiring restarting - indicated by restart=true

type Semaphore added in v0.17.0

type Semaphore struct {
	// contains filtered or unexported fields
}

Semaphore is a struct wrapping a sema`phore thast makes it easier to debug deadlocvks and failures to release

func NewSemaphore added in v0.17.0

func NewSemaphore(count int64) *Semaphore

func (Semaphore) Acquire added in v0.17.0

func (l Semaphore) Acquire(ctx context.Context, count int64, owner string) error

func (Semaphore) Release added in v0.17.0

func (l Semaphore) Release(i int64, owner string)

func (Semaphore) String added in v0.17.0

func (l Semaphore) String() any

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL