util

package
v1.5.5 Latest Latest
Warning

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

Go to latest
Published: Jul 30, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAvailableSpace added in v1.4.0

func GetAvailableSpace(path string) int64

GetAvailableSpace gets the amount of available space at the path specified.

func GetNamespace

func GetNamespace() string

GetNamespace returns the namespace the pod is executing in

func MinQuantity added in v1.4.0

func MinQuantity(availableSpace, imageSize *resource.Quantity) resource.Quantity

MinQuantity calculates the minimum of two quantities.

func ParseEnvVar added in v1.4.0

func ParseEnvVar(envVarName string, decode bool) (string, error)

ParseEnvVar provides a wrapper to attempt to fetch the specified env var

func RandAlphaNum

func RandAlphaNum(n int) string

RandAlphaNum provides an implementation to generate a random alpha numeric string of the specified length

func StartPrometheusEndpoint added in v1.4.0

func StartPrometheusEndpoint(certsDirectory string)

StartPrometheusEndpoint starts an http server providing a prometheus endpoint using the passed in directory to store the self signed certificates that will be generated before starting the http server.

func UnArchiveLocalTar added in v1.5.0

func UnArchiveLocalTar(filePath, destDir string, arg ...string) error

UnArchiveLocalTar unarchives a local tar file to the specified destination.

func UnArchiveTar added in v1.5.0

func UnArchiveTar(reader io.Reader, destDir string, arg ...string) error

UnArchiveTar unarchives a tar file and streams its files using the specified io.Reader to the specified destination.

Types

type CountingReader added in v1.4.0

type CountingReader struct {
	Reader  io.ReadCloser
	Current int64
}

CountingReader is a reader that keeps track of how much has been read

func (*CountingReader) Close added in v1.4.0

func (r *CountingReader) Close() error

Close closes the stream

func (*CountingReader) Read added in v1.4.0

func (r *CountingReader) Read(p []byte) (n int, err error)

Read reads bytes from the stream and updates the prometheus clone_progress metric according to the progress.

Jump to

Keyboard shortcuts

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