utils

Documentation

Index

• Variables
• func CalculateDigest(data any) (string, error)
• func ClearIOStats(pid int)
• func ComputeDelay() time.Duration
• func DecodePath(orig string) string
• func DriveLetterPort(letter rune) (string, error)
• func EncodePath(path string) string
• func GenerateKeyPair(bitSize int) ([]byte, []byte, error)
• func GeneratePublicKeyFromPrivateKey(encodedPrivateKey []byte) ([]byte, error)
• func GetLocalIPs() ([]string, error)
• func GetProcIO(pid int) (read, write int64, readSpeed, writeSpeed float64, err error)
• func GetTaskLogPath(upid string) string
• func HashHostname(host string) uint32
• func HumanReadableBytes(bytes int64) string
• func HumanReadableSpeed(speed float64) string
• func IsMounted(path string) bool
• func IsRequestFromSelf(r *http.Request) bool
• func IsValid(path string) bool
• func IsValidID(id string) bool
• func IsValidNamespace(namespace string) bool
• func IsValidPathString(path string) bool
• func RandomHostname() string
• func Slugify(input string) string
• func ValidateOnCalendar(value string) error
• func ValidateTargetPath(path string) bool
• func WaitForLogFile(taskUpid string, maxWait time.Duration) error
• type DriveInfo

Variables

var BaseTransport = &http.Transport{
	MaxIdleConns:        200,
	MaxIdleConnsPerHost: 20,
	IdleConnTimeout:     15 * time.Second,
	DisableKeepAlives:   false,
	DialContext: (&net.Dialer{
		Timeout:   30 * time.Second,
		KeepAlive: 30 * time.Second,
	}).DialContext,
	TLSHandshakeTimeout:   10 * time.Second,
	TLSClientConfig:       &tls.Config{InsecureSkipVerify: true},
	ExpectContinueTimeout: 1 * time.Second,
}

var MountTransport = &http.Transport{
	MaxIdleConns:       0,
	DisableKeepAlives:  true,
	DisableCompression: false,
	IdleConnTimeout:    0,
	DialContext: (&net.Dialer{
		Timeout:   5 * time.Minute,
		KeepAlive: 0,
	}).DialContext,
	TLSHandshakeTimeout: 5 * time.Minute,
	TLSClientConfig: &tls.Config{
		InsecureSkipVerify: true,
	},
	ExpectContinueTimeout: 1 * time.Minute,
	WriteBufferSize:       0,
	ReadBufferSize:        0,
	ForceAttemptHTTP2:     false,
}

Functions

func CalculateDigest

func CalculateDigest(data any) (string, error)

func ClearIOStats

func ClearIOStats(pid int)

func ComputeDelay

func ComputeDelay() time.Duration

func DecodePath

func DecodePath(orig string) string

func DriveLetterPort

func DriveLetterPort(letter rune) (string, error)

func EncodePath

func EncodePath(path string) string

func GenerateKeyPair

func GenerateKeyPair(bitSize int) ([]byte, []byte, error)

func GeneratePublicKeyFromPrivateKey

func GeneratePublicKeyFromPrivateKey(encodedPrivateKey []byte) ([]byte, error)

func GetLocalIPs

func GetLocalIPs() ([]string, error)

func GetProcIO

func GetProcIO(pid int) (read, write int64, readSpeed, writeSpeed float64, err error)

func GetTaskLogPath

func GetTaskLogPath(upid string) string

func HashHostname

func HashHostname(host string) uint32

func HumanReadableBytes

func HumanReadableBytes(bytes int64) string

humanReadableBytes formats the given number of bytes into a human-readable string.

func HumanReadableSpeed

func HumanReadableSpeed(speed float64) string

func IsMounted

func IsMounted(path string) bool

func IsRequestFromSelf

func IsRequestFromSelf(r *http.Request) bool

func IsValid

func IsValid(path string) bool

func IsValidID

func IsValidID(id string) bool

func IsValidNamespace

func IsValidNamespace(namespace string) bool

func IsValidPathString

func IsValidPathString(path string) bool

func RandomHostname

func RandomHostname() string

randomHostname generates a pseudo-random string to use as a fallback hostname.

func Slugify

func Slugify(input string) string

func ValidateOnCalendar

func ValidateOnCalendar(value string) error

ValidateOnCalendar checks if a string is a valid systemd timer OnCalendar value

func ValidateTargetPath

func ValidateTargetPath(path string) bool

func WaitForLogFile

func WaitForLogFile(taskUpid string, maxWait time.Duration) error

Types

type DriveInfo

type DriveInfo struct {
	Letter     string `json:"letter"`
	Type       string `json:"type"`
	VolumeName string `json:"volume_name"`
	FileSystem string `json:"filesystem"`
	TotalBytes uint64 `json:"total_bytes"`
	UsedBytes  uint64 `json:"used_bytes"`
	FreeBytes  uint64 `json:"free_bytes"`
	Total      string `json:"total"`
	Used       string `json:"used"`
	Free       string `json:"free"`
}