utils

package

Go to main page

Versions in this module

v0

v0.4.1

May 20, 2026

Changes in this version

+ func DirSize(dir string) (int64, error)

+ func FindVMMByCmdline(_, _ string) ([]int, error) — darwin/amd64, js/wasm, windows/amd64

+ func FindVMMByCmdline(binaryName, expectArg string) ([]int, error) — linux/amd64

+ type ProcScan []procEntry — linux/amd64

+ func ScanProcsByBinary(binaryName string) (ProcScan, error)

+ func (s ProcScan) Find(expectArg string) []int

+ type ProcScan struct — darwin/amd64, js/wasm, windows/amd64

+ func ScanProcsByBinary(_ string) (ProcScan, error)

+ func (ProcScan) Find(_ string) []int

v0.4.0

May 13, 2026

Changes in this version

+ func FileHead(f *os.File, n int) ([]byte, error)

+ func ReadJSONFile(path string, v any) error

v0.3.9

May 5, 2026

Changes in this version

+ func DoAPIOnce(ctx context.Context, hc *http.Client, method, url string, body []byte, ...) ([]byte, error)

+ func DoAPIWithRetry(ctx context.Context, hc *http.Client, method, url string, body []byte, ...) ([]byte, error)

+ func MapValues[K comparable, V, R any](m map[K]*V, fn func(*V) R) []R

+ func PeekReader(r io.Reader, n int) ([]byte, io.Reader, error)

+ func RunQemuImg(ctx context.Context, args ...string) error

v0.3.8

Apr 27, 2026

v0.3.7

Apr 24, 2026

v0.3.6

Apr 23, 2026

v0.3.5

Apr 20, 2026

v0.3.4

Apr 19, 2026

v0.3.3

Apr 17, 2026

v0.3.2

Apr 15, 2026

v0.3.1

Apr 13, 2026

Changes in this version

+ func NewSocketHTTPClientWithTimeout(socketPath string, timeout time.Duration) *http.Client

v0.3.0

Apr 9, 2026

v0.2.9

Apr 8, 2026

v0.2.8

Apr 4, 2026

v0.2.7

Apr 3, 2026

v0.2.6

Apr 2, 2026

Changes in this version

+ func WatchFile(ctx context.Context, filePath string, debounce time.Duration) (<-chan struct{}, error)

v0.2.5

Apr 2, 2026

Changes in this version

+ func Map[T, R any](ctx context.Context, items []T, ...) ([]R, error)

v0.2.4

Apr 1, 2026

Changes in this version

+ const BaseBackoff

+ const HTTPTimeout

+ const MaxRetries

+ const StaleTempAge

+ func AtomicWriteFile(path string, data []byte, perm os.FileMode) error

+ func AtomicWriteJSON(path string, v any) error

+ func CheckSocket(socketPath string) error

+ func CleanStaleRecords[T any](items map[string]*T, nameMap map[string]string, targetIDs []string, ...)

+ func DetectHugePages() bool

+ func DoAPI(ctx context.Context, hc *http.Client, method, url string, body []byte, ...) ([]byte, error)

+ func DoWithRetry[T any](ctx context.Context, fn func() (T, error)) (T, error)

+ func EnsureDirs(dirs ...string) error

+ func ExtractTar(dir string, r io.Reader) error

+ func FilterUnreferenced(candidates []string, refs map[string]struct{}, exclude ...map[string]struct{}) []string

+ func GenerateID() (string, error)

+ func InitNamedIndex[T any](items *map[string]*T, names *map[string]string)

+ func IsProcessAlive(pid int) bool

+ func IsRetryable(err error) bool

+ func LookupCopy[T any](m map[string]*T, key string) (T, error)

+ func MergeSets[K comparable](sets ...map[K]struct{}) map[K]struct

+ func NewSocketHTTPClient(socketPath string) *http.Client

+ func ReadPIDFile(path string) (int, error)

+ func ReflinkCopy(dst, src string) error

+ func RemoveMatching(ctx context.Context, dir string, match func(os.DirEntry) bool) []error

+ func ResolveRef[T any](items map[string]*T, names map[string]string, ref string, notFound error) (string, error)

+ func ResolveRefs[T any](items map[string]*T, names map[string]string, refs []string, notFound error) ([]string, error)

+ func ScanFileStems(dir, suffix string) ([]string, error)

+ func ScanSubdirs(dir string) ([]string, error)

+ func SparseCopy(dst, src string) error

+ func SyncParentDir(dir string) error

+ func TarDir(tw *tar.Writer, dir string) error

+ func TarDirStream(dir string, cleanup func()) io.ReadCloser

+ func TarDirStreamWithRemove(dir string) io.ReadCloser

+ func TerminateProcess(ctx context.Context, pid int, binaryName, expectArg string, ...) error

+ func UUIDv5(name string) string

+ func ValidFile(path string) bool

+ func VerifyProcess(pid int, binaryName string) bool

+ func VerifyProcessCmdline(pid int, binaryName, expectArg string) bool

+ func WaitFor(ctx context.Context, timeout, interval time.Duration, ...) error

+ func WritePIDFile(path string, pid int) error

+ type APIError struct

+ Code int

+ Message string

+ func (e *APIError) Error() string

+ type BatchResult struct

+ Errors []error

+ Succeeded []string

+ func ForEach(ctx context.Context, ids []string, fn func(context.Context, string) error) BatchResult

+ func (r BatchResult) Err() error

+ type PipeStreamReader struct

+ func NewPipeStreamReader(pr *io.PipeReader, done <-chan error, cleanup func()) *PipeStreamReader

+ func (r *PipeStreamReader) Close() error

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