util

Documentation

Index

• Constants
• Variables
• func CalculateSizeInMB(humanReadableSize string) int
• func CanReadFile(path string) bool
• func ChownR(path string, uid, gid int) error
• func ConcatStrings(src []string, prefix string, postfix string) []string
• func FindAndSet(path string, c interface{}, value string) error
• func GenerateCACert(certPath, keyPath string, name string) error
• func GenerateSignedCert(certPath, keyPath, cn string, ips []net.IP, alternateDNS []string, ...) error
• func GetAlternateDNS(domain string) []string
• func GetBinaryDownloadURL(version, platform string) string
• func GetDNSIP(serviceCIDR string) (net.IP, error)
• func GetServiceClusterIP(serviceCIDR string) (net.IP, error)
• func IsDirectory(path string) (bool, error)
• func MaybeChownDirRecursiveToMinikubeUser(dir string) error
• func Pad(str string) string
• func ReplaceChars(src []string, replacer *strings.Replacer) []string
• func TeePrefix(prefix string, r io.Reader, w io.Writer, ...) error
• func Until(fn func() error, w io.Writer, name string, sleep time.Duration, ...)
• type DefaultDownloader
  • func (f DefaultDownloader) CacheMinikubeISOFromURL(url string) error
  • func (f DefaultDownloader) GetISOCacheFilepath(isoURL string) string
  • func (f DefaultDownloader) GetISOFileURI(isoURL string) string
  • func (f DefaultDownloader) IsMinikubeISOCached(isoURL string) bool
  • func (f DefaultDownloader) ShouldCacheMinikubeISO(isoURL string) bool
• type ISODownloader

Constants

const (
	APIServerPort      = 8443
	DefaultDNSDomain   = "cluster.local"
	DefaultServiceCIDR = "10.96.0.0/12"
)

These constants are used by both minikube

const ErrPrefix = "! "

ErrPrefix notes an error

const OutPrefix = "> "

OutPrefix notes output

Variables

var DefaultLegacyAdmissionControllers = append([]string{"Initializers"}, DefaultV114AdmissionControllers...)

DefaultLegacyAdmissionControllers are admission controllers we include with Kubernetes <1.14.0

var DefaultProgressBar getter.ProgressTracker = &progressBar{}

var DefaultV114AdmissionControllers = []string{
	"NamespaceLifecycle",
	"LimitRanger",
	"ServiceAccount",
	"DefaultStorageClass",
	"DefaultTolerationSeconds",
	"NodeRestriction",
	"MutatingAdmissionWebhook",
	"ValidatingAdmissionWebhook",
	"ResourceQuota",
}

DefaultV114AdmissionControllers are admission controllers we default to in v1.14.x

Functions

func CalculateSizeInMB

func CalculateSizeInMB(humanReadableSize string) int

CalculateSizeInMB returns the number of MB in the human readable string

func CanReadFile

func CanReadFile(path string) bool

CanReadFile returns true if the file represented by path exists and is readable, otherwise false.

func ChownR

func ChownR(path string, uid, gid int) error

ChownR does a recursive os.Chown

func ConcatStrings

func ConcatStrings(src []string, prefix string, postfix string) []string

ConcatStrings concatenates each string in the src slice with prefix and postfix and returns a new slice

func FindAndSet

func FindAndSet(path string, c interface{}, value string) error

FindAndSet sets the nested value.

func GenerateCACert

func GenerateCACert(certPath, keyPath string, name string) error

GenerateCACert generates a CA certificate and RSA key for a common name

func GenerateSignedCert

func GenerateSignedCert(certPath, keyPath, cn string, ips []net.IP, alternateDNS []string, signerCertPath, signerKeyPath string) error

GenerateSignedCert generates a signed certificate and key

func GetAlternateDNS

func GetAlternateDNS(domain string) []string

GetAlternateDNS returns a list of alternate names for a domain

func GetBinaryDownloadURL

func GetBinaryDownloadURL(version, platform string) string

GetBinaryDownloadURL returns a suitable URL for the platform

func GetDNSIP

func GetDNSIP(serviceCIDR string) (net.IP, error)

GetDNSIP returns x.x.x.10 of the service CIDR

func GetServiceClusterIP

func GetServiceClusterIP(serviceCIDR string) (net.IP, error)

GetServiceClusterIP returns the first IP of the ServiceCIDR

func IsDirectory

func IsDirectory(path string) (bool, error)

IsDirectory checks if path is a directory

func MaybeChownDirRecursiveToMinikubeUser

func MaybeChownDirRecursiveToMinikubeUser(dir string) error

MaybeChownDirRecursiveToMinikubeUser changes ownership of a dir, if requested

func Pad

func Pad(str string) string

Pad pads the string with newlines

func ReplaceChars

func ReplaceChars(src []string, replacer *strings.Replacer) []string

ReplaceChars returns a copy of the src slice with each string modified by the replacer

func TeePrefix

func TeePrefix(prefix string, r io.Reader, w io.Writer, logger func(format string, args ...interface{})) error

TeePrefix copies bytes from a reader to writer, logging each new line.

func Until

func Until(fn func() error, w io.Writer, name string, sleep time.Duration, done <-chan struct{})

Until endlessly loops the provided function until a message is received on the done channel. The function will wait the duration provided in sleep between function calls. Errors will be sent on provider Writer.

Types

type DefaultDownloader

type DefaultDownloader struct{}

DefaultDownloader is the default ISODownloader

func (DefaultDownloader) CacheMinikubeISOFromURL

func (f DefaultDownloader) CacheMinikubeISOFromURL(url string) error

CacheMinikubeISOFromURL downloads the ISO, if it doesn't exist in cache

func (DefaultDownloader) GetISOCacheFilepath

func (f DefaultDownloader) GetISOCacheFilepath(isoURL string) string

GetISOCacheFilepath returns the path of an ISO in the local cache

func (DefaultDownloader) GetISOFileURI

func (f DefaultDownloader) GetISOFileURI(isoURL string) string

GetISOFileURI gets the local destination for a remote source

func (DefaultDownloader) IsMinikubeISOCached

func (f DefaultDownloader) IsMinikubeISOCached(isoURL string) bool

IsMinikubeISOCached returns if an ISO exists in the local cache

func (DefaultDownloader) ShouldCacheMinikubeISO

func (f DefaultDownloader) ShouldCacheMinikubeISO(isoURL string) bool

ShouldCacheMinikubeISO returns if we need to download the ISO

type ISODownloader

type ISODownloader interface {
	GetISOFileURI(isoURL string) string
	CacheMinikubeISOFromURL(isoURL string) error
}

ISODownloader downloads an ISO